Structs§
- Abort
OnDrop 🔒 - Catch
UpConfig - Configuration for catching up on historical messages
- Messages
Manager - High-level messages manager that provides a unified interface for message operations.
- Messages
Manager Builder - Builder for creating MessagesManager instances with persistent state support.
Enums§
- Message
Event - Comprehensive message event that covers all message flows for persistence and monitoring.
Traits§
- Messages
Manager Trait - Trait abstraction for MessagesManager to enable mocking in tests
Functions§
- subscription_
state_ 🔒to_ config - Convert SubscriptionState to SubscriptionConfig for wire protocol