redisclient::client

Struct RedisClient

Source 
pub struct RedisClient { /* private fields */ }

Implementations§

Source§

impl RedisClient

Source

pub fn new() -> RedisResult<RedisClient>

Source

pub fn with_config(config: RedisConfig) -> RedisResult<RedisClient>

Source

pub fn flushall(&mut self) -> RedisResult<()>

Source

pub fn auth<S>(&mut self, username: Option<S>, password: S) -> RedisResult<()>
where S: ToString,

The AUTH command authenticates the current connection

Return value: Simple string reply

Source

pub fn echo<S>(&mut self, message: S) -> RedisResult<String>
where S: ToString,

Returns message.

Return value: Bulk string reply

Source

pub fn ping(&mut self) -> RedisResult<()>

Returns PONG if no argument is provided, otherwise return a copy of the argument as a bulk.

Return value: Simple string reply

Source

pub fn quit(&mut self) -> RedisResult<()>

Ask the server to close the connection.

Return value: Simple string reply

Source

pub fn select(&mut self, index: u8) -> RedisResult<()>

Select the Redis logical database having the specified zero-based numeric index.

Return value: Simple string reply

Source

pub fn hdel<K>(&mut self, key: K, fields: Vec<K>) -> RedisResult<usize>
where K: RedisSerializationProtocol,

Removes the specified fields from the hash stored at key.

Return value: Integer reply

Source

pub fn hexists<K, F>(&mut self, key: K, field: F) -> RedisResult<bool>
where K: RedisSerializationProtocol, F: RedisSerializationProtocol,

Returns if field is an existing field in the hash stored at key.

Return value: Integer reply

Source

pub fn hget<K, F, V>(&mut self, key: K, field: F) -> RedisResult<V>
where K: RedisSerializationProtocol, F: RedisSerializationProtocol, V: RedisDeserializationProtocol,

Returns the value associated with field in the hash stored at key.

Return value: Bulk string reply

Source

pub fn hgetall<K, M>(&mut self, key: K) -> RedisResult<M>
where K: RedisSerializationProtocol, M: RedisDeserializationProtocol,

Returns all fields and values of the hash stored at key.

Return value: Array reply

Source

pub fn hincrby<K, F>( &mut self, key: K, field: F, increment: i64, ) -> RedisResult<i64>
where K: RedisSerializationProtocol, F: RedisSerializationProtocol,

Increments the number stored at field in the hash stored at key by increment.

Return value: Integer value

Source

pub fn hincrbyfloat<K, F>( &mut self, key: K, field: F, increment: f64, ) -> RedisResult<f64>
where K: RedisSerializationProtocol, F: RedisSerializationProtocol,

Increment the specified field of a hash stored at key, and representing a floating point number, by the specified increment.

Return value: Bulk string reply

Source

pub fn hkeys<K, V>(&mut self, key: K) -> RedisResult<Vec<V>>
where K: RedisSerializationProtocol, V: RedisDeserializationProtocol,

Returns all field names in the hash stored at key.

Return value: Array reply

Source

pub fn hlen<K>(&mut self, key: K) -> RedisResult<u64>
where K: RedisSerializationProtocol,

Returns the number of fields contained in the hash stored at key.

Return value: Integer reply

Source

pub fn hmget<K, F, V>(&mut self, key: K, fields: Vec<F>) -> RedisResult<Vec<V>>
where K: RedisSerializationProtocol, F: RedisSerializationProtocol, V: RedisDeserializationProtocol,

Returns the values associated with the specified fields in the hash stored at key.

Return value: Array reply

Source

pub fn hmset<K, F, V>(&mut self, key: K, fvs: Vec<(F, V)>) -> RedisResult<()>
where K: RedisSerializationProtocol, F: RedisSerializationProtocol, V: RedisSerializationProtocol,

Sets the specified fields to their respective values in the hash stored at key.

Return values: Simple string reply

Source

pub fn hscan(&mut self)

Source

pub fn hset<K, F, V>( &mut self, key: K, field: F, value: V, ) -> RedisResult<usize>
where K: RedisSerializationProtocol, F: RedisSerializationProtocol, V: RedisSerializationProtocol,

Sets field in the hash stored at key to value.

Return value: Integer reply

Source

pub fn hsetnx<K, F, V>( &mut self, key: K, field: F, value: V, ) -> RedisResult<usize>
where K: RedisSerializationProtocol, F: RedisSerializationProtocol, V: RedisSerializationProtocol,

Sets field in the hash stored at key to value, only if field does not yet exist.

Return value: Integer value

Source

pub fn hstrlen<K, F>(&mut self, key: K, field: F) -> RedisResult<usize>
where K: RedisSerializationProtocol, F: RedisSerializationProtocol,

Returns the string length of the value associated with field in the hash stored at key.

Return value: Integer reply

Source

pub fn hvals<K, V>(&mut self, key: K) -> RedisResult<Vec<V>>
where K: RedisSerializationProtocol, V: RedisDeserializationProtocol,

Returns all values in the hash stored at key.

Return value: Array reply

Source

pub fn copy(&mut self) -> RedisResult<()>

This command copies the value stored at the source key to the destination key.

Return value: Integer reply

Source

pub fn del<K>(&mut self, keys: Vec<K>) -> RedisResult<usize>
where K: RedisSerializationProtocol,

Removes the specified keys. A key is ignored if it does not exist.

Return value: Integer reply

Source

pub fn dump<K>(&mut self, key: K) -> RedisResult<String>
where K: RedisSerializationProtocol,

Serialize the value stored at key in a Redis-specific format and return it to the user.

Return value: Bulk string reply

Source

pub fn exists<K>(&mut self, keys: Vec<K>) -> RedisResult<usize>
where K: RedisSerializationProtocol,

Returns if key exists.

Return value: Integer reply

Source

pub fn expire<K>(&mut self, key: K, seconds: usize) -> RedisResult<bool>
where K: RedisSerializationProtocol,

Set a timeout on key. After the timeout has expired, the key will automatically be deleted.

Return value: Integer reply

Source

pub fn expireat<K>(&mut self, key: K, timestamp: u64) -> RedisResult<bool>
where K: RedisSerializationProtocol,

EXPIREAT has the same effect and semantic as EXPIRE, but instead of specifying the number of seconds representing the TTL, it takes an absolute Unix timestamp.

Return value: Integer reply

Source

pub fn keys<S>(&mut self, pattern: S) -> RedisResult<Vec<String>>
where S: ToString,

Returns all keys matching pattern.

Return value: Array reply

Source

pub fn persist<K>(&mut self, key: K) -> RedisResult<bool>
where K: RedisSerializationProtocol,

Remove the existing timeout on key, turning the key from volatile to persistent.

Return value: Integer reply

Source

pub fn pexpire<K>(&mut self, key: K, milliseconds: u64) -> RedisResult<bool>
where K: RedisSerializationProtocol,

This command works exactly like EXPIRE but the time to live of the key is specified in milliseconds instead of seconds.

Return value: Integer reply

Source

pub fn pttl<K>(&mut self, key: K) -> RedisResult<i64>
where K: RedisSerializationProtocol,

Like TTL this command returns the remaining time to live of a key that has an expire set, with the sole difference that TTL returns the amount of remaining time in seconds while PTTL returns it in milliseconds.

Return value: Integer reply

Source

pub fn randomkey(&mut self) -> RedisResult<String>

Return a random key from the currently selected database.

Return value: Bulk string reply

Source

pub fn rename<K>(&mut self, key: K, newkey: K) -> RedisResult<()>
where K: RedisSerializationProtocol,

Renames key to newkey. It returns an error when key does not exist.

Return value: Simple string reply

Source

pub fn renamenx<K>(&mut self, key: K, newkey: K) -> RedisResult<bool>
where K: RedisSerializationProtocol,

Renames key to newkey if newkey does not yet exist. It returns an error when key does not exist.

Return value: Integer reply

Source

pub fn touch<K>(&mut self, keys: Vec<K>) -> RedisResult<isize>
where K: RedisSerializationProtocol,

Alters the last access time of a key(s). A key is ignored if it does not exist.

Return value: Integer reply

Source

pub fn ttl<K>(&mut self, key: K) -> RedisResult<isize>
where K: RedisSerializationProtocol,

Returns the remaining time to live of a key that has a timeout.

Return value: Integer reply

Source

pub fn type_<K>(&mut self, key: K) -> RedisResult<DataType>
where K: RedisSerializationProtocol,

Returns the string representation of the type of the value stored at key.

Return value: Simple string reply

This command is very similar to DEL: it removes the specified keys.

Return value: Integer reply

Source

pub fn brpoplpush<K, E>( &mut self, source: K, destination: K, timeout: usize, ) -> RedisResult<E>
where K: RedisSerializationProtocol, E: RedisDeserializationProtocol,

BRPOPLPUSH is the blocking variant of RPOPLPUSH.

Return value: Bulk string reply

Source

pub fn lindex<K, V>(&mut self, key: K, index: isize) -> RedisResult<V>
where K: RedisSerializationProtocol, V: RedisDeserializationProtocol,

Returns the element at index index in the list stored at key.

Return value: Bulk string reply

Source

pub fn linsert<K, E>( &mut self, key: K, operator: ListBeforeOrAfter, pivot: E, element: E, ) -> RedisResult<usize>
where K: RedisSerializationProtocol, E: RedisSerializationProtocol,

Inserts element in the list stored at key either before or after the reference value pivot.

Return value: Integer reply

Source

pub fn llen<K>(&mut self, key: K) -> RedisResult<usize>
where K: RedisSerializationProtocol,

Returns the length of the list stored at key.

Return value: Integer reply

Source

pub fn lpop<K, E>(&mut self, key: K) -> RedisResult<E>
where K: RedisSerializationProtocol, E: RedisDeserializationProtocol,

Removes and returns the first element of the list stored at key.

Return value: Bulk string reply

Source

pub fn lpos(&mut self)

The command returns the index of matching elements inside a Redis list.

Source

pub fn lpush<K, E>(&mut self, key: K, elements: Vec<E>) -> RedisResult<usize>
where K: RedisSerializationProtocol, E: RedisSerializationProtocol,

Insert all the specified values at the head of the list stored at key.

Retrun value: Integer reply

Source

pub fn lpushx<K, E>(&mut self, key: K, elements: Vec<E>) -> RedisResult<usize>
where K: RedisSerializationProtocol, E: RedisSerializationProtocol,

Inserts specified values at the head of the list stored at key, only if key already exists and holds a list.

Return value: Integer value

Source

pub fn lrange<K, E>( &mut self, key: K, start: isize, end: isize, ) -> RedisResult<Vec<E>>
where K: RedisSerializationProtocol, E: RedisDeserializationProtocol,

Returns the specified elements of the list stored at key.

Return value: Array reply

Source

pub fn lrem<K, E>( &mut self, key: K, count: isize, element: E, ) -> RedisResult<usize>
where K: RedisSerializationProtocol, E: RedisSerializationProtocol,

Removes the first count occurrences of elements equal to element from the list stored at key.

Return value: Integer reply

Source

pub fn lset<K, E>( &mut self, key: K, index: isize, element: E, ) -> RedisResult<()>
where K: RedisSerializationProtocol, E: RedisSerializationProtocol,

Sets the list element at index to element.

Return value: Simple string reply

Source

pub fn ltrim<K>(&mut self, key: K, start: isize, stop: isize) -> RedisResult<()>
where K: RedisSerializationProtocol,

Trim an existing list so that it will contain only the specified range of elements specified.

Return value: Simple string reply

Source

pub fn rpop<K, E>(&mut self, key: K) -> RedisResult<E>
where K: RedisSerializationProtocol, E: RedisDeserializationProtocol,

Removes and returns the last element of the list stored at key.

Return value: Bulk string reply

Source

pub fn rpoplpush<K, E>(&mut self, source: K, destination: K) -> RedisResult<E>
where K: RedisSerializationProtocol, E: RedisDeserializationProtocol,

Atomically returns and removes the last element (tail) of the list stored at source, and pushes the element at the first element (head) of the list stored at destination.

Return value: Bulk string reply

Source

pub fn rpush<K, E>(&mut self, key: K, elements: Vec<E>) -> RedisResult<usize>
where K: RedisSerializationProtocol, E: RedisSerializationProtocol,

Insert all the specified values at the tail of the list stored at key.

Return value: Integer value

Source

pub fn rpushx<K, E>(&mut self, key: K, elements: Vec<E>) -> RedisResult<usize>
where K: RedisSerializationProtocol, E: RedisSerializationProtocol,

Inserts specified values at the tail of the list stored at key, only if key already exists and holds a list.

Return value: Integer reply

Source

pub fn sadd<K, M>(&mut self, key: K, members: HashSet<M>) -> RedisResult<usize>
where K: RedisSerializationProtocol, M: RedisSerializationProtocol + Hash + Eq,

Add the specified members to the set stored at key.

Return value: Integer value

Source

pub fn scard<K>(&mut self, key: K) -> RedisResult<usize>
where K: RedisSerializationProtocol,

Returns the set cardinality (number of elements) of the set stored at key.

Return value: Integer reply

Source

pub fn sdiff<K, M>(&mut self, keys: Vec<K>) -> RedisResult<HashSet<M>>
where K: RedisSerializationProtocol, M: RedisDeserializationProtocol + Hash + Eq,

Returns the members of the set resulting from the difference between the first set and all the successive sets.

Return value: Array reply

Source

pub fn sdiffstore<K>( &mut self, destination: K, keys: Vec<K>, ) -> RedisResult<usize>
where K: RedisSerializationProtocol + Hash + Eq,

This command is equal to SDIFF, but instead of returning the resulting set, it is stored in destination.

Return value: Integer reply

Source

pub fn sinter<K, M>(&mut self, keys: Vec<K>) -> RedisResult<HashSet<M>>
where K: RedisSerializationProtocol, M: RedisDeserializationProtocol + Hash + Eq,

Returns the members of the set resulting from the intersection of all the given sets.

Return value: Array reply

Source

pub fn sinterstore<K>( &mut self, destination: K, keys: Vec<K>, ) -> RedisResult<usize>
where K: RedisSerializationProtocol,

This command is equal to SINTER, but instead of returning the resulting set, it is stored in destination.

Return value: Integer reply

Source

pub fn sismember<K, M>(&mut self, key: K, member: M) -> RedisResult<bool>
where K: RedisSerializationProtocol, M: RedisSerializationProtocol + Hash + Eq,

Returns if member is a member of the set stored at key.

Return value: Integer reply

Source

pub fn smembers<K, M>(&mut self, key: K) -> RedisResult<HashSet<M>>
where K: RedisSerializationProtocol, M: RedisDeserializationProtocol + Hash + Eq,

Returns all the members of the set value stored at key.

Return value: Array reply

Source

pub fn smismember<K, M>( &mut self, key: K, members: HashSet<M>, ) -> RedisResult<Vec<bool>>
where K: RedisSerializationProtocol, M: RedisSerializationProtocol + Hash + Eq,

Returns whether each member is a member of the set stored at key.

Return value: Array reply

Source

pub fn smove<K, M>( &mut self, source: K, destination: K, member: M, ) -> RedisResult<usize>
where K: RedisSerializationProtocol, M: RedisSerializationProtocol + Hash + Eq,

Move member from the set at source to the set at destination.

Return value: Integer reply

Source

pub fn spop<K, M>(&mut self, key: K, count: Option<usize>) -> RedisResult<M>
where K: RedisSerializationProtocol, M: RedisDeserializationProtocol,

Removes and returns one or more random members from the set value store at key.

Return value: Bulk string reply or Array reply

Source

pub fn srandmember<K, M>( &mut self, key: K, count: Option<usize>, ) -> RedisResult<M>
where K: RedisSerializationProtocol, M: RedisDeserializationProtocol,

When called with just the key argument, return a random element from the set value stored at key.

Return value: Bulk string reply or Array reply

Source

pub fn srem<K, M>(&mut self, key: K, members: HashSet<M>) -> RedisResult<usize>
where K: RedisSerializationProtocol, M: RedisSerializationProtocol + Hash + Eq,

Remove the specified members from the set stored at key.

Return value: Integer reply

Source

pub fn sscan()

Like Scan command

Source

pub fn sunion<K, M>(&mut self, keys: Vec<K>) -> RedisResult<HashSet<M>>
where K: RedisSerializationProtocol, M: RedisDeserializationProtocol + Hash + Eq,

Returns the members of the set resulting from the union of all the given sets.

Return value: Array reply

Source

pub fn sunionstore<K>( &mut self, destination: K, keys: Vec<K>, ) -> RedisResult<usize>
where K: RedisSerializationProtocol,

This command is equal to SUNION, but instead of returning the resulting set, it is stored in destination.

Return value: Integer reply

Source

pub fn append<K, V>(&mut self, key: K, value: V) -> RedisResult<u64>
where K: RedisSerializationProtocol, V: RedisSerializationProtocol,

Source

pub fn bitcount<K>( &mut self, key: K, start: Option<i64>, end: Option<i64>, ) -> RedisResult<u64>
where K: RedisSerializationProtocol,

Count the number of set bits (population counting) in a string.

Source

pub fn bitop<K1, K2>( &mut self, operation: &str, destkey: K1, keys: Vec<K2>, ) -> RedisResult<usize>
where K1: RedisSerializationProtocol, K2: RedisSerializationProtocol,

Perform a bitwise operation between multiple keys (containing string values) and store the result in the destination key.

Source

pub fn bitpos<K>( &mut self, key: K, bit: u8, start: Option<usize>, end: Option<usize>, ) -> RedisResult<isize>
where K: RedisSerializationProtocol,

Return the position of the first bit set to 1 or 0 in a string.

Source

pub fn decr<K>(&mut self, key: K) -> RedisResult<i64>
where K: RedisSerializationProtocol,

Decrements the number stored at key by one.

Source

pub fn decrby<K>(&mut self, key: K, decrement: i64) -> RedisResult<i64>
where K: RedisSerializationProtocol,

Decrements the number stored at key by decrement.

Source

pub fn get<K, V>(&mut self, key: K) -> RedisResult<V>
where K: RedisSerializationProtocol, V: RedisDeserializationProtocol,

Get the value of key.

Source

pub fn getbit<K>(&mut self, key: K, offset: i64) -> RedisResult<u8>
where K: RedisSerializationProtocol,

Returns the bit value at offset in the string value stored at key.

Source

pub fn getrange<K>( &mut self, key: K, start: i64, end: i64, ) -> RedisResult<String>
where K: RedisSerializationProtocol,

Returns the substring of the string value stored at key, determined by the offsets start and end (both are inclusive).

Source

pub fn getset<K, V>(&mut self, key: K, value: V) -> RedisResult<String>
where K: RedisSerializationProtocol, V: ToString,

Atomically sets key to value and returns the old value stored at key.

Source

pub fn incr<K>(&mut self, key: K) -> RedisResult<i64>
where K: RedisSerializationProtocol,

Increments the number stored at key by one.

Source

pub fn incrby<K>(&mut self, key: K, increment: i64) -> RedisResult<i64>
where K: RedisSerializationProtocol,

Increments the number stored at key by increment.

Source

pub fn incrbyfloat<K>(&mut self, key: K, increment: f64) -> RedisResult<f64>
where K: RedisSerializationProtocol,

Increment the string representing a floating point number stored at key by the specified increment.

Source

pub fn mget<K, V>(&mut self, keys: Vec<K>) -> RedisResult<Vec<V>>
where K: RedisSerializationProtocol, V: RedisDeserializationProtocol,

Returns the values of all specified keys.

Source

pub fn mset<K, V>(&mut self, kvs: Vec<(K, V)>) -> RedisResult<()>
where K: RedisSerializationProtocol, V: RedisSerializationProtocol,

Sets the given keys to their respective values.

Source

pub fn msetnx<K, V>(&mut self, kvs: Vec<(K, V)>) -> RedisResult<()>
where K: RedisSerializationProtocol, V: RedisSerializationProtocol,

Sets the given keys to their respective values.

Source

pub fn psetex<K, V>( &mut self, key: K, milliseconds: u64, value: V, ) -> RedisResult<()>
where K: RedisSerializationProtocol, V: RedisSerializationProtocol,

PSETEX works exactly like SETEX with the sole difference that the expire time is specified in milliseconds instead of seconds.

Source

pub fn set<K, V>( &mut self, key: K, value: V, ex_seconds: Option<u64>, px_milliseconds: Option<u64>, nx: Option<bool>, xx: Option<bool>, ) -> RedisResult<()>
where K: RedisSerializationProtocol, V: RedisSerializationProtocol,

Set key to hold the string value.

Source

pub fn simple_set<K, V>(&mut self, key: K, value: V) -> RedisResult<()>
where K: RedisSerializationProtocol, V: RedisSerializationProtocol,

Set key to hold the string value.

Source

pub fn setbit<K>(&mut self, key: K, offset: usize, value: u8) -> RedisResult<u8>
where K: RedisSerializationProtocol,

Sets or clears the bit at offset in the string value stored at key.

Source

pub fn setex<K, V>( &mut self, key: K, seconds: usize, value: V, ) -> RedisResult<()>
where K: RedisSerializationProtocol, V: RedisSerializationProtocol,

Set key to hold the string value and set key to timeout after a given number of seconds.

Source

pub fn setnx<K, V>(&mut self, key: K, value: V) -> RedisResult<bool>
where K: RedisSerializationProtocol, V: RedisSerializationProtocol,

Set key to hold string value if key does not exist.

Source

pub fn setrange<K, V>( &mut self, key: K, offset: usize, value: V, ) -> RedisResult<usize>
where K: RedisSerializationProtocol, V: RedisSerializationProtocol,

Overwrites part of the string stored at key, starting at the specified offset, for the entire length of value.

Source

pub fn strlen<K>(&mut self, key: K) -> RedisResult<u64>
where K: RedisSerializationProtocol,

Returns the length of the string value stored at key.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.