kevy 3.18.0

kevy — a pure-Rust, zero-dependency, Redis-compatible KV server.
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

use super::*;
use kevy_index::{IndexKind, ValType};

fn spec(name: &str) -> IndexSpec {
    IndexSpec {
        name: name.into(),
        prefix: b"user:".to_vec(),
        field: b"age".to_vec(),
        ty: ValType::I64,
        kind: IndexKind::Range,
        ann: None,
        max_bytes: 0,
        group_by: None,
    }
}

fn install_one(name: &str) {
    let mut c = Catalog::new();
    c.create(spec(name)).unwrap();
    install_catalog(c);
}

#[test]
fn hook_backfill_and_query_lifecycle() {
    let mut store = Store::new();
    // Pre-existing rows (to be backfilled).
    store.hset(b"user:1", &[(b"age".to_vec(), b"30".to_vec())]).unwrap();
    store.hset(b"user:2", &[(b"age".to_vec(), b"25".to_vec())]).unwrap();
    store.hset(b"user:bad", &[(b"age".to_vec(), b"x".to_vec())]).unwrap();
    install_one("t_age");

    // Live write during Building: hook double-writes.
    on_write(&mut store, b"user:3");
    assert!(segment_building(&mut store, b"t_age"));
    assert!(with_ready_segment(&mut store, b"t_age", |_, _| ()).is_err());

    // user:3 has no hash yet — create it and write again (HSET path).
    store.hset(b"user:3", &[(b"age".to_vec(), b"40".to_vec())]).unwrap();
    on_write(&mut store, b"user:3");

    // Tick drains the backfill.
    on_tick(&mut store);
    let (hits, stats) = with_ready_segment(&mut store, b"t_age", |spec, seg| {
        let min = IndexValue::parse_literal(spec.ty, b"0").unwrap();
        let max = IndexValue::parse_literal(spec.ty, b"100").unwrap();
        (seg.range(&min, &max, None, 10).0, seg.stats())
    })
    .unwrap();
    assert_eq!(hits.len(), 3, "2 backfilled + 1 live");
    assert_eq!(hits[0].0, b"user:2".to_vec());
    assert_eq!(stats.coerce_failures, 1, "user:bad excluded");

    // Update moves the row; delete removes it.
    store.hset(b"user:1", &[(b"age".to_vec(), b"99".to_vec())]).unwrap();
    on_write(&mut store, b"user:1");
    store.del(&[b"user:2".to_vec()]);
    on_write(&mut store, b"user:2");
    let hits = with_ready_segment(&mut store, b"t_age", |spec, seg| {
        let min = IndexValue::parse_literal(spec.ty, b"0").unwrap();
        let max = IndexValue::parse_literal(spec.ty, b"100").unwrap();
        seg.range(&min, &max, None, 10).0
    })
    .unwrap();
    assert_eq!(hits.len(), 2);
    assert_eq!(hits.last().unwrap().0, b"user:1".to_vec());
    assert_eq!(hits.last().unwrap().1, IndexValue::I64(99));

    install_catalog(Catalog::new()); // cleanup for other tests
}