cratestack_sqlx/backplane.rs
1//! Subscription backplanes (`docs/design/subscriptions-websocket.md` ยง4):
2//! [`InProcessBackplane`] for one replica, [`PgNotifyBackplane`] for many.
3//!
4//! Both fan out locally the same way ([`LocalHub`](cratestack_core::backplane::LocalHub)),
5//! which lives in `cratestack-core` with [`InProcessBackplane`], so a
6//! `db = None` service can use it without sqlx.
7
8pub(crate) mod notify_payload;
9mod pg_notify;
10
11pub use cratestack_core::backplane::{InProcessBackplane, SUBSCRIPTION_BUFFER_CAPACITY};
12pub use pg_notify::PgNotifyBackplane;
13
14#[cfg(test)]
15mod tests;