Struct rumqttlog::router::DataRequest

pub struct DataRequest { /* fields omitted */ }

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

Implementations

impl DataRequest

pub fn new(topic: String, qos: u8) -> DataRequest

New data request with offsets starting from 0

pub fn offsets(
    topic: String,
    qos: u8,
    cursor: (u64, u64),
    last_retain: u64
) -> DataRequest

New data request with provided offsets

Trait Implementations

impl Clone for DataRequest

fn clone(&self) -> DataRequest

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DataRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DataRequest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl PartialEq<DataRequest> for DataRequest

fn eq(&self, other: &DataRequest) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &DataRequest) -> bool

This method tests for !=.

impl Serialize for DataRequest

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for DataRequest