Function persistence_save_and_load

nodedb/tests/event_streaming_mv.rs:168–202

()

#[test]
fn persistence_save_and_load() {
    let dir = tempfile::tempdir().unwrap();
    let persist = MvPersistence::open(dir.path()).unwrap();

    let snapshot = vec![
        (
            "INSERT".to_string(),
            vec![GroupState {
                count: 5,
                sum: 100.0,
                min: Some(10.0),
                max: Some(50.0),
                finalized: false,
                latest_event_time: 5000,
            }],
        ),
        (
            "UPDATE".to_string(),
            vec![GroupState {
                count: 3,
                sum: 30.0,
                min: Some(5.0),
                max: Some(15.0),
                finalized: true,
                latest_event_time: 3000,
            }],
        ),
    ];

    persist.save(1, "order_stats", &snapshot).unwrap();
    let loaded = persist.load(1, "order_stats").unwrap().unwrap();
    assert_eq!(loaded.len(), 2);
    assert_eq!(loaded[0].1[0].count, 5);
    assert!(loaded[1].1[0].finalized);
}

#[test]
fn persistence_survives_reopen() {