wedb_standalone 0.1.2

Standalone server foundation: RESP protocol, AOF logic layer, and node service orchestration
1
2
3
4
5
6
7
8
9
10
11
12
13
14
//! 发布订阅域(对标 libs/server/PubSub/*)
//!
//! C# 侧 SubscribeBroker 以 TsavoriteLog 专日志为分发介质,后台任务消费并
//! 回放进会话输出缓冲;Rust 侧以待发队列 + 同步收敛点承接同等三面
//! (发布入队 / 消费广播 / 即时直投),订阅者经 [`PubSubSink`] 投递面解耦。
//! 订阅表为 papaya 无锁并发表(whasher 统一出口),广播遍历不阻塞订阅变更。

pub mod pattern_subscription_entry;
pub mod subscribe_broker;
pub mod subscriber;

pub use pattern_subscription_entry::PatternSubscriptionEntry;
pub use subscribe_broker::SubscribeBroker;
pub use subscriber::{PubSubMailbox, PubSubMessage, PubSubMessageKind, PubSubSink};