[−][src]Struct rumqttlog::router::DataRequest

pub struct DataRequest {
    pub topic: String,
    pub segment: u64,
    pub offset: u64,
    pub size: u64,
}

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

Fields

topic: String

Log to sweep

segment: u64

Segment id of the log.

offset: u64

Current offset. For requests, this is where sweeps start from. For reply, this is the last offset

size: u64

Request Size / Reply size

Trait Implementations

impl Clone for DataRequest[src]

impl Debug for DataRequest[src]

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T> ToOwned for T where
    T: Clone, [src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.