Skip to main content

Module multiplexer_store

Module multiplexer_store 

Source
Expand description

SQLite MultiplexerStore implementation.

Records (event_id, subscriber_id) completion rows in the configured relation. Event ids are stored as TEXT (UUID string) since SQLite has no native UUID type. mark_completed uses INSERT ... ON CONFLICT DO NOTHING so concurrent or redelivered calls converge. All SQLite work runs in spawn_blocking.

Structsยง

SqliteMultiplexerStore
SqliteMultiplexerStoreConfig