Struct rpc_pb::Request

pub struct Request<'a> {
    pub service: &'a str,
    pub method: &'a str,
    pub seq_no: u64,
    pub body: &'a [u8],
    pub caller: Vec<ClientID>,
    pub trace: Option<TraceID>,
}

A request to a server.

Fields

service: &'a str

The service this request is intended for.

method: &'a str

The method this request intends to call.

seq_no: u64

A client-provided sequence number used to match requests to responses.

body: &'a [u8]

The body of the request.

caller: Vec<ClientID>

A chain of callers.

trace: Option<TraceID>

The trace ID for this request.

Trait Implementations

impl<'a> Clone for Request<'a>

fn clone(&self) -> Request<'a>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Request<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> Default for Request<'a>

fn default() -> Request<'a>

Returns the “default value” for a type.

impl<'a> FieldPackHelper<'a, message<Request<'a>>> for Request<'a>

fn field_pack_sz(&self, tag: &Tag) -> usize

The size of encoding self with tag.

fn field_pack(&self, tag: &Tag, out: &mut [u8])

Pack the tag into the output buffer.

impl<'a> FieldUnpackHelper<'a, message<Request<'a>>> for Request<'a>

fn merge_field(&mut self, proto: message<Request<'a>>)

Merge the proto into self.

impl<'a> From<&Request<'a>> for Context

fn from(req: &Request<'a>) -> Self

Converts to this type from the input type.

impl<'a> From<message<Request<'a>>> for Request<'a>

fn from(proto: message<Self>) -> Self

Converts to this type from the input type.

impl<'a> Packable for Request<'a>

fn pack_sz(&self) -> usize

pack_sz returns the number of bytes required to serialize the Packable object.

fn pack(&self, buf: &mut [u8])

pack fills in the buffer out with the packed binary representation of the Packable object. The implementor is responsible to ensure that out is exactly pack_sz() bytes and implementations are encouraged to assert this.

fn stream<W: Write>(&self, writer: &mut W) -> Result<usize, Error>

stream writes the object to the provided writer using the same representation that would be used in a call to pack. The implementor is responsible for making sure that the number of bytes written is exactly equal to the number of required bytes.

impl<'a> Unpackable<'a> for Request<'a>

type Error = Error

Type of error this unpackable returns.

fn unpack<'b>(buf: &'b [u8]) -> Result<(Self, &'b [u8]), Error>

where 'b: 'a,

unpack attempts to return an Unpackable object stored in a prefix of buf. The method returns the result and remaining unused buffer.

impl<'a> Message<'a> for Request<'a>