Struct copra::protocol::ProtoCodec

pub struct ProtoCodec { /* fields omitted */ }

Server side codec that can deduce protocol from byte stream

Server can provide services to clients that use different protocols. When a new connection is established, the server try each protocol until it succeeds in decoding the request. Since copra use keep-alive connections to exchange messages, this match is cached so that the protocol resolution overhead is only incurred when receiving the first request.

Methods

impl ProtoCodec

fn new(protos: &[Box<RpcProtocol>]) -> Self

Create a new codec that support multiple protocols.

Trait Implementations

impl Debug for ProtoCodec

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

Formats the value using the given formatter.

impl Decoder for ProtoCodec

type Item = (RequestId, RequestPackage)

The type of decoded frames.

type Error = Error

The type of unrecoverable frame decoding errors.

fn decode(
    &mut self,
    buf: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>

Attempts to decode a frame from the provided buffer of bytes.

fn decode_eof(
    &mut self,
    buf: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>

A default method available to be called when there are no more bytes available to be read from the underlying I/O.

impl Encoder for ProtoCodec

type Item = (RequestId, ResponsePackage)

The type of items consumed by the Encoder

type Error = Error

The type of encoding errors.

fn encode(
    &mut self,
    msg: Self::Item,
    buf: &mut BytesMut
) -> Result<(), Self::Error>

Encodes a frame into the buffer provided.