Struct fred::RedisClient
[−]
[src]
pub struct RedisClient { /* fields omitted */ }A Redis client.
Methods
impl RedisClient[src]
fn new(config: RedisConfig) -> RedisClient
Create a new RedisClient instance.
fn quit(self) -> Box<Future<Item = Self, Error = RedisError>>
Close the connection to the Redis server. The returned future resolves when the command has been written to the socket,
not when the connection has been fully closed. Some time after this future resolves the future returned by connect
or connect_with_policy will resolve, and that indicates that the connection has been fully closed.
This function will also close all error, message, and reconnection event streams.
Note: This function will immediately succeed if the client is already disconnected. This is to allow quit to be used
a means to break out from reconnect logic. If this function is called while the client is waiting to attempt to reconnect
then when it next wakes up to try to reconnect it will instead break out with a RedisErrorKind::Canceled error.
This in turn will resolve the future returned by connect or connect_with_policy some time later.
fn state(&self) -> ClientState
Read the state of the underlying connection.
fn connect(&self, handle: &Handle) -> ConnectionFuture
Connect to the Redis server. The returned future will resolve when the connection to the Redis server has been fully closed by both ends.
The on_connect function can be used to be notified when the client first successfully connects.
fn connect_with_policy(
&self,
handle: &Handle,
policy: ReconnectPolicy
) -> Box<Future<Item = (), Error = RedisError>>
&self,
handle: &Handle,
policy: ReconnectPolicy
) -> Box<Future<Item = (), Error = RedisError>>
Connect to the Redis server with a ReconnectPolicy to apply if the connection closes due to an error.
The returned future will resolve when max_attempts is reached on the ReconnectPolicy.
Use the on_error and on_reconnect functions to be notified when the connection dies or successfully reconnects.
Note that when the client automatically reconnects it will not re-select the previously selected database,
nor will it re-subscribe to any pubsub channels. Use on_reconnect to implement that functionality if needed.
Additionally, on_connect can be used to be notified when the client first successfully connects, since sometimes
some special initialization is needed upon first connecting.
fn on_reconnect(&self) -> Box<Stream<Item = Self, Error = RedisError>>
Listen for successful reconnection notifications. When using a config with a ReconnectPolicy the future
returned by connect_with_policy will not resolve until max_attempts is reached, potentially running forever
if set to 0. This function can be used to receive notifications whenever the client successfully reconnects
in order to select the right database again, re-subscribe to channels, etc. A reconnection event is also
triggered upon first connecting.
If called more than once the original stream will be closed before creating the new one.
fn on_connect(&self) -> Box<Future<Item = Self, Error = RedisError>>
Returns a future that resolves when the client connects to the server. If the client is already connected this future will resolve immediately.
This can be used with on_reconnect to separate initialization logic that needs
to occur only on the first connection vs subsequent connections.
Unlike on_reconnect, on_message, and on_error this function can be called
multiple times and it will not cancel futures returned by previous calls.
fn on_error(&self) -> Box<Stream<Item = RedisError, Error = RedisError>>
Listen for protocol and connection errors. This stream can be used to more intelligently handle errors that may not appear in the request-response cycle, and so cannot be handled by response futures.
Similar to on_message, this function does not need to be called again if the connection goes down. If it
is called more than once the previous stream will be closed before creating the new one.
fn on_message(
&self
) -> Box<Stream<Item = (String, RedisValue), Error = RedisError>>
&self
) -> Box<Stream<Item = (String, RedisValue), Error = RedisError>>
Listen for (channel, message) tuples on the PubSub interface.
If the connection to the Redis server goes down for any reason this function does not need to be called again.
Messages will start appearing on the original stream after subscribe is called again. If this is called more
than once the previous stream will be closed before creating the new one.
fn select(self, db: u8) -> Box<Future<Item = Self, Error = RedisError>>
Select the database this client should use.
fn info(
self,
section: Option<InfoKind>
) -> Box<Future<Item = (Self, String), Error = RedisError>>
self,
section: Option<InfoKind>
) -> Box<Future<Item = (Self, String), Error = RedisError>>
Read info about the Redis server.
fn ping(self) -> Box<Future<Item = (Self, String), Error = RedisError>>
Ping the Redis server.
fn subscribe<T: Into<String>>(
self,
channel: T
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
self,
channel: T
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
Subscribe to a channel on the PubSub interface. Any messages received before on_message is called will be discarded, so it's
usually best to call on_message before calling subscribe for the first time. The usize returned here is the number of
channels to which the client is currently subscribed.
fn unsubscribe<T: Into<String>>(
self,
channel: T
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
self,
channel: T
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
Unsubscribe from a channel on the PubSub interface.
fn publish<T: Into<String>, V: Into<RedisValue>>(
self,
channel: T,
message: V
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
self,
channel: T,
message: V
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
Publish a message on the PubSub interface, returning the number of clients that received the message.
fn get<K: Into<RedisKey>>(
self,
key: K
) -> Box<Future<Item = (Self, Option<RedisValue>), Error = RedisError>>
self,
key: K
) -> Box<Future<Item = (Self, Option<RedisValue>), Error = RedisError>>
Read a value from Redis at key.
fn set<K: Into<RedisKey>, V: Into<RedisValue>>(
self,
key: K,
value: V,
expire: Option<Expiration>,
options: Option<SetOptions>
) -> Box<Future<Item = (Self, bool), Error = RedisError>>
self,
key: K,
value: V,
expire: Option<Expiration>,
options: Option<SetOptions>
) -> Box<Future<Item = (Self, bool), Error = RedisError>>
Set a value at key with optional NX|XX and EX|PX arguments.
The bool returned by this function describes whether or not the key was set due to any NX|XX options.
fn auth<V: Into<String>>(
self,
value: V
) -> Box<Future<Item = (Self, String), Error = RedisError>>
self,
value: V
) -> Box<Future<Item = (Self, String), Error = RedisError>>
Request for authentication in a password-protected Redis server. Returns ok if successful.
fn bgrewriteaof(self) -> Box<Future<Item = (Self, String), Error = RedisError>>
Instruct Redis to start an Append Only File rewrite process. Returns ok.
fn bgsave(self) -> Box<Future<Item = (Self, String), Error = RedisError>>
Save the DB in background. Returns ok.
fn client_list(self) -> Box<Future<Item = (Self, String), Error = RedisError>>
Returns information and statistics about the client connections.
fn client_getname(
self
) -> Box<Future<Item = (Self, Option<String>), Error = RedisError>>
self
) -> Box<Future<Item = (Self, Option<String>), Error = RedisError>>
Returns the name of the current connection as a string, or None if no name is set.
fn client_setname<V: Into<String>>(
self,
name: V
) -> Box<Future<Item = (Self, Option<String>), Error = RedisError>>
self,
name: V
) -> Box<Future<Item = (Self, Option<String>), Error = RedisError>>
Assigns a name to the current connection. Returns ok if successful, None otherwise.
fn dbsize(self) -> Box<Future<Item = (Self, usize), Error = RedisError>>
Return the number of keys in the currently-selected database.
fn decr<K: Into<RedisKey>>(
self,
key: K
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
self,
key: K
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
Decrements the number stored at key by one. If the key does not exist, it is set to 0 before performing the operation. Returns error if the key contains a value of the wrong type.
fn decrby<V: Into<RedisValue>, K: Into<RedisKey>>(
self,
key: K,
value: V
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
self,
key: K,
value: V
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
Decrements the number stored at key by value argument. If the key does not exist, it is set to 0 before performing the operation. Returns error if the key contains a value of the wrong type.
fn del<K: Into<MultipleKeys>>(
self,
keys: K
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
self,
keys: K
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
Removes the specified keys. A key is ignored if it does not exist. Returns the number of keys removed.
fn dump<K: Into<RedisKey>>(
self,
key: K
) -> Box<Future<Item = (Self, Option<String>), Error = RedisError>>
self,
key: K
) -> Box<Future<Item = (Self, Option<String>), Error = RedisError>>
Serialize the value stored at key in a Redis-specific format and return it as bulk string. If key does not exist None is returned
fn exists<K: Into<MultipleKeys>>(
self,
keys: K
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
self,
keys: K
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
Returns number of keys that exist from the keys arguments.
fn expire<K: Into<RedisKey>>(
self,
key: K,
seconds: i64
) -> Box<Future<Item = (Self, bool), Error = RedisError>>
self,
key: K,
seconds: i64
) -> Box<Future<Item = (Self, bool), Error = RedisError>>
Set a timeout on key. After the timeout has expired, the key will automatically be deleted.
Returns true if timeout set, false if key does not exist.
fn expire_at<K: Into<RedisKey>>(
self,
key: K,
timestamp: i64
) -> Box<Future<Item = (Self, bool), Error = RedisError>>
self,
key: K,
timestamp: i64
) -> Box<Future<Item = (Self, bool), Error = RedisError>>
Set a timeout on key based on a UNIX timestamp. After the timeout has expired, the key will automatically be deleted.
Returns true if timeout set, false if key does not exist.
fn flushall(
self,
async: bool
) -> Box<Future<Item = (Self, String), Error = RedisError>>
self,
async: bool
) -> Box<Future<Item = (Self, String), Error = RedisError>>
Delete the keys in all databases. Returns a string reply.
fn flushdb(
self,
async: bool
) -> Box<Future<Item = (Self, String), Error = RedisError>>
self,
async: bool
) -> Box<Future<Item = (Self, String), Error = RedisError>>
Delete all the keys in the currently selected database. Returns a string reply.
fn getrange<K: Into<RedisKey>>(
self,
key: K,
start: usize,
end: usize
) -> Box<Future<Item = (Self, String), Error = RedisError>>
self,
key: K,
start: usize,
end: usize
) -> Box<Future<Item = (Self, String), Error = RedisError>>
Returns the substring of the string value stored at key, determined by the offsets start and end (both inclusive). Note: Command formerly called SUBSTR in Redis verison <=2.0.
fn getset<V: Into<RedisValue>, K: Into<RedisKey>>(
self,
key: K,
value: V
) -> Box<Future<Item = (Self, Option<RedisValue>), Error = RedisError>>
self,
key: K,
value: V
) -> Box<Future<Item = (Self, Option<RedisValue>), Error = RedisError>>
Atomically sets key to value and returns the old value stored at key. Returns error if key does not hold string value. Returns None if key does not exist.
fn hdel<F: Into<MultipleKeys>, K: Into<RedisKey>>(
self,
key: K,
fields: F
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
self,
key: K,
fields: F
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
Removes the specified fields from the hash stored at key. Specified fields that do not exist within this hash are ignored. If key does not exist, it is treated as an empty hash and this command returns 0.
fn hexists<F: Into<RedisKey>, K: Into<RedisKey>>(
self,
key: K,
field: F
) -> Box<Future<Item = (Self, bool), Error = RedisError>>
self,
key: K,
field: F
) -> Box<Future<Item = (Self, bool), Error = RedisError>>
Returns true if field exists on key.
fn hget<F: Into<RedisKey>, K: Into<RedisKey>>(
self,
key: K,
field: F
) -> Box<Future<Item = (Self, Option<RedisValue>), Error = RedisError>>
self,
key: K,
field: F
) -> Box<Future<Item = (Self, Option<RedisValue>), Error = RedisError>>
Returns the value associated with field in the hash stored at key.
fn hgetall<K: Into<RedisKey>>(
self,
key: K
) -> Box<Future<Item = (Self, HashMap<String, RedisValue>), Error = RedisError>>
self,
key: K
) -> Box<Future<Item = (Self, HashMap<String, RedisValue>), Error = RedisError>>
Returns all fields and values of the hash stored at key. In the returned value, every field name is followed by its value Returns an empty hashmap if hash is empty.
fn hincrby<F: Into<RedisKey>, K: Into<RedisKey>>(
self,
key: K,
field: F,
incr: i64
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
self,
key: K,
field: F,
incr: i64
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
Increments the number stored at field in the hash stored at key by incr. If key does not exist, a new key holding a hash is created.
If field does not exist the value is set to 0 before the operation is performed.
fn hincrbyfloat<K: Into<RedisKey>, F: Into<RedisKey>>(
self,
key: K,
field: F,
incr: f64
) -> Box<Future<Item = (Self, f64), Error = RedisError>>
self,
key: K,
field: F,
incr: f64
) -> Box<Future<Item = (Self, f64), Error = RedisError>>
Increment the specified field of a hash stored at key, and representing a floating point number, by the specified increment.
If the field does not exist, it is set to 0 before performing the operation.
Returns an error if field value contains wrong type or content/increment are not parsable.
fn hkeys<K: Into<RedisKey>>(
self,
key: K
) -> Box<Future<Item = (Self, Vec<String>), Error = RedisError>>
self,
key: K
) -> Box<Future<Item = (Self, Vec<String>), Error = RedisError>>
Returns all field names in the hash stored at key. Returns an empty vec if the list is empty. Null fields are converted to "nil".
fn hlen<K: Into<RedisKey>>(
self,
key: K
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
self,
key: K
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
Returns the number of fields contained in the hash stored at key.
fn hmget<F: Into<MultipleKeys>, K: Into<RedisKey>>(
self,
key: K,
fields: F
) -> Box<Future<Item = (Self, Vec<RedisValue>), Error = RedisError>>
self,
key: K,
fields: F
) -> Box<Future<Item = (Self, Vec<RedisValue>), Error = RedisError>>
Returns the values associated with the specified fields in the hash stored at key. Values in a returned list may be null.
fn hmset<V: Into<RedisValue>, F: Into<RedisKey> + Hash + Eq, K: Into<RedisKey>>(
self,
key: K,
values: HashMap<F, V>
) -> Box<Future<Item = (Self, String), Error = RedisError>>
self,
key: K,
values: HashMap<F, V>
) -> Box<Future<Item = (Self, String), Error = RedisError>>
Sets the specified fields to their respective values in the hash stored at key. This command overwrites any specified fields already existing in the hash. If key does not exist, a new key holding a hash is created.
fn hset<K: Into<RedisKey>, F: Into<RedisKey>, V: Into<RedisValue>>(
self,
key: K,
field: F,
value: V
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
self,
key: K,
field: F,
value: V
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
Sets field in the hash stored at key to value. If key does not exist, a new key holding a hash is created. If field already exists in the hash, it is overwritten. Note: Return value of 1 means new field was created and set. Return of 0 means field already exists and was overwritten.
fn hsetnx<K: Into<RedisKey>, F: Into<RedisKey>, V: Into<RedisValue>>(
self,
key: K,
field: F,
value: V
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
self,
key: K,
field: F,
value: V
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
Sets field in the hash stored at key to value, only if field does not yet exist. If key does not exist, a new key holding a hash is created. Note: Return value of 1 means new field was created and set. Return of 0 means no operation performed.
fn hstrlen<K: Into<RedisKey>, F: Into<RedisKey>>(
self,
key: K,
field: F
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
self,
key: K,
field: F
) -> Box<Future<Item = (Self, usize), Error = RedisError>>
Returns the string length of the value associated with field in the hash stored at key. If the key or the field do not exist, 0 is returned.
fn hvals<K: Into<RedisKey>>(
self,
key: K
) -> Box<Future<Item = (Self, Vec<RedisValue>), Error = RedisError>>
self,
key: K
) -> Box<Future<Item = (Self, Vec<RedisValue>), Error = RedisError>>
Returns all values in the hash stored at key. Returns an empty vector if the list is empty.
fn incr<K: Into<RedisKey>>(
self,
key: K
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
self,
key: K
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
Increments the number stored at key by one. If the key does not exist, it is set to 0 before performing the operation. Returns an error if the value at key is of the wrong type.
fn incrby<K: Into<RedisKey>>(
self,
key: K,
incr: i64
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
self,
key: K,
incr: i64
) -> Box<Future<Item = (Self, i64), Error = RedisError>>
Increments the number stored at key by incr. If the key does not exist, it is set to 0 before performing the operation. Returns an error if the value at key is of the wrong type.
fn incrbyfloat<K: Into<RedisKey>>(
self,
key: K,
incr: f64
) -> Box<Future<Item = (Self, f64), Error = RedisError>>
self,
key: K,
incr: f64
) -> Box<Future<Item = (Self, f64), Error = RedisError>>
Increment the string representing a floating point number stored at key by the argument value. If the key does not exist, it is set to 0 before performing the operation. Returns error if key value is wrong type or if the current value or increment value are not parseable as float value.
Trait Implementations
impl Clone for RedisClient[src]
fn clone(&self) -> Self
Note: Both the cloned client and the original will refer to the same underlying socket and command stream.
fn clone_from(&mut self, source: &Self)1.0.0
Performs copy-assignment from source. Read more