[−][src]Struct rumqttlog::router::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
Implementations
impl DataRequest
[src]
pub fn new(topic: String, qos: u8) -> DataRequest
[src]
New data request with offsets starting from 0
pub fn offsets(
topic: String,
qos: u8,
cursor: (u64, u64),
last_retain: u64
) -> DataRequest
[src]
topic: String,
qos: u8,
cursor: (u64, u64),
last_retain: u64
) -> DataRequest
New data request with provided offsets
Trait Implementations
impl Clone for DataRequest
[src]
pub fn clone(&self) -> DataRequest
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for DataRequest
[src]
impl<'de> Deserialize<'de> for DataRequest
[src]
pub fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl PartialEq<DataRequest> for DataRequest
[src]
pub fn eq(&self, other: &DataRequest) -> bool
[src]
pub fn ne(&self, other: &DataRequest) -> bool
[src]
impl Serialize for DataRequest
[src]
pub fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
__S: Serializer,
[src]
__S: Serializer,
impl StructuralPartialEq for DataRequest
[src]
Auto Trait Implementations
impl RefUnwindSafe for DataRequest
[src]
impl Send for DataRequest
[src]
impl Sync for DataRequest
[src]
impl Unpin for DataRequest
[src]
impl UnwindSafe for DataRequest
[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
T: for<'de> Deserialize<'de>,
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,