Skip to main content

Module multiplexer

Module multiplexer 

Source
Expand description

PostgreSQL MultiplexerStore implementation.

Records (event_id, subscriber_id) completion rows in the configured relation. mark_completed uses INSERT ... ON CONFLICT DO NOTHING so concurrent or redelivered calls converge without conflict.

Structsยง

PgMultiplexerStore
PgMultiplexerStoreConfig