Struct copra::codec::ProtobufCodec

pub struct ProtobufCodec<T, U> { /* fields omitted */ }

Codec for protobuf messages

Methods

impl<T, U> ProtobufCodec<T, U>

fn new() -> Self

Create a new instance of the protobuf codec.

Trait Implementations

impl<T: Clone, U: Clone> Clone for ProtobufCodec<T, U>

fn clone(&self) -> ProtobufCodec<T, U>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug, U: Debug> Debug for ProtobufCodec<T, U>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<T, U> MethodCodec for ProtobufCodec<T, U> where
    T: Message + MessageStatic,
    U: Message, 

type Request = T

Request message decoded from raw bytes

type Response = U

Response message for encoding to raw bytes

type Error = ProtobufError

Error during decoding or encoding

fn decode(&self, buf: Bytes) -> Result<Self::Request, Self::Error>

Decode message from bytes.

fn encode(&self, msg: Self::Response) -> Result<Bytes, Self::Error>

Encode message to bytes.