photon-backend 0.1.0

Photon publish/subscribe backend implementations and storage adapters
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! Storage adapter port — one implementation per `--storage` tier (`mem`, `sqlite`, `nats`, `fluvio`, `kafka`).
//!
//! [`StoragePort`] is the primary extension point. [`GenericPhotonBackend`](crate::backend::GenericPhotonBackend)
//! maps [`PhotonBackend`](crate::backend::PhotonBackend) calls onto port methods.
//!
//! ## Contract summary
//!
//! | Method | Role |
//! |--------|------|
//! | `append` | Persist one event; assign monotonic `seq` per partition |
//! | `subscribe` | Stream events; optional replay after `after_seq` |
//! | `get_checkpoint_seq` / `set_checkpoint` | Durable subscription cursors |
//! | `get_event` | Optional point lookup (`mem` / `sqlite`; brokers set `supports_get_event: false`) |
//!
//! ## Capabilities
//!
//! | Field | `mem` / `sqlite` | Brokers |
//! |-------|------------------|---------|
//! | `supports_get_event` | `true` | `false` |
//! | `max_replay_window` | unbounded / file-backed | ~15 min broker retention |
//!
//! See also: [`crate::checkpoint`], [`crate::retention`], [`crate::backend`].

mod partition;
mod in_proc;
mod port;

pub use in_proc::InProcStoragePort;
pub use port::{StorageCapabilities, StoragePort};
pub use partition::topic_filter_matches;