Crate eventuary_sqlite 

SQLite event log backend for eventuary.

Append-only events table with auto-incrementing sequence. Reader streams events in sequence order and supports consumer groups via a consumer_offsets table scoped by (consumer_group_id, stream_id, partition, partition_count).

ack advances the checkpoint, nack leaves it unchanged. SQLite work runs in tokio::task::spawn_blocking to avoid blocking the async runtime.

Also ships sqlite-backed implementations of the IO store traits:

• SqliteMultiplexerStore
• SqliteBufferStore
• SqliteDedupeStore
• SqliteCheckpointStore
• SqliteWatermarkStore

Re-exports

pub use buffer_store::SqliteBufferStore;

pub use buffer_store::SqliteBufferStoreConfig;

pub use buffer_store::SqliteBufferStoreId;

pub use checkpoint_store::SqliteCheckpointStore;

pub use checkpoint_store::SqliteCheckpointStoreConfig;

pub use dedupe_store::SqliteDedupeStore;

pub use dedupe_store::SqliteDedupeStoreConfig;

pub use multiplexer_store::SqliteMultiplexerStore;

pub use multiplexer_store::SqliteMultiplexerStoreConfig;

pub use watermark_store::SqliteWatermarkStore;

pub use watermark_store::SqliteWatermarkStoreConfig;

Modules

buffer_store

SQLite BufferStore implementation.

checkpoint_store

database

dedupe_store

SQLite DedupeStore implementation.

multiplexer_store

SQLite MultiplexerStore implementation.

reader

relation

watermark_store

SQLite WatermarkStore implementation.

writer