beyond-slipstream 0.1.0

Watchable distributed config over NATS JetStream — cache locally, stream updates, resume from a sequence number after any restart.
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

//! Shared KV store abstraction for Beyond services.
//!
//! This crate provides a backend-agnostic interface for key-value storage,
//! with NATS JetStream as the primary implementation.
//!
//! # Architecture
//!
//! ```text
//! ┌─────────────────────────────────────────────────────────────┐
//! │              KvReader │ KvWatcher │ KvWriter                │
//! │                 (core KV operations)                        │
//! ├─────────────────────────────────────────────────────────────┤
//! │                        KvStore                              │
//! │            (named bucket with reader/watcher/writer)        │
//! ├─────────────────────────────────────────────────────────────┤
//! │                       Connection                            │
//! │              (lifecycle, store factory, capabilities)       │
//! ├─────────────────────────────────────────────────────────────┤
//! │                    NatsConnection                           │
//! │               (concrete implementation)                     │
//! └─────────────────────────────────────────────────────────────┘
//! ```

#![deny(unsafe_code)]

mod kv;
mod nats;
pub mod snapshot;
mod stores;

pub use kv::{
    KvEntry, KvError, KvReader, KvTtl, KvUpdate, KvWatcher, KvWriter, VersionToken, WatchCursor,
};
pub use nats::{NatsConnection, NatsConnectionConfig, nats_connect};
pub use stores::{Connection, ConnectionCapabilities, KvStore, StorageType, StoreConfig};