Function stream_buffer_retention_evicts_oldest

nodedb/tests/event_cdc.rs:34–49

()

#[test]
fn stream_buffer_retention_evicts_oldest() {
    let retention = RetentionConfig {
        max_events: 3,
        max_age_secs: 86_400,
    };
    let buf = StreamBuffer::new("orders_stream".to_string(), retention);

    for i in 1..=5 {
        buf.push(make_cdc_event(i, 0, "orders", "INSERT"));
    }

    let events = buf.read_from_lsn(0, 100);
    assert_eq!(events.len(), 3);
    // Oldest (seq 1, 2) evicted; remaining are 3, 4, 5.
    assert_eq!(events[0].sequence, 3);
}

#[test]
fn consumer_group_offset_tracking() {