Struct libaster::protocol::redis::Cmd

pub struct Cmd { /* private fields */ }

Implementations

impl Cmd

pub fn cluster_mark_total(&self, cluster: &str)

pub fn cluster_mark_remote(&self, cluster: &str)

pub fn incr_notify(&self, count: u16)

pub fn borrow(&self) -> Ref<'_, Command>

pub fn borrow_mut(&self) -> RefMut<'_, Command>

pub fn unset_error(&self)

pub fn unset_done(&self)

pub fn set_reply<T: IntoReply<Message>>(&self, reply: T)

pub fn set_error<T: IntoReply<Message>>(&self, reply: T)

pub fn reregister(&mut self, task: Task)

pub fn set_expect(&mut self, expect: u16)

pub fn set_subs(&mut self, subs: Option<Vec<Cmd>>)

pub fn check_valid(&self) -> bool

pub fn change_info_resp(&mut self)

pub fn mk_read_all_subs(&mut self, addrs: Vec<String>)

pub fn get_addr(&self) -> Option<String>

Trait Implementations

impl Clone for Cmd

fn clone(&self) -> Cmd

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Cmd

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

Formats the value using the given formatter.

impl Drop for Cmd

fn drop(&mut self)

Executes the destructor for this type.

impl From<MessageMut> for Cmd

fn from(msg_mut: MessageMut) -> Cmd

Converts to this type from the input type.

impl Request for Cmd

type Reply = Message

type FrontCodec = RedisHandleCodec

type BackCodec = RedisNodeCodec

fn ping_request() -> Self

fn reregister(&mut self, task: Task)

fn key_hash(&self, hash_tag: &[u8], hasher: fn(_: &[u8]) -> u64) -> u64

fn subs(&self) -> Option<Vec<Self>>

fn is_done(&self) -> bool

fn is_error(&self) -> bool

fn add_cycle(&self)

fn can_cycle(&self) -> bool

fn valid(&self) -> bool

fn set_reply<R: IntoReply<Message>>(&self, t: R)

fn set_error(&self, t: &AsError)

fn mark_total(&self, cluster: &str)

fn mark_remote(&self, cluster: &str)

fn get_sendtime(&self) -> Option<Instant>