[−][src]Module rumqttlog::router
Structs
| Acks | |
| AcksRequest | |
| Data | |
| DataRequest | Request that connection/linker makes to extract data from commitlog NOTE Connection can make one sweep request to get data from multiple topics but we'll keep it simple for now as multiple requests in one message can makes constant extraction size harder |
| Disconnection | |
| Message | |
| ReplicationAck | Replication connection frames this after receiving an ack from other replica This is used by router to update watermarks, which is used to send acks for replicated data |
| ReplicationData | Data sent router to be written to commitlog |
| Router | |
| Topics | |
| TopicsRequest | |
| Tracker | Used to register a new connection with the router Connection messages encompasses a handle for router to communicate with this connection |
Enums
| ConnectionAck | |
| Event | Messages from connection to router |
| Notification | Notification from router to connection |
| Request | Requests for pull operations |