Struct rumqttlog::router::Data [−][src]
pub struct Data {
pub topic: String,
pub qos: u8,
pub cursor: (u64, u64),
pub last_retain: u64,
pub size: usize,
pub payload: Vec<Bytes>,
}
Fields
topic: String
Log to sweep
qos: u8
Qos of the topic
cursor: (u64, u64)
(segment, offset) tuples per replica (1 native and 2 replicas)
last_retain: u64
Next retain publish id
size: usize
Payload size
payload: Vec<Bytes>
Reply data chain