Module rumqttlog::router[][src]

Structs

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

Used to register a new connection with the router Connection messages encompasses a handle for router to communicate with this connection

Enums

Messages from connection to router

Notification from router to connection

Requests for pull operations