pub struct Message<C> where
C: Encoder + Decoder + Debug, {
pub header: MsgType,
pub content: C,
}
impl<C> Message<C> where
C: Encoder + Decoder + Debug,
[src]
impl<C> Debug for Message<C> where
C: Debug + Encoder + Decoder,
[src]
Formats the value using the given formatter. Read more
impl<C> Decoder for Message<C> where
C: Encoder + Decoder + Debug,
[src]
decode Kafka compliant protocol values from buf
Returns the “default value” for a type. Read more
Formats the value using the given formatter. Read more
impl<C> Encoder for Message<C> where
C: Encoder + Decoder + Debug,
[src]
encoding contents for buffer
size of this object in bytes
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
impl<T> Any for T where
T: 'static + ?Sized,
[src]
Immutably borrows from an owned value. Read more
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Instruments this type with the current Span
, returning an
Instrumented
wrapper. Read more
impl<T, U> Into<U> for T where
U: From<T>,
[src]
The resulting type after obtaining ownership.
Creates owned data from borrowed data, usually by cloning. Read more
🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more
Converts the given value to a String
. Read more
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
The type returned in the event of a conversion error.
The type returned in the event of a conversion error.