Enum Request

pub enum Request {
    Array(Vec<Request>),
    BulkString(BulkString),
    BulkStatic(&'static [u8]),
    BulkInteger(i64),
    String(ByteString),
    Integer(i64),
}

A single RESP value, this owns the data that is to-be written to Redis.

It is cloneable to allow multiple copies to be delivered in certain circumstances, e.g. multiple subscribers to the same topic.

Variants

Array(Vec<Request>)

Zero, one or more other Reqeestss.

BulkString(BulkString)

A bulk string. In Redis terminology a string is a byte-array, so this is stored as a vector of u8s to allow clients to interpret the bytes as appropriate.

BulkStatic(&'static [u8])

A bulk string. In Redis terminology a string is a byte-array, so this is stored as a vector of u8s to allow clients to interpret the bytes as appropriate.

BulkInteger(i64)

Convert integer to string representation.

String(ByteString)

A valid utf-8 string

Integer(i64)

Redis documentation defines an integer as being a signed 64-bit integer: https://redis.io/topics/protocol#resp-integers

Implementations

impl Request

pub fn from_static(data: &'static str) -> Self

Create request from static str

pub fn from_bstatic(data: &'static [u8]) -> Self

Create request from static str

pub fn add<T>(self, other: T) -> Self

where Request: From<T>,

Convenience function for building dynamic Redis commands with variable numbers of arguments, e.g. RPUSH

Self get converted to array if it is not an array.

pub fn extend<T>(self, other: impl IntoIterator<Item = T>) -> Self

where Request: From<T>,

Convenience function for building dynamic Redis commands with variable numbers of arguments, e.g. RPUSH

Self get converted to array if it is not an array.

Trait Implementations

impl Clone for Request

fn clone(&self) -> Request

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Request

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

Formats the value using the given formatter.

impl<T> From<T> for Request

where BulkString: From<T>,

fn from(val: T) -> Request

Converts to this type from the input type.

impl From<i16> for Request

fn from(val: i16) -> Request

Converts to this type from the input type.

impl From<i32> for Request

fn from(val: i32) -> Request

Converts to this type from the input type.

impl From<i64> for Request

fn from(val: i64) -> Request

Converts to this type from the input type.

impl From<i8> for Request

fn from(val: i8) -> Request

Converts to this type from the input type.

impl From<u16> for Request

fn from(val: u16) -> Request

Converts to this type from the input type.

impl From<u32> for Request

fn from(val: u32) -> Request

Converts to this type from the input type.

impl From<u8> for Request

fn from(val: u8) -> Request

Converts to this type from the input type.

impl From<usize> for Request

fn from(val: usize) -> Request

Converts to this type from the input type.

impl Hash for Request

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Request

fn eq(&self, other: &Request) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Service<Request> for Client

type Response = Response

Responses given by the service.

type Error = Error

Errors produced by the service when polling readiness or executing call.

async fn ready(&self, _: ServiceCtx<'_, Self>) -> Result<(), Self::Error>

Returns when the service is able to process requests.

async fn call( &self, req: Request, _: ServiceCtx<'_, Self>, ) -> Result<Response, Error>

Process the request and return the response asynchronously.

async fn shutdown(&self)

Shutdown service.

fn poll(&self, cx: &mut Context<'_>) -> Result<(), Self::Error>

Polls service from the current task.

fn map<F, Res>(self, f: F) -> ServiceChain<Map<Self, F, Req, Res>, Req>

where Self: Sized, F: Fn(Self::Response) -> Res,

Map this service’s output to a different type, returning a new service of the resulting type.

fn map_err<F, E>(self, f: F) -> ServiceChain<MapErr<Self, F, E>, Req>

where Self: Sized, F: Fn(Self::Error) -> E,

Map this service’s error to a different error, returning a new service.

impl Eq for Request

impl StructuralPartialEq for Request