Function stream_buffer_push_and_read

nodedb/tests/event_cdc.rs:17–31

()

#[test]
fn stream_buffer_push_and_read() {
    let buf = StreamBuffer::new("orders_stream".to_string(), RetentionConfig::default());
    buf.push(make_cdc_event(1, 0, "orders", "INSERT"));
    buf.push(make_cdc_event(2, 0, "orders", "UPDATE"));
    buf.push(make_cdc_event(3, 1, "orders", "INSERT"));

    let all = buf.read_from_lsn(0, 100);
    assert_eq!(all.len(), 3);

    let p0 = buf.read_partition_from_lsn(0, 0, 100);
    assert_eq!(p0.len(), 2);

    let p1 = buf.read_partition_from_lsn(1, 0, 100);
    assert_eq!(p1.len(), 1);
}

#[test]
fn stream_buffer_retention_evicts_oldest() {