Skip to content

[DIFF] Built-in pub/sub messaging — real-time message queue inside the KV store #209

@ElioNeto

Description

@ElioNeto

Differentiator

No embedded KV store offers built-in pub/sub. Eliminates need for Redis/NATS alongside ApexStore.

Description

Subscribe to key patterns and receive real-time notifications on data changes:

let mut sub = engine.subscribe("orders/**")
loop { let event = sub.recv().await }

Implementation

  • tokio broadcast channels
  • Glob-style pattern matching
  • Durable subscriptions (survive restarts)
  • WebSocket endpoint: /ws/keys?pattern=orders/**

Impact

  • Eliminates separate message broker
  • Real-time UIs without polling
  • One less dependency for event-driven apps

Metadata

Metadata

Assignees

No one assigned

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions