tarantool::network::protocol::api

Trait Request

pub trait Request {
    type Response: Sized;

    const TYPE: IProtoType;

    // Required methods
    fn encode_body(&self, out: &mut impl Write) -> Result<(), Error>;
    fn decode_response_body(
        in: &mut Cursor<Vec<u8>>,
    ) -> Result<Self::Response, Error>;

    // Provided methods
    fn encode_header(
        &self,
        out: &mut impl Write,
        sync: SyncIndex,
    ) -> Result<(), Error> { ... }
    fn encode(&self, out: &mut impl Write, sync: SyncIndex) -> Result<(), Error> { ... }
}

Required Associated Constants§

const TYPE: IProtoType

Required Associated Types§

type Response: Sized

Required Methods§

fn encode_body(&self, out: &mut impl Write) -> Result<(), Error>

fn decode_response_body( in: &mut Cursor<Vec<u8>>, ) -> Result<Self::Response, Error>

Provided Methods§

fn encode_header( &self, out: &mut impl Write, sync: SyncIndex, ) -> Result<(), Error>

fn encode(&self, out: &mut impl Write, sync: SyncIndex) -> Result<(), Error>

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§

impl Request for Auth<'_, '_, '_>

const TYPE: IProtoType = IProtoType::Auth

type Response = ()

impl Request for Ping

const TYPE: IProtoType = IProtoType::Ping

type Response = ()

impl<T> Request for Call<'_, '_, T>
where T: ToTupleBuffer + ?Sized,

const TYPE: IProtoType = IProtoType::Call

type Response = Tuple

impl<T> Request for Delete<'_, T>
where T: ToTupleBuffer + ?Sized,

const TYPE: IProtoType = IProtoType::Delete

type Response = Option<Tuple>

impl<T> Request for Eval<'_, '_, T>
where T: ToTupleBuffer + ?Sized,

const TYPE: IProtoType = IProtoType::Eval

type Response = Tuple

impl<T> Request for Execute<'_, '_, T>
where T: ToTupleBuffer + ?Sized,

const TYPE: IProtoType = IProtoType::Execute

type Response = Vec<Tuple>

impl<T> Request for Insert<'_, T>
where T: ToTupleBuffer + ?Sized,

const TYPE: IProtoType = IProtoType::Insert

type Response = Option<Tuple>

impl<T> Request for Replace<'_, T>
where T: ToTupleBuffer + ?Sized,

const TYPE: IProtoType = IProtoType::Replace

type Response = Option<Tuple>

impl<T> Request for Select<'_, T>
where T: ToTupleBuffer + ?Sized,

const TYPE: IProtoType = IProtoType::Select

type Response = Vec<Tuple>

impl<T, Op> Request for Update<'_, T, Op>
where T: ToTupleBuffer + ?Sized, Op: Encode,

const TYPE: IProtoType = IProtoType::Update

type Response = Option<Tuple>

impl<T, Op> Request for Upsert<'_, T, Op>
where T: ToTupleBuffer + ?Sized, Op: Encode,

const TYPE: IProtoType = IProtoType::Upsert

type Response = Option<Tuple>