Enum cuprate_levin::message::LevinMessage

pub enum LevinMessage<T: LevinBody> {
    Body(T),
    Bucket(Bucket<T::Command>),
    Dummy(usize),
}

A levin message that can be sent to a peer.

Variants

Body(T)

A message body.

A levin header will be added to this message before it is sent to the peer.

Bucket(Bucket<T::Command>)

A full levin bucket.

This bucket will be sent to the peer directly with no extra information.

This should only be used to send fragmented messages: make_fragmented_messages

Dummy(usize)

A dummy message.

A dummy message which the peer will ignore. The dummy message will be the exact size (in bytes) of the given usize on the wire.

Trait Implementations

impl<T: LevinBody> Encoder<LevinMessage<T>> for LevinMessageCodec<T>

type Error = BucketError

The type of encoding errors.

fn encode( &mut self, item: LevinMessage<T>, dst: &mut BytesMut, ) -> Result<(), Self::Error>

Encodes a frame into the buffer provided.

impl<T: LevinBody> From<Bucket<<T as LevinBody>::Command>> for LevinMessage<T>

fn from(value: Bucket<T::Command>) -> Self

Converts to this type from the input type.

impl<T: LevinBody> From<Dummy> for LevinMessage<T>

fn from(value: Dummy) -> Self

Converts to this type from the input type.

impl<T: LevinBody> From<T> for LevinMessage<T>

fn from(value: T) -> Self

Converts to this type from the input type.

Layout

Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.