Struct Client

pub struct Client {

    pub fd: Fd,
    pub token: Token,
    pub flags: i32,
    pub query_buf: Vec<u8>,
    pub last_interaction: SystemTime,
    pub argv: Vec<RobjPtr>,
    pub authenticate: bool,
    pub reply_state: ReplyState,
    pub reply: Vec<RobjPtr>,
    pub reply_db_file: Option<File>,
    pub reply_db_off: u64,
    pub reply_db_size: u64,
    pub reply_off: usize,
    pub request_type: RequestType,
    pub multi_bulk_len: usize,
    pub bulk_len: Option<usize>,
    pub db_idx: usize,
    pub slave_select_db: usize,
}

Fields

fd: Fd

token: Token

flags: i32

query_buf: Vec<u8>

last_interaction: SystemTime

argv: Vec<RobjPtr>

authenticate: bool

reply_state: ReplyState

reply: Vec<RobjPtr>

reply_db_file: Option<File>

reply_db_off: u64

reply_db_size: u64

reply_off: usize

request_type: RequestType

multi_bulk_len: usize

bulk_len: Option<usize>

db_idx: usize

slave_select_db: usize

Implementations

impl Client

pub fn with_fd_and_el( fd: Fd, el: &mut AeEventLoop, ) -> Result<Rc<RefCell<Client>>, ()>

pub fn with_fd(fd: Fd) -> Rc<RefCell<Client>>

pub fn parse_query_buf(&mut self) -> Result<(), CommandError>

pub fn process_input_buffer( &mut self, server: &mut Server, el: &mut AeEventLoop, )

pub fn process_command( &mut self, server: &mut Server, el: &mut AeEventLoop, ) -> Result<(), CommandError>

pub fn prepare_to_write(&mut self, el: &mut AeEventLoop) -> Result<(), ()>

pub fn argc(&self) -> usize

pub fn reset(&mut self)

pub fn add_reply(&mut self, r: RobjPtr)

pub fn add_str_reply(&mut self, s: &str)

pub fn add_reply_from_string(&mut self, s: String)

pub fn glue_reply(&mut self)

pub fn is_slave(&self) -> bool

pub fn is_monitor(&self) -> bool

pub fn is_master(&self) -> bool