hydracache 0.59.0

User-facing HydraCache runtime crate.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use super::{
    CacheInvalidation, CacheInvalidationFrame, CacheInvalidationMessage,
    CACHE_INVALIDATION_FRAME_VERSION,
};

#[test]
fn frame_version_compat_current_wire_version_round_trips() {
    let frame = CacheInvalidationFrame::new(CacheInvalidationMessage::new(
        "member-a",
        CacheInvalidation::tag("users"),
    ))
    .with_cluster_name("orders")
    .with_message_id(7);

    let encoded = frame.encode().unwrap();
    let decoded = CacheInvalidationFrame::decode(&encoded).unwrap();

    assert_eq!(decoded.version(), CACHE_INVALIDATION_FRAME_VERSION);
    assert_eq!(decoded.cluster_name(), Some("orders"));
    assert_eq!(decoded.message_id(), Some(7));
    assert_eq!(decoded.invalidation().tag_value(), Some("users"));
}

#[test]
fn frame_version_compat_future_wire_version_fails_closed() {
    let mut frame = CacheInvalidationFrame::new(CacheInvalidationMessage::new(
        "member-a",
        CacheInvalidation::flush(),
    ));
    frame.version = CACHE_INVALIDATION_FRAME_VERSION + 1;

    let encoded = frame.encode().unwrap();
    let error = CacheInvalidationFrame::decode(&encoded).unwrap_err();

    assert!(error
        .to_string()
        .contains("unsupported invalidation frame version"));
}