WAL-S

Implementation of write-ahead log based storage.

Features

• Write-Ahead Log
• Read snapshots
• Write batching
• Metadata support
• Stateless iterators
• Stateful iterators
• Sliding window
• Counter and time based identifiers
• Distance metrics
• Data exporting

Getting started

WALS::new("stream1", db)
    .snapshot()
    .iter()
    .for_each(|record| {
        let stream2 = WALS::from("stream2", db);
        let result = process(record);
        stream2.append(result);
    })

 stream
    .flush()
    .snapshot()
    .unwrap()
    .window(10, &StreamID::default())
    .for_each(|batch| {
        println!("size={}", batch.len());
        assert_eq!(batch.len(), 10);
        counter += 1;
    });

Docs

TBD