sqlitegraph 2.0.7

Embedded graph database with full ACID transactions, HNSW vector search, dual backend support, and comprehensive graph algorithms library
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

//! In-process pub/sub for SQLiteGraph
//!
//! Minimal, best-effort pub/sub system with:
//! - ID-only events (no payloads)
//! - Emitted on commit only
//! - In-process channel delivery
//! - No persistence or delivery guarantees
//!
//! # Architecture
//!
//! Events are emitted when transactions commit and carry only identifiers
//! (node_id, edge_id, key_hash, snapshot_id). Consumers must read actual
//! data from the graph/KV APIs using the provided snapshot_id.
//!
//! # Module Organization
//!
//! - [`event`](crate::backend::native::v2::pubsub::event): Event type definitions
//! - [`subscriber`](crate::backend::native::v2::pubsub::subscriber): Subscription management
//! - [`publisher`](crate::backend::native::v2::pubsub::publisher): Channel-based event delivery
//! - [`emit`](crate::backend::native::v2::pubsub::emit): WAL record to event conversion
//!
//! # Pub/Sub Integration Tests
//!
//! The test suite validates:
//! - Event emission on commit (not rollback)
//! - All event types (NodeChanged, EdgeChanged, KVChanged, SnapshotCommitted)
//! - Filter behavior by event type and entity IDs
//! - Multiple subscribers receive independent events
//! - Unsubscribe stops event delivery
//! - Best-effort delivery (no panic on dropped receiver)
//!
//! Run tests with: `cargo test --lib pubsub`

pub mod emit;
pub mod event;
pub mod publisher;
pub mod subscriber;

pub use emit::{records_to_events, should_emit_event};
pub use event::{PubSubEvent, PubSubEventType};
pub use publisher::Publisher;
pub use subscriber::{NodeMetadata, Subscriber, SubscriberId, SubscriptionFilter};

#[cfg(test)]
mod tests;