strev_postgres/lib.rs
1//! PostgreSQL backend for strev.
2//!
3//! Provides [`PostgresPublisher`] and [`PostgresSubscriber`] backed by a durable message
4//! table with per-consumer-group offset tracking. Subscribers poll for new messages and
5//! advance their offset transactionally, using `FOR UPDATE SKIP LOCKED` so competing
6//! consumers in the same group never process the same message twice.
7mod publisher;
8mod schema;
9mod subscriber;
10
11pub use publisher::{PostgresPublisher, PostgresPublisherConfig};
12pub use subscriber::{PostgresSubscriber, PostgresSubscriberConfig};