Structs§
- Catch
UpRequest - Type-safe catch-up request for historical messages
- Catch
UpResponse - Catch-up response with historical messages
- Filter
Update Request - Generic filter update request
- Message
Filters - Message filtering criteria for querying stored messages
- Message
Service Client - The client stub that makes RPC calls to the server. All request methods return Futures.
- Serve
Message Service - A serving function to use with [::tarpc::server::InFlightRequest::execute].
- Subscription
Config
Enums§
- Filter
- Unified filter type for different kinds of message filtering
- Filter
Operation - Type-safe filter operations using unified Filter type
- Message
Error - Error types for message operations
- Message
Service Request - The request sent over the wire from the client to the server.
- Message
Service Response - The response sent over the wire from the server to the client.
- Message
Service Response Wrap - Publish
Result - Result of publishing a message to the relay
- Stream
Message - Messages sent over the streaming protocol
Traits§
- Message
Service - Message store service for message interaction operations
- Message
Service Stub - The stub trait for service
MessageService.
Type Aliases§
- Message
Result - Result type for message operations
- Messages
Service Request Wrap - Simplified request wrapper - now just RPC requests All subscription, filter updates, and catch-up requests are now handled as RPC calls