Trait fbthrift_git::protocol::Protocol

pub trait Protocol: 'static {
    type Frame: Framing;
    type Sizer: ProtocolWriter<Final = usize>;
    type Serializer: ProtocolWriter<Final = <<Self::Frame as Framing>::EncBuf as BufMutExt>::Final>;
    type Deserializer: ProtocolReader;

    const PROTOCOL_ID: ProtocolID;

    // Required methods
    fn serializer<SZ, SER>(
        sz: SZ,
        ser: SER
    ) -> <Self::Serializer as ProtocolWriter>::Final
       where SZ: FnOnce(&mut Self::Sizer),
             SER: FnOnce(&mut Self::Serializer);
    fn deserializer(buf: <Self::Frame as Framing>::DecBuf) -> Self::Deserializer;
    fn into_buffer(_: Self::Deserializer) -> <Self::Frame as Framing>::DecBuf;
}

An instance of Protocol glues a Framing implementation to a serializer (ProtocolWriter) and deserializer (ProtocolReader). It constructs, as needed, a serializer to construct a frame with a given protocol, or a deserializer from a frame into a stream of deserialized objects.

Required Associated Types

type Frame: Framing

Type of the framing implementation

type Sizer: ProtocolWriter<Final = usize>

Compute the size of a frame for a given protocol. This can be exact or too large, but must not be too small.

type Serializer: ProtocolWriter<Final = <<Self::Frame as Framing>::EncBuf as BufMutExt>::Final>

Serialize into a buffer. The buffer is allocated with the size computed by Sizer, so it must be large enough.

type Deserializer: ProtocolReader

Set up a deserializer from a frame’s buffer.

Required Associated Constants

const PROTOCOL_ID: ProtocolID

Required Methods

fn serializer<SZ, SER>( sz: SZ, ser: SER ) -> <Self::Serializer as ProtocolWriter>::Final

where SZ: FnOnce(&mut Self::Sizer), SER: FnOnce(&mut Self::Serializer),

fn deserializer(buf: <Self::Frame as Framing>::DecBuf) -> Self::Deserializer

fn into_buffer(_: Self::Deserializer) -> <Self::Frame as Framing>::DecBuf

Object Safety

This trait is not object safe.

Implementors

impl<F> Protocol for BinaryProtocol<F>

where F: Framing + 'static,

type Frame = F

type Sizer = BinaryProtocolSerializer<SizeCounter>

type Serializer = BinaryProtocolSerializer<<F as Framing>::EncBuf>

type Deserializer = BinaryProtocolDeserializer<<F as Framing>::DecBuf>

const PROTOCOL_ID: ProtocolID = ProtocolID::BinaryProtocol

impl<F> Protocol for CompactProtocol<F>

where F: Framing + 'static,

type Frame = F

type Sizer = CompactProtocolSerializer<SizeCounter>

type Serializer = CompactProtocolSerializer<<F as Framing>::EncBuf>

type Deserializer = CompactProtocolDeserializer<<F as Framing>::DecBuf>

const PROTOCOL_ID: ProtocolID = ProtocolID::CompactProtocol

impl<F> Protocol for SimpleJsonProtocol<F>

where F: Framing + 'static,

type Frame = F

type Sizer = SimpleJsonProtocolSerializer<SizeCounter>

type Serializer = SimpleJsonProtocolSerializer<<F as Framing>::EncBuf>

type Deserializer = SimpleJsonProtocolDeserializer<<F as Framing>::DecBuf>

const PROTOCOL_ID: ProtocolID = ProtocolID::SimpleJSONProtocol