eventuary-postgres 0.1.0

PostgreSQL event backend for eventuary
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

//! PostgreSQL event log backend for [eventuary](https://crates.io/crates/eventuary).
//!
//! Provides an append-only events table backed by `sqlx::PgPool` with source
//! cursors (`PgCursor`) ordered by `BIGSERIAL` sequence. `PgReader` is a source
//! reader: its acker advances only the active in-memory stream cursor, and nack
//! leaves the row eligible for redelivery by that stream.
//!
//! Durable consumer progress is owned by `PgCheckpointStore` and composed with
//! `eventuary_core::io::reader::CheckpointReader`. Checkpoints are keyed by
//! `(consumer_group_id, stream_id, cursor_id)` and store the full cursor as JSON.
//!
//! Schema setup is component-owned. `PgWriter::connect(pool, config).await`
//! prepares only the event-log table, while
//! `PgDedupeStore::connect(pool, config).await` prepares only the dedupe table.
//! `PgDatabase::connect(...)` only opens a pool and does not create Eventuary
//! tables.
//!
//! Also ships postgres-backed implementations of the IO store traits:
//! - [`PgMultiplexerStore`]
//! - [`PgBufferStore`]
//! - [`PgDedupeStore`]
//! - [`PgCheckpointStore`]
//! - [`PgWatermarkStore`]

pub mod buffer_store;
pub mod checkpoint_store;
pub mod claim_buffer_store;
pub mod coordinated_reader;
pub mod database;
pub mod dedupe_store;
pub mod event_log;
pub mod multiplexer_store;
pub mod partition_backfill;
pub mod partition_coordinator;
pub mod reader;
pub mod relation;
pub mod schema;
pub mod watermark_store;
pub mod writer;

pub use buffer_store::{PgBufferStore, PgBufferStoreConfig, PgBufferStoreId};
pub use checkpoint_store::{PgCheckpointStore, PgCheckpointStoreConfig};
pub use claim_buffer_store::{PgClaimedBufferStore, PgClaimedBufferStoreConfig};
pub use coordinated_reader::{
    PgCoordinatedAcker, PgCoordinatedCursor, PgCoordinatedReader, PgCoordinatedReaderConfig,
    PgCoordinatedStream, PgCoordinatedSubscription,
};
pub use dedupe_store::{PgDedupeStore, PgDedupeStoreConfig};
pub use event_log::{PgEventLogSchema, PgEventLogSchemaConfig};
pub use multiplexer_store::{PgMultiplexerStore, PgMultiplexerStoreConfig};
pub use partition_backfill::{BackfillReport, PgPartitionBackfill, PgPartitionBackfillConfig};
pub use partition_coordinator::{PgPartitionCoordinator, PgPartitionCoordinatorConfig};
pub use watermark_store::{PgWatermarkStore, PgWatermarkStoreConfig};
pub use writer::{PgPartitioningConfig, PgWriter, PgWriterConfig};