Struct rustis::client::Transaction
source · pub struct Transaction { /* private fields */ }
Expand description
Represents an on-going transaction
on a specific client instance.
Implementations§
source§impl Transaction
impl Transaction
sourcepub fn retry_on_error(&mut self, retry_on_error: bool)
pub fn retry_on_error(&mut self, retry_on_error: bool)
Set a flag to override default retry_on_error
behavior.
sourcepub fn forget(&mut self, command: Command)
pub fn forget(&mut self, command: Command)
Queue a command into the transaction and forget its response.
sourcepub async fn execute<T: DeserializeOwned>(self) -> Result<T>
pub async fn execute<T: DeserializeOwned>(self) -> Result<T>
Execute the transaction by the sending the queued command as a whole batch to the Redis server.
§Return
It is the caller responsability to use the right type to cast the server response to the right tuple or collection depending on which command has been queued or forgotten.
The most generic type that can be requested as a result is Vec<resp::Value>
§Example
use rustis::{
client::{Client, Transaction, BatchPreparedCommand},
commands::StringCommands,
resp::{cmd, Value}, Result,
};
#[cfg_attr(feature = "tokio-runtime", tokio::main)]
#[cfg_attr(feature = "async-std-runtime", async_std::main)]
async fn main() -> Result<()> {
let client = Client::connect("127.0.0.1:6379").await?;
let mut transaction = client.create_transaction();
transaction.set("key1", "value1").forget();
transaction.set("key2", "value2").forget();
transaction.get::<_, String>("key1").queue();
let value: String = transaction.execute().await?;
assert_eq!("value1", value);
Ok(())
}
Trait Implementations§
source§impl<'a> BitmapCommands<'a> for &'a mut Transaction
impl<'a> BitmapCommands<'a> for &'a mut Transaction
source§fn bitcount<K>(
self,
key: K,
range: BitRange
) -> PreparedCommand<'a, Self, usize>
fn bitcount<K>( self, key: K, range: BitRange ) -> PreparedCommand<'a, Self, usize>
Count the number of set bits (population counting) in a string. Read more
source§fn bitfield<K, C, E, O>(
self,
key: K,
sub_commands: C
) -> PreparedCommand<'a, Self, Vec<u64>>where
Self: Sized,
K: SingleArg,
E: SingleArg,
O: SingleArg,
C: MultipleArgsCollection<BitFieldSubCommand<E, O>>,
fn bitfield<K, C, E, O>(
self,
key: K,
sub_commands: C
) -> PreparedCommand<'a, Self, Vec<u64>>where
Self: Sized,
K: SingleArg,
E: SingleArg,
O: SingleArg,
C: MultipleArgsCollection<BitFieldSubCommand<E, O>>,
The command treats a Redis string as an array of bits,
and is capable of addressing specific integer fields
of varying bit widths and arbitrary non (necessary) aligned offset. Read more
source§fn bitfield_readonly<K, C, E, O>(
self,
key: K,
get_commands: C
) -> PreparedCommand<'a, Self, Vec<u64>>where
Self: Sized,
K: SingleArg,
E: SingleArg,
O: SingleArg,
C: MultipleArgsCollection<BitFieldGetSubCommand<E, O>>,
fn bitfield_readonly<K, C, E, O>(
self,
key: K,
get_commands: C
) -> PreparedCommand<'a, Self, Vec<u64>>where
Self: Sized,
K: SingleArg,
E: SingleArg,
O: SingleArg,
C: MultipleArgsCollection<BitFieldGetSubCommand<E, O>>,
Read-only variant of the BITFIELD command.
It is like the original BITFIELD but only accepts GET subcommand
and can safely be used in read-only replicas. Read more
source§fn bitop<D, K, KK>(
self,
operation: BitOperation,
dest_key: D,
keys: KK
) -> PreparedCommand<'a, Self, usize>
fn bitop<D, K, KK>( self, operation: BitOperation, dest_key: D, keys: KK ) -> PreparedCommand<'a, Self, usize>
Perform a bitwise operation between multiple keys (containing string values)
and store the result in the destination key. Read more
source§fn bitpos<K>(
self,
key: K,
bit: u64,
range: BitRange
) -> PreparedCommand<'a, Self, usize>
fn bitpos<K>( self, key: K, bit: u64, range: BitRange ) -> PreparedCommand<'a, Self, usize>
Perform a bitwise operation between multiple keys (containing string values)
and store the result in the destination key. Read more
source§impl<'a> BloomCommands<'a> for &'a mut Transaction
Available on crate feature redis-bloom
only.
impl<'a> BloomCommands<'a> for &'a mut Transaction
Available on crate feature
redis-bloom
only.source§fn bf_add(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
fn bf_add(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
Adds an item to a bloom filter Read more
source§fn bf_exists(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
fn bf_exists(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
Determines whether an item may exist in the Bloom Filter or not. Read more
source§fn bf_info_all(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, BfInfoResult>where
Self: Sized,
fn bf_info_all(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, BfInfoResult>where
Self: Sized,
Return information about key filter. Read more
source§fn bf_info(
self,
key: impl SingleArg,
param: BfInfoParameter
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
fn bf_info(
self,
key: impl SingleArg,
param: BfInfoParameter
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
Return information about key filter for a specific information parameter Read more
source§fn bf_insert<I: SingleArg, R: CollectionResponse<bool>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>,
options: BfInsertOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn bf_insert<I: SingleArg, R: CollectionResponse<bool>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>,
options: BfInsertOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
source§fn bf_loadchunk(
self,
key: impl SingleArg,
iterator: i64,
data: impl SingleArg
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn bf_loadchunk(
self,
key: impl SingleArg,
iterator: i64,
data: impl SingleArg
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Restores a filter previously saved using
bf_scandump
. Read moresource§fn bf_madd<I: SingleArg, R: CollectionResponse<bool>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn bf_madd<I: SingleArg, R: CollectionResponse<bool>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Adds one or more items to the Bloom Filter and creates the filter if it does not exist yet. Read more
source§fn bf_mexists<I: SingleArg, R: CollectionResponse<bool>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn bf_mexists<I: SingleArg, R: CollectionResponse<bool>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Determines if one or more items may exist in the filter or not. Read more
source§fn bf_reserve(
self,
key: impl SingleArg,
error_rate: f64,
capacity: usize,
options: BfReserveOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn bf_reserve(
self,
key: impl SingleArg,
error_rate: f64,
capacity: usize,
options: BfReserveOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Creates an empty Bloom Filter with a single sub-filter
for the initial capacity requested and with an upper bound error_rate. Read more
source§fn bf_scandump(
self,
key: impl SingleArg,
iterator: i64
) -> PreparedCommand<'a, Self, BfScanDumpResult>where
Self: Sized,
fn bf_scandump(
self,
key: impl SingleArg,
iterator: i64
) -> PreparedCommand<'a, Self, BfScanDumpResult>where
Self: Sized,
source§impl<'a> CountMinSketchCommands<'a> for &'a mut Transaction
Available on crate feature redis-bloom
only.
impl<'a> CountMinSketchCommands<'a> for &'a mut Transaction
Available on crate feature
redis-bloom
only.source§fn cms_incrby<I: SingleArg, R: CollectionResponse<usize>>(
self,
key: impl SingleArg,
items: impl KeyValueArgsCollection<I, usize>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn cms_incrby<I: SingleArg, R: CollectionResponse<usize>>(
self,
key: impl SingleArg,
items: impl KeyValueArgsCollection<I, usize>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Increases the count of item by increment. Read more
source§fn cms_info(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, CmsInfoResult>where
Self: Sized,
fn cms_info(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, CmsInfoResult>where
Self: Sized,
Returns width, depth and total count of the sketch. Read more
source§fn cms_initbydim(
self,
key: impl SingleArg,
width: usize,
depth: usize
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn cms_initbydim(
self,
key: impl SingleArg,
width: usize,
depth: usize
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Initializes a Count-Min Sketch to dimensions specified by user. Read more
source§fn cms_initbyprob(
self,
key: impl SingleArg,
error: f64,
probability: f64
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn cms_initbyprob(
self,
key: impl SingleArg,
error: f64,
probability: f64
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Initializes a Count-Min Sketch to accommodate requested tolerances. Read more
source§fn cms_merge<S: SingleArg, W: SingleArgCollection<usize>>(
self,
destination: impl SingleArg,
sources: impl SingleArgCollection<S>,
weights: Option<W>
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn cms_merge<S: SingleArg, W: SingleArgCollection<usize>>(
self,
destination: impl SingleArg,
sources: impl SingleArgCollection<S>,
weights: Option<W>
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Returns the count for one or more items in a sketch. Read more
source§fn cms_query<I: SingleArg, C: CollectionResponse<usize>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, C>where
Self: Sized,
fn cms_query<I: SingleArg, C: CollectionResponse<usize>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, C>where
Self: Sized,
Merges several sketches into one sketch. Read more
source§impl<'a> CuckooCommands<'a> for &'a mut Transaction
Available on crate feature redis-bloom
only.
impl<'a> CuckooCommands<'a> for &'a mut Transaction
Available on crate feature
redis-bloom
only.source§fn cf_add(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn cf_add(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Adds an item to the cuckoo filter, creating the filter if it does not exist. Read more
source§fn cf_addnx(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
fn cf_addnx(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
Adds an item to a cuckoo filter if the item did not exist previously. Read more
source§fn cf_count(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
fn cf_count(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
Returns the number of times an item may be in the filter. Read more
source§fn cf_del(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
fn cf_del(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
Deletes an item once from the filter. Read more
source§fn cf_exists(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
fn cf_exists(
self,
key: impl SingleArg,
item: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
source§fn cf_info(self, key: impl SingleArg) -> PreparedCommand<'a, Self, CfInfoResult>where
Self: Sized,
fn cf_info(self, key: impl SingleArg) -> PreparedCommand<'a, Self, CfInfoResult>where
Self: Sized,
Return information about
key
Read moresource§fn cf_insert<I: SingleArg>(
self,
key: impl SingleArg,
options: CfInsertOptions,
item: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, Vec<usize>>where
Self: Sized,
fn cf_insert<I: SingleArg>(
self,
key: impl SingleArg,
options: CfInsertOptions,
item: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, Vec<usize>>where
Self: Sized,
Adds one or more items to a cuckoo filter, allowing the filter to be created with a custom capacity if it does not exist yet. Read more
source§fn cf_insertnx<I: SingleArg, R: CollectionResponse<i64>>(
self,
key: impl SingleArg,
options: CfInsertOptions,
item: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn cf_insertnx<I: SingleArg, R: CollectionResponse<i64>>(
self,
key: impl SingleArg,
options: CfInsertOptions,
item: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Adds one or more items to a cuckoo filter, allowing the filter to be created with a custom capacity if it does not exist yet. Read more
source§fn cf_loadchunk(
self,
key: impl SingleArg,
iterator: i64,
data: impl SingleArg
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn cf_loadchunk(
self,
key: impl SingleArg,
iterator: i64,
data: impl SingleArg
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Restores a filter previously saved using
cf_scandump
. Read moresource§fn cf_mexists<I: SingleArg, R: CollectionResponse<bool>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn cf_mexists<I: SingleArg, R: CollectionResponse<bool>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
source§fn cf_reserve(
self,
key: impl SingleArg,
capacity: usize,
options: CfReserveOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn cf_reserve(
self,
key: impl SingleArg,
capacity: usize,
options: CfReserveOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Create a Cuckoo Filter as
key
with a single sub-filter for the initial amount of capacity
for items.
Because of how Cuckoo Filters work, the filter is likely to declare itself full before capacity
is reached
and therefore fill rate will likely never reach 100%.
The fill rate can be improved by using a larger bucketsize
at the cost of a higher error rate.
When the filter self-declare itself full
, it will auto-expand by generating additional sub-filters at the cost of reduced performance and increased error rate.
The new sub-filter is created with size of the previous sub-filter multiplied by expansion
.
Like bucket size, additional sub-filters grow the error rate linearly.
The size of the new sub-filter is the size of the last sub-filter multiplied by expansion
. Read moresource§fn cf_scandump(
self,
key: impl SingleArg,
iterator: i64
) -> PreparedCommand<'a, Self, CfScanDumpResult>where
Self: Sized,
fn cf_scandump(
self,
key: impl SingleArg,
iterator: i64
) -> PreparedCommand<'a, Self, CfScanDumpResult>where
Self: Sized,
source§impl<'a> GenericCommands<'a> for &'a mut Transaction
impl<'a> GenericCommands<'a> for &'a mut Transaction
source§fn copy<S, D>(
self,
source: S,
destination: D,
destination_db: Option<usize>,
replace: bool
) -> PreparedCommand<'a, Self, bool>
fn copy<S, D>( self, source: S, destination: D, destination_db: Option<usize>, replace: bool ) -> PreparedCommand<'a, Self, bool>
This command copies the value stored at the source key to the destination key. Read more
source§fn del<K, C>(self, keys: C) -> PreparedCommand<'a, Self, usize>
fn del<K, C>(self, keys: C) -> PreparedCommand<'a, Self, usize>
Removes the specified keys. A key is ignored if it does not exist. Read more
source§fn dump<K>(self, key: K) -> PreparedCommand<'a, Self, DumpResult>
fn dump<K>(self, key: K) -> PreparedCommand<'a, Self, DumpResult>
Serialize the value stored at key in a Redis-specific format and return it to the user. Read more
source§fn exists<K, C>(self, keys: C) -> PreparedCommand<'a, Self, usize>
fn exists<K, C>(self, keys: C) -> PreparedCommand<'a, Self, usize>
Returns if keys exist. Read more
source§fn expire<K>(
self,
key: K,
seconds: u64,
option: ExpireOption
) -> PreparedCommand<'a, Self, bool>
fn expire<K>( self, key: K, seconds: u64, option: ExpireOption ) -> PreparedCommand<'a, Self, bool>
Set a timeout on key in seconds Read more
source§fn expireat<K>(
self,
key: K,
unix_time_seconds: u64,
option: ExpireOption
) -> PreparedCommand<'a, Self, bool>
fn expireat<K>( self, key: K, unix_time_seconds: u64, option: ExpireOption ) -> PreparedCommand<'a, Self, bool>
EXPIREAT has the same effect and semantic as EXPIRE,
but instead of specifying the number of seconds representing the TTL (time to live),
it takes an absolute Unix timestamp (seconds since January 1, 1970) Read more
source§fn expiretime<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
fn expiretime<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
Returns the absolute Unix timestamp (since January 1, 1970) in seconds at which the given key will expire. Read more
source§fn keys<P, K, A>(self, pattern: P) -> PreparedCommand<'a, Self, A>where
Self: Sized,
P: SingleArg,
K: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<K> + DeserializeOwned,
fn keys<P, K, A>(self, pattern: P) -> PreparedCommand<'a, Self, A>where
Self: Sized,
P: SingleArg,
K: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<K> + DeserializeOwned,
Returns all keys matching pattern. Read more
source§fn migrate<H, K>(
self,
host: H,
port: u16,
key: K,
destination_db: usize,
timeout: u64,
options: MigrateOptions
) -> PreparedCommand<'a, Self, MigrateResult>
fn migrate<H, K>( self, host: H, port: u16, key: K, destination_db: usize, timeout: u64, options: MigrateOptions ) -> PreparedCommand<'a, Self, MigrateResult>
Atomically transfer a key or a collection of keys from a source Redis instance to a destination Redis instance. Read more
source§fn move_<K>(self, key: K, db: usize) -> PreparedCommand<'a, Self, i64>
fn move_<K>(self, key: K, db: usize) -> PreparedCommand<'a, Self, i64>
Move key from the currently selected database to the specified destination database. Read more
source§fn object_encoding<K, E>(self, key: K) -> PreparedCommand<'a, Self, E>
fn object_encoding<K, E>(self, key: K) -> PreparedCommand<'a, Self, E>
Returns the internal encoding for the Redis object stored at
key
Read moresource§fn object_freq<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
fn object_freq<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
This command returns the logarithmic access frequency counter of a Redis object stored at
key
. Read moresource§fn object_idle_time<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
fn object_idle_time<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
This command returns the time in seconds since the last access to the value stored at
key
. Read moresource§fn object_refcount<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
fn object_refcount<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
This command returns the reference count of the stored at
key
. Read moresource§fn persist<K>(self, key: K) -> PreparedCommand<'a, Self, bool>
fn persist<K>(self, key: K) -> PreparedCommand<'a, Self, bool>
Remove the existing timeout on key,
turning the key from volatile (a key with an expire set)
to persistent (a key that will never expire as no timeout is associated). Read more
source§fn pexpire<K>(
self,
key: K,
milliseconds: u64,
option: ExpireOption
) -> PreparedCommand<'a, Self, bool>
fn pexpire<K>( self, key: K, milliseconds: u64, option: ExpireOption ) -> PreparedCommand<'a, Self, bool>
This command works exactly like EXPIRE but the time to live of the key is specified in milliseconds instead of seconds. Read more
source§fn pexpireat<K>(
self,
key: K,
unix_time_milliseconds: u64,
option: ExpireOption
) -> PreparedCommand<'a, Self, bool>
fn pexpireat<K>( self, key: K, unix_time_milliseconds: u64, option: ExpireOption ) -> PreparedCommand<'a, Self, bool>
PEXPIREAT has the same effect and semantic as EXPIREAT,
but the Unix time at which the key will expire is specified in milliseconds instead of seconds. Read more
source§fn pexpiretime<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
fn pexpiretime<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
PEXPIRETIME has the same semantic as EXPIRETIME,
but returns the absolute Unix expiration timestamp in milliseconds instead of seconds. Read more
source§fn pttl<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
fn pttl<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
Returns the remaining time to live of a key that has a timeout. Read more
source§fn randomkey<R>(self) -> PreparedCommand<'a, Self, R>where
Self: Sized,
R: PrimitiveResponse,
fn randomkey<R>(self) -> PreparedCommand<'a, Self, R>where
Self: Sized,
R: PrimitiveResponse,
Return a random key from the currently selected database. Read more
source§fn rename<K1, K2>(self, key: K1, new_key: K2) -> PreparedCommand<'a, Self, ()>
fn rename<K1, K2>(self, key: K1, new_key: K2) -> PreparedCommand<'a, Self, ()>
Renames key to newkey. Read more
source§fn renamenx<K1, K2>(
self,
key: K1,
new_key: K2
) -> PreparedCommand<'a, Self, bool>
fn renamenx<K1, K2>( self, key: K1, new_key: K2 ) -> PreparedCommand<'a, Self, bool>
Renames key to newkey if newkey does not yet exist.
It returns an error when key does not exist. Read more
source§fn restore<K>(
self,
key: K,
ttl: u64,
serialized_value: Vec<u8>,
options: RestoreOptions
) -> PreparedCommand<'a, Self, ()>
fn restore<K>( self, key: K, ttl: u64, serialized_value: Vec<u8>, options: RestoreOptions ) -> PreparedCommand<'a, Self, ()>
Create a key associated with a value that is obtained by deserializing
the provided serialized value (obtained via DUMP). Read more
source§fn scan<K, A>(
self,
cursor: u64,
options: ScanOptions
) -> PreparedCommand<'a, Self, (u64, A)>where
Self: Sized,
K: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<K> + DeserializeOwned,
fn scan<K, A>(
self,
cursor: u64,
options: ScanOptions
) -> PreparedCommand<'a, Self, (u64, A)>where
Self: Sized,
K: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<K> + DeserializeOwned,
Iterates the set of keys in the currently selected Redis database. Read more
source§fn sort<K, M, A>(
self,
key: K,
options: SortOptions
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<M> + DeserializeOwned,
fn sort<K, M, A>(
self,
key: K,
options: SortOptions
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<M> + DeserializeOwned,
Returns the elements contained in the list, set or sorted set at key. Read more
source§fn sort_and_store<K, D>(
self,
key: K,
destination: D,
options: SortOptions
) -> PreparedCommand<'a, Self, usize>
fn sort_and_store<K, D>( self, key: K, destination: D, options: SortOptions ) -> PreparedCommand<'a, Self, usize>
Stores the elements contained in the list, set or sorted set at key. Read more
source§fn sort_readonly<K, M, A>(
self,
key: K,
options: SortOptions
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<M> + DeserializeOwned,
fn sort_readonly<K, M, A>(
self,
key: K,
options: SortOptions
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<M> + DeserializeOwned,
Read-only variant of the SORT command. Read more
source§fn touch<K, KK>(self, keys: KK) -> PreparedCommand<'a, Self, usize>
fn touch<K, KK>(self, keys: KK) -> PreparedCommand<'a, Self, usize>
Alters the last access time of a key(s). A key is ignored if it does not exist. Read more
source§fn ttl<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
fn ttl<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
Returns the remaining time to live of a key that has a timeout. Read more
source§fn type_<K>(self, key: K) -> PreparedCommand<'a, Self, String>
fn type_<K>(self, key: K) -> PreparedCommand<'a, Self, String>
Returns the string representation of the type of the value stored at key. Read more
source§impl<'a> GeoCommands<'a> for &'a mut Transaction
impl<'a> GeoCommands<'a> for &'a mut Transaction
source§fn geoadd<K, M, I>(
self,
key: K,
condition: GeoAddCondition,
change: bool,
items: I
) -> PreparedCommand<'a, Self, usize>
fn geoadd<K, M, I>( self, key: K, condition: GeoAddCondition, change: bool, items: I ) -> PreparedCommand<'a, Self, usize>
Adds the specified geospatial items (longitude, latitude, name) to the specified key. Read more
source§fn geodist<K, M>(
self,
key: K,
member1: M,
member2: M,
unit: GeoUnit
) -> PreparedCommand<'a, Self, Option<f64>>
fn geodist<K, M>( self, key: K, member1: M, member2: M, unit: GeoUnit ) -> PreparedCommand<'a, Self, Option<f64>>
Return the distance between two members in the geospatial index
represented by the sorted set. Read more
source§fn geopos<K, M, C>(
self,
key: K,
members: C
) -> PreparedCommand<'a, Self, Vec<Option<(f64, f64)>>>
fn geopos<K, M, C>( self, key: K, members: C ) -> PreparedCommand<'a, Self, Vec<Option<(f64, f64)>>>
Return the positions (longitude,latitude) of all the specified members
of the geospatial index represented by the sorted set at key. Read more
source§fn geosearch<K, M1, M2, A>(
self,
key: K,
from: GeoSearchFrom<M1>,
by: GeoSearchBy,
options: GeoSearchOptions
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M1: SingleArg,
M2: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<GeoSearchResult<M2>> + DeserializeOwned,
fn geosearch<K, M1, M2, A>(
self,
key: K,
from: GeoSearchFrom<M1>,
by: GeoSearchBy,
options: GeoSearchOptions
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M1: SingleArg,
M2: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<GeoSearchResult<M2>> + DeserializeOwned,
source§fn geosearchstore<D, S, M>(
self,
destination: D,
source: S,
from: GeoSearchFrom<M>,
by: GeoSearchBy,
options: GeoSearchStoreOptions
) -> PreparedCommand<'a, Self, usize>
fn geosearchstore<D, S, M>( self, destination: D, source: S, from: GeoSearchFrom<M>, by: GeoSearchBy, options: GeoSearchStoreOptions ) -> PreparedCommand<'a, Self, usize>
source§impl<'a> GraphCommands<'a> for &'a mut Transaction
Available on crate feature redis-graph
only.
impl<'a> GraphCommands<'a> for &'a mut Transaction
Available on crate feature
redis-graph
only.source§fn graph_config_get<N, V, R>(
self,
name: impl SingleArg
) -> PreparedCommand<'a, Self, R>
fn graph_config_get<N, V, R>( self, name: impl SingleArg ) -> PreparedCommand<'a, Self, R>
Retrieves the current value of a RedisGraph configuration parameter. Read more
source§fn graph_config_set(
self,
name: impl SingleArg,
value: impl SingleArg
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn graph_config_set(
self,
name: impl SingleArg,
value: impl SingleArg
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Set the value of a RedisGraph configuration parameter. Read more
source§fn graph_delete(
self,
graph: impl SingleArg
) -> PreparedCommand<'a, Self, String>where
Self: Sized,
fn graph_delete(
self,
graph: impl SingleArg
) -> PreparedCommand<'a, Self, String>where
Self: Sized,
Completely removes the graph and all of its entities. Read more
source§fn graph_explain<R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
graph: impl SingleArg,
query: impl SingleArg
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
fn graph_explain<R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
graph: impl SingleArg,
query: impl SingleArg
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
Constructs a query execution plan but does not run it. Read more
source§fn graph_list<R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
fn graph_list<R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
Lists all graph keys in the keyspace. Read more
source§fn graph_profile<R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
graph: impl SingleArg,
query: impl SingleArg,
options: GraphQueryOptions
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
fn graph_profile<R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
graph: impl SingleArg,
query: impl SingleArg,
options: GraphQueryOptions
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
Executes a query and produces an execution plan augmented with metrics for each operation’s execution. Read more
source§fn graph_query(
self,
graph: impl SingleArg,
query: impl SingleArg,
options: GraphQueryOptions
) -> PreparedCommand<'a, Self, GraphResultSet>where
Self: Sized,
fn graph_query(
self,
graph: impl SingleArg,
query: impl SingleArg,
options: GraphQueryOptions
) -> PreparedCommand<'a, Self, GraphResultSet>where
Self: Sized,
Executes the given query against a specified graph. Read more
source§fn graph_ro_query(
self,
graph: impl SingleArg,
query: impl SingleArg,
options: GraphQueryOptions
) -> PreparedCommand<'a, Self, GraphResultSet>where
Self: Sized,
fn graph_ro_query(
self,
graph: impl SingleArg,
query: impl SingleArg,
options: GraphQueryOptions
) -> PreparedCommand<'a, Self, GraphResultSet>where
Self: Sized,
Executes a given read only query against a specified graph Read more
source§fn graph_slowlog<R: CollectionResponse<GraphSlowlogResult>>(
self,
graph: impl SingleArg
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn graph_slowlog<R: CollectionResponse<GraphSlowlogResult>>(
self,
graph: impl SingleArg
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Returns a list containing up to 10 of the slowest queries issued against the given graph ID. Read more
source§impl<'a> HashCommands<'a> for &'a mut Transaction
impl<'a> HashCommands<'a> for &'a mut Transaction
source§fn hdel<K, F, C>(self, key: K, fields: C) -> PreparedCommand<'a, Self, usize>
fn hdel<K, F, C>(self, key: K, fields: C) -> PreparedCommand<'a, Self, usize>
Removes the specified fields from the hash stored at key. Read more
source§fn hexists<K, F>(self, key: K, field: F) -> PreparedCommand<'a, Self, bool>
fn hexists<K, F>(self, key: K, field: F) -> PreparedCommand<'a, Self, bool>
Returns if field is an existing field in the hash stored at key. Read more
source§fn hget<K, F, V>(self, key: K, field: F) -> PreparedCommand<'a, Self, V>
fn hget<K, F, V>(self, key: K, field: F) -> PreparedCommand<'a, Self, V>
Returns the value associated with field in the hash stored at key. Read more
source§fn hgetall<K, F, V, A>(self, key: K) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
F: PrimitiveResponse,
V: PrimitiveResponse,
A: KeyValueCollectionResponse<F, V>,
fn hgetall<K, F, V, A>(self, key: K) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
F: PrimitiveResponse,
V: PrimitiveResponse,
A: KeyValueCollectionResponse<F, V>,
Returns all fields and values of the hash stored at key. Read more
source§fn hincrby<K, F>(
self,
key: K,
field: F,
increment: i64
) -> PreparedCommand<'a, Self, i64>
fn hincrby<K, F>( self, key: K, field: F, increment: i64 ) -> PreparedCommand<'a, Self, i64>
Increments the number stored at field in the hash stored at key by increment. Read more
source§fn hincrbyfloat<K, F>(
self,
key: K,
field: F,
increment: f64
) -> PreparedCommand<'a, Self, f64>
fn hincrbyfloat<K, F>( self, key: K, field: F, increment: f64 ) -> PreparedCommand<'a, Self, f64>
Increment the specified field of a hash stored at key,
and representing a floating point number, by the specified increment. Read more
source§fn hkeys<K, F, A>(self, key: K) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
F: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<F> + DeserializeOwned,
fn hkeys<K, F, A>(self, key: K) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
F: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<F> + DeserializeOwned,
Returns all field names in the hash stored at key. Read more
source§fn hlen<K>(self, key: K) -> PreparedCommand<'a, Self, usize>
fn hlen<K>(self, key: K) -> PreparedCommand<'a, Self, usize>
Returns the number of fields contained in the hash stored at key. Read more
source§fn hmget<K, F, V, C, A>(self, key: K, fields: C) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
F: SingleArg,
C: SingleArgCollection<F>,
V: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<V> + DeserializeOwned,
fn hmget<K, F, V, C, A>(self, key: K, fields: C) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
F: SingleArg,
C: SingleArgCollection<F>,
V: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<V> + DeserializeOwned,
Returns the values associated with the specified fields in the hash stored at key. Read more
source§fn hrandfield<K, F>(self, key: K) -> PreparedCommand<'a, Self, F>
fn hrandfield<K, F>(self, key: K) -> PreparedCommand<'a, Self, F>
return random fields from the hash value stored at key. Read more
source§fn hrandfields<K, F, A>(
self,
key: K,
count: isize
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
F: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<F> + DeserializeOwned,
fn hrandfields<K, F, A>(
self,
key: K,
count: isize
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
F: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<F> + DeserializeOwned,
return random fields from the hash value stored at key. Read more
source§fn hrandfields_with_values<K, F, V, A>(
self,
key: K,
count: isize
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
F: PrimitiveResponse,
V: PrimitiveResponse,
A: KeyValueCollectionResponse<F, V>,
fn hrandfields_with_values<K, F, V, A>(
self,
key: K,
count: isize
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
F: PrimitiveResponse,
V: PrimitiveResponse,
A: KeyValueCollectionResponse<F, V>,
return random fields from the hash value stored at key. Read more
source§fn hscan<K, F, V>(
self,
key: K,
cursor: u64,
options: HScanOptions
) -> PreparedCommand<'a, Self, HScanResult<F, V>>where
Self: Sized,
K: SingleArg,
F: PrimitiveResponse + DeserializeOwned,
V: PrimitiveResponse + DeserializeOwned,
fn hscan<K, F, V>(
self,
key: K,
cursor: u64,
options: HScanOptions
) -> PreparedCommand<'a, Self, HScanResult<F, V>>where
Self: Sized,
K: SingleArg,
F: PrimitiveResponse + DeserializeOwned,
V: PrimitiveResponse + DeserializeOwned,
Iterates fields of Hash types and their associated values. Read more
source§fn hset<K, F, V, I>(self, key: K, items: I) -> PreparedCommand<'a, Self, usize>
fn hset<K, F, V, I>(self, key: K, items: I) -> PreparedCommand<'a, Self, usize>
Sets field in the hash stored at key to value. Read more
source§fn hsetnx<K, F, V>(
self,
key: K,
field: F,
value: V
) -> PreparedCommand<'a, Self, bool>
fn hsetnx<K, F, V>( self, key: K, field: F, value: V ) -> PreparedCommand<'a, Self, bool>
Sets field in the hash stored at key to value, only if field does not yet exist. Read more
source§fn hstrlen<K, F>(self, key: K, field: F) -> PreparedCommand<'a, Self, usize>
fn hstrlen<K, F>(self, key: K, field: F) -> PreparedCommand<'a, Self, usize>
Returns the string length of the value associated with field in the hash stored at key. Read more
source§fn hvals<K, V, A>(self, key: K) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
V: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<V> + DeserializeOwned,
fn hvals<K, V, A>(self, key: K) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
V: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<V> + DeserializeOwned,
list of values in the hash, or an empty list when key does not exist. Read more
source§impl<'a> HyperLogLogCommands<'a> for &'a mut Transaction
impl<'a> HyperLogLogCommands<'a> for &'a mut Transaction
source§fn pfadd<K, E, EE>(
self,
key: K,
elements: EE
) -> PreparedCommand<'a, Self, bool>
fn pfadd<K, E, EE>( self, key: K, elements: EE ) -> PreparedCommand<'a, Self, bool>
Adds the specified elements to the specified HyperLogLog. Read more
source§fn pfcount<K, KK>(self, keys: KK) -> PreparedCommand<'a, Self, usize>
fn pfcount<K, KK>(self, keys: KK) -> PreparedCommand<'a, Self, usize>
Return the approximated cardinality of the set(s)
observed by the HyperLogLog at key(s). Read more
source§impl<'a> JsonCommands<'a> for &'a mut Transaction
Available on crate feature redis-json
only.
impl<'a> JsonCommands<'a> for &'a mut Transaction
Available on crate feature
redis-json
only.source§fn json_arrappend<K, P, V, VV, R>(
self,
key: K,
path: P,
values: VV
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
K: SingleArg,
P: SingleArg,
V: SingleArg,
VV: SingleArgCollection<V>,
R: CollectionResponse<Option<usize>>,
fn json_arrappend<K, P, V, VV, R>(
self,
key: K,
path: P,
values: VV
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
K: SingleArg,
P: SingleArg,
V: SingleArg,
VV: SingleArgCollection<V>,
R: CollectionResponse<Option<usize>>,
source§fn json_arrindex<K, P, V, R>(
self,
key: K,
path: P,
value: V,
options: JsonArrIndexOptions
) -> PreparedCommand<'a, Self, R>
fn json_arrindex<K, P, V, R>( self, key: K, path: P, value: V, options: JsonArrIndexOptions ) -> PreparedCommand<'a, Self, R>
Search for the first occurrence of a scalar JSON value in an array Read more
source§fn json_arrinsert<K, P, V, VV, R>(
self,
key: K,
path: P,
index: isize,
values: VV
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
K: SingleArg,
P: SingleArg,
V: SingleArg,
VV: SingleArgCollection<V>,
R: CollectionResponse<Option<usize>>,
fn json_arrinsert<K, P, V, VV, R>(
self,
key: K,
path: P,
index: isize,
values: VV
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
K: SingleArg,
P: SingleArg,
V: SingleArg,
VV: SingleArgCollection<V>,
R: CollectionResponse<Option<usize>>,
source§fn json_arrlen<K, P, R>(self, key: K, path: P) -> PreparedCommand<'a, Self, R>
fn json_arrlen<K, P, R>(self, key: K, path: P) -> PreparedCommand<'a, Self, R>
source§fn json_arrpop<K, P, R, RR>(
self,
key: K,
path: P,
index: isize
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
K: SingleArg,
P: SingleArg,
R: PrimitiveResponse + DeserializeOwned,
RR: CollectionResponse<R>,
fn json_arrpop<K, P, R, RR>(
self,
key: K,
path: P,
index: isize
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
K: SingleArg,
P: SingleArg,
R: PrimitiveResponse + DeserializeOwned,
RR: CollectionResponse<R>,
Remove and return an element from the index in the array Read more
source§fn json_arrtrim<K, P, R>(
self,
key: K,
path: P,
start: isize,
stop: isize
) -> PreparedCommand<'a, Self, R>
fn json_arrtrim<K, P, R>( self, key: K, path: P, start: isize, stop: isize ) -> PreparedCommand<'a, Self, R>
Remove and return an element from the index in the array Read more
source§fn json_clear<K, P>(self, key: K, path: P) -> PreparedCommand<'a, Self, usize>
fn json_clear<K, P>(self, key: K, path: P) -> PreparedCommand<'a, Self, usize>
Clear container values (arrays/objects) and set numeric values to 0 Read more
source§fn json_debug_memory<K, P, R>(
self,
key: K,
path: P
) -> PreparedCommand<'a, Self, R>
fn json_debug_memory<K, P, R>( self, key: K, path: P ) -> PreparedCommand<'a, Self, R>
Report a value’s memory usage in bytes Read more
source§fn json_del<K, P>(self, key: K, path: P) -> PreparedCommand<'a, Self, usize>
fn json_del<K, P>(self, key: K, path: P) -> PreparedCommand<'a, Self, usize>
Delete a value Read more
source§fn json_forget<K, P>(self, key: K, path: P) -> PreparedCommand<'a, Self, usize>
fn json_forget<K, P>(self, key: K, path: P) -> PreparedCommand<'a, Self, usize>
source§fn json_get<K, V>(
self,
key: K,
options: JsonGetOptions
) -> PreparedCommand<'a, Self, V>
fn json_get<K, V>( self, key: K, options: JsonGetOptions ) -> PreparedCommand<'a, Self, V>
Return the value at path in JSON serialized form Read more
source§fn json_mget<K, KK, P, V, VV>(
self,
keys: KK,
path: P
) -> PreparedCommand<'a, Self, VV>where
Self: Sized,
K: SingleArg,
KK: SingleArgCollection<K>,
P: SingleArg,
V: PrimitiveResponse + DeserializeOwned,
VV: CollectionResponse<V>,
fn json_mget<K, KK, P, V, VV>(
self,
keys: KK,
path: P
) -> PreparedCommand<'a, Self, VV>where
Self: Sized,
K: SingleArg,
KK: SingleArgCollection<K>,
P: SingleArg,
V: PrimitiveResponse + DeserializeOwned,
VV: CollectionResponse<V>,
source§fn json_numincrby<K, P, V, R>(
self,
key: K,
path: P,
value: V
) -> PreparedCommand<'a, Self, R>
fn json_numincrby<K, P, V, R>( self, key: K, path: P, value: V ) -> PreparedCommand<'a, Self, R>
Increment the number value stored at path by number Read more
source§fn json_nummultby<K, P, V, R>(
self,
key: K,
path: P,
value: V
) -> PreparedCommand<'a, Self, R>
fn json_nummultby<K, P, V, R>( self, key: K, path: P, value: V ) -> PreparedCommand<'a, Self, R>
Multiply the number value stored at path by number Read more
source§fn json_objkeys<K, P, R, RR>(
self,
key: K,
path: P
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
K: SingleArg,
P: SingleArg,
R: PrimitiveResponse + DeserializeOwned,
RR: CollectionResponse<Vec<R>>,
fn json_objkeys<K, P, R, RR>(
self,
key: K,
path: P
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
K: SingleArg,
P: SingleArg,
R: PrimitiveResponse + DeserializeOwned,
RR: CollectionResponse<Vec<R>>,
Return the keys in the object that’s referenced by
path
Read moresource§fn json_objlen<K, P, R>(self, key: K, path: P) -> PreparedCommand<'a, Self, R>
fn json_objlen<K, P, R>(self, key: K, path: P) -> PreparedCommand<'a, Self, R>
source§fn json_resp<K, P, VV>(self, key: K, path: P) -> PreparedCommand<'a, Self, VV>
fn json_resp<K, P, VV>(self, key: K, path: P) -> PreparedCommand<'a, Self, VV>
Return the JSON in key in
Redis serialization protocol specification
form Read moresource§fn json_set<K, P, V>(
self,
key: K,
path: P,
value: V,
condition: SetCondition
) -> PreparedCommand<'a, Self, ()>
fn json_set<K, P, V>( self, key: K, path: P, value: V, condition: SetCondition ) -> PreparedCommand<'a, Self, ()>
source§fn json_strappend<K, P, V, R>(
self,
key: K,
path: P,
value: V
) -> PreparedCommand<'a, Self, R>
fn json_strappend<K, P, V, R>( self, key: K, path: P, value: V ) -> PreparedCommand<'a, Self, R>
Append the json-string values to the string at path Read more
source§fn json_strlen<K, P, R>(self, key: K, path: P) -> PreparedCommand<'a, Self, R>
fn json_strlen<K, P, R>(self, key: K, path: P) -> PreparedCommand<'a, Self, R>
source§fn json_toggle<K, P, R>(self, key: K, path: P) -> PreparedCommand<'a, Self, R>
fn json_toggle<K, P, R>(self, key: K, path: P) -> PreparedCommand<'a, Self, R>
Toggle a Boolean value stored at
path
Read moresource§fn json_type<K, P, R, RR>(
self,
key: K,
path: P
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
K: SingleArg,
P: SingleArg,
R: PrimitiveResponse + DeserializeOwned,
RR: CollectionResponse<R>,
fn json_type<K, P, R, RR>(
self,
key: K,
path: P
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
K: SingleArg,
P: SingleArg,
R: PrimitiveResponse + DeserializeOwned,
RR: CollectionResponse<R>,
Report the type of JSON value at
path
Read moresource§impl<'a> ListCommands<'a> for &'a mut Transaction
impl<'a> ListCommands<'a> for &'a mut Transaction
source§fn lindex<K, E>(self, key: K, index: isize) -> PreparedCommand<'a, Self, E>
fn lindex<K, E>(self, key: K, index: isize) -> PreparedCommand<'a, Self, E>
Returns the element at index index in the list stored at key. Read more
source§fn linsert<K, E>(
self,
key: K,
where_: LInsertWhere,
pivot: E,
element: E
) -> PreparedCommand<'a, Self, usize>
fn linsert<K, E>( self, key: K, where_: LInsertWhere, pivot: E, element: E ) -> PreparedCommand<'a, Self, usize>
Inserts element in the list stored at key either before or after the reference value pivot. Read more
source§fn llen<K>(self, key: K) -> PreparedCommand<'a, Self, usize>
fn llen<K>(self, key: K) -> PreparedCommand<'a, Self, usize>
Inserts element in the list stored at key either before or after the reference value pivot. Read more
source§fn lmove<S, D, E>(
self,
source: S,
destination: D,
where_from: LMoveWhere,
where_to: LMoveWhere
) -> PreparedCommand<'a, Self, E>
fn lmove<S, D, E>( self, source: S, destination: D, where_from: LMoveWhere, where_to: LMoveWhere ) -> PreparedCommand<'a, Self, E>
Atomically returns and removes the first/last element (head/tail depending on the wherefrom argument)
of the list stored at source, and pushes the element at the first/last element
(head/tail depending on the whereto argument) of the list stored at destination. Read more
source§fn lmpop<K, E, C>(
self,
keys: C,
where_: LMoveWhere,
count: usize
) -> PreparedCommand<'a, Self, (String, Vec<E>)>where
Self: Sized,
K: SingleArg,
E: PrimitiveResponse + DeserializeOwned,
C: SingleArgCollection<K>,
fn lmpop<K, E, C>(
self,
keys: C,
where_: LMoveWhere,
count: usize
) -> PreparedCommand<'a, Self, (String, Vec<E>)>where
Self: Sized,
K: SingleArg,
E: PrimitiveResponse + DeserializeOwned,
C: SingleArgCollection<K>,
Pops one or more elements from the first non-empty list key from the list of provided key names. Read more
source§fn lpop<K, E, A>(self, key: K, count: usize) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
E: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<E> + DeserializeOwned,
fn lpop<K, E, A>(self, key: K, count: usize) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
E: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<E> + DeserializeOwned,
Removes and returns the first elements of the list stored at key. Read more
source§fn lpos<K, E>(
self,
key: K,
element: E,
rank: Option<usize>,
max_len: Option<usize>
) -> PreparedCommand<'a, Self, Option<usize>>
fn lpos<K, E>( self, key: K, element: E, rank: Option<usize>, max_len: Option<usize> ) -> PreparedCommand<'a, Self, Option<usize>>
Returns the index of matching elements inside a Redis list. Read more
source§fn lpos_with_count<K, E, A>(
self,
key: K,
element: E,
num_matches: usize,
rank: Option<usize>,
max_len: Option<usize>
) -> PreparedCommand<'a, Self, A>
fn lpos_with_count<K, E, A>( self, key: K, element: E, num_matches: usize, rank: Option<usize>, max_len: Option<usize> ) -> PreparedCommand<'a, Self, A>
Returns the index of matching elements inside a Redis list. Read more
source§fn lpush<K, E, C>(self, key: K, elements: C) -> PreparedCommand<'a, Self, usize>
fn lpush<K, E, C>(self, key: K, elements: C) -> PreparedCommand<'a, Self, usize>
Insert all the specified values at the head of the list stored at key Read more
source§fn lpushx<K, E, C>(
self,
key: K,
elements: C
) -> PreparedCommand<'a, Self, usize>
fn lpushx<K, E, C>( self, key: K, elements: C ) -> PreparedCommand<'a, Self, usize>
Inserts specified values at the head of the list stored at key,
only if key already exists and holds a list. Read more
source§fn lrange<K, E, A>(
self,
key: K,
start: isize,
stop: isize
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
E: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<E> + DeserializeOwned,
fn lrange<K, E, A>(
self,
key: K,
start: isize,
stop: isize
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
E: PrimitiveResponse + DeserializeOwned,
A: CollectionResponse<E> + DeserializeOwned,
Returns the specified elements of the list stored at key. Read more
source§fn lrem<K, E>(
self,
key: K,
count: isize,
element: E
) -> PreparedCommand<'a, Self, usize>
fn lrem<K, E>( self, key: K, count: isize, element: E ) -> PreparedCommand<'a, Self, usize>
Removes the first count occurrences of elements equal to element from the list stored at key. Read more
source§fn lset<K, E>(
self,
key: K,
index: isize,
element: E
) -> PreparedCommand<'a, Self, ()>
fn lset<K, E>( self, key: K, index: isize, element: E ) -> PreparedCommand<'a, Self, ()>
Sets the list element at index to element. Read more
source§fn ltrim<K>(
self,
key: K,
start: isize,
stop: isize
) -> PreparedCommand<'a, Self, ()>
fn ltrim<K>( self, key: K, start: isize, stop: isize ) -> PreparedCommand<'a, Self, ()>
Trim an existing list so that it will contain only the specified range of elements specified. Read more
source§fn rpop<K, E, C>(self, key: K, count: usize) -> PreparedCommand<'a, Self, C>where
Self: Sized,
K: SingleArg,
E: PrimitiveResponse + DeserializeOwned,
C: CollectionResponse<E> + DeserializeOwned,
fn rpop<K, E, C>(self, key: K, count: usize) -> PreparedCommand<'a, Self, C>where
Self: Sized,
K: SingleArg,
E: PrimitiveResponse + DeserializeOwned,
C: CollectionResponse<E> + DeserializeOwned,
Removes and returns the first elements of the list stored at key. Read more
source§fn rpush<K, E, C>(self, key: K, elements: C) -> PreparedCommand<'a, Self, usize>
fn rpush<K, E, C>(self, key: K, elements: C) -> PreparedCommand<'a, Self, usize>
Insert all the specified values at the tail of the list stored at key Read more
source§impl<'a> ScriptingCommands<'a> for &'a mut Transaction
impl<'a> ScriptingCommands<'a> for &'a mut Transaction
source§fn eval<R>(self, builder: CallBuilder) -> PreparedCommand<'a, Self, R>
fn eval<R>(self, builder: CallBuilder) -> PreparedCommand<'a, Self, R>
Invoke the execution of a server-side Lua script. Read more
source§fn eval_readonly<R>(self, builder: CallBuilder) -> PreparedCommand<'a, Self, R>
fn eval_readonly<R>(self, builder: CallBuilder) -> PreparedCommand<'a, Self, R>
source§fn evalsha<R>(self, builder: CallBuilder) -> PreparedCommand<'a, Self, R>
fn evalsha<R>(self, builder: CallBuilder) -> PreparedCommand<'a, Self, R>
Evaluate a script from the server’s cache by its SHA1 digest. Read more
source§fn evalsha_readonly<R>(
self,
builder: CallBuilder
) -> PreparedCommand<'a, Self, R>
fn evalsha_readonly<R>( self, builder: CallBuilder ) -> PreparedCommand<'a, Self, R>
source§fn fcall<R>(self, builder: CallBuilder) -> PreparedCommand<'a, Self, R>
fn fcall<R>(self, builder: CallBuilder) -> PreparedCommand<'a, Self, R>
Invoke a function. Read more
source§fn fcall_readonly<R>(self, builder: CallBuilder) -> PreparedCommand<'a, Self, R>
fn fcall_readonly<R>(self, builder: CallBuilder) -> PreparedCommand<'a, Self, R>
Invoke a function. Read more
source§fn function_delete<L>(self, library_name: L) -> PreparedCommand<'a, Self, ()>
fn function_delete<L>(self, library_name: L) -> PreparedCommand<'a, Self, ()>
Delete a library and all its functions. Read more
source§fn function_dump(self) -> PreparedCommand<'a, Self, FunctionDumpResult>where
Self: Sized,
fn function_dump(self) -> PreparedCommand<'a, Self, FunctionDumpResult>where
Self: Sized,
Return the serialized payload of loaded libraries.
You can restore the serialized payload later with the
function_restore
command. Read moresource§fn function_flush(
self,
flushing_mode: FlushingMode
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn function_flush(
self,
flushing_mode: FlushingMode
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Deletes all the libraries. Read more
source§fn function_kill(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn function_kill(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Kill a function that is currently executing. Read more
source§fn function_list(
self,
options: FunctionListOptions
) -> PreparedCommand<'a, Self, Vec<LibraryInfo>>where
Self: Sized,
fn function_list(
self,
options: FunctionListOptions
) -> PreparedCommand<'a, Self, Vec<LibraryInfo>>where
Self: Sized,
Return information about the functions and libraries. Read more
source§fn function_load<F, L>(
self,
replace: bool,
function_code: F
) -> PreparedCommand<'a, Self, L>
fn function_load<F, L>( self, replace: bool, function_code: F ) -> PreparedCommand<'a, Self, L>
Load a library to Redis. Read more
source§fn function_restore<P>(
self,
serialized_payload: P,
policy: FunctionRestorePolicy
) -> PreparedCommand<'a, Self, ()>
fn function_restore<P>( self, serialized_payload: P, policy: FunctionRestorePolicy ) -> PreparedCommand<'a, Self, ()>
Restore libraries from the serialized payload. Read more
source§fn function_stats(self) -> PreparedCommand<'a, Self, FunctionStats>where
Self: Sized,
fn function_stats(self) -> PreparedCommand<'a, Self, FunctionStats>where
Self: Sized,
Return information about the function that’s currently running and information about the available execution engines. Read more
source§fn script_debug(
self,
debug_mode: ScriptDebugMode
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn script_debug(
self,
debug_mode: ScriptDebugMode
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Set the debug mode for subsequent scripts executed with EVAL. Read more
source§fn script_exists<S, C>(self, sha1s: C) -> PreparedCommand<'a, Self, Vec<bool>>
fn script_exists<S, C>(self, sha1s: C) -> PreparedCommand<'a, Self, Vec<bool>>
Returns information about the existence of the scripts in the script cache. Read more
source§fn script_flush(
self,
flushing_mode: FlushingMode
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn script_flush(
self,
flushing_mode: FlushingMode
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Flush the Lua scripts cache. Read more
source§fn script_kill(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn script_kill(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Kills the currently executing EVAL script,
assuming no write operation was yet performed by the script. Read more
source§fn script_load<S, V>(self, script: S) -> PreparedCommand<'a, Self, V>
fn script_load<S, V>(self, script: S) -> PreparedCommand<'a, Self, V>
Load a script into the scripts cache, without executing it. Read more
source§impl<'a> SearchCommands<'a> for &'a mut Transaction
Available on crate feature redis-search
only.
impl<'a> SearchCommands<'a> for &'a mut Transaction
Available on crate feature
redis-search
only.source§fn ft_aggregate<I, Q>(
self,
index: I,
query: Q,
options: FtAggregateOptions
) -> PreparedCommand<'a, Self, FtAggregateResult>
fn ft_aggregate<I, Q>( self, index: I, query: Q, options: FtAggregateOptions ) -> PreparedCommand<'a, Self, FtAggregateResult>
Run a search query on an index,
and perform aggregate transformations on the results,
extracting statistics etc from them Read more
source§fn ft_aliasadd<A, I>(self, alias: A, index: I) -> PreparedCommand<'a, Self, ()>
fn ft_aliasadd<A, I>(self, alias: A, index: I) -> PreparedCommand<'a, Self, ()>
Add an alias to an index Read more
source§fn ft_aliasdel<A>(self, alias: A) -> PreparedCommand<'a, Self, ()>
fn ft_aliasdel<A>(self, alias: A) -> PreparedCommand<'a, Self, ()>
Remove an alias from an index Read more
source§fn ft_aliasupdate<A, I>(
self,
alias: A,
index: I
) -> PreparedCommand<'a, Self, ()>
fn ft_aliasupdate<A, I>( self, alias: A, index: I ) -> PreparedCommand<'a, Self, ()>
Add an alias to an index. Read more
source§fn ft_alter<I>(
self,
index: I,
skip_initial_scan: bool,
attribute: FtFieldSchema
) -> PreparedCommand<'a, Self, ()>
fn ft_alter<I>( self, index: I, skip_initial_scan: bool, attribute: FtFieldSchema ) -> PreparedCommand<'a, Self, ()>
Add a new attribute to the index. Read more
source§fn ft_config_get<O, N, V, R>(self, option: O) -> PreparedCommand<'a, Self, R>where
Self: Sized,
O: SingleArg,
N: PrimitiveResponse,
V: PrimitiveResponse,
R: KeyValueCollectionResponse<N, V>,
fn ft_config_get<O, N, V, R>(self, option: O) -> PreparedCommand<'a, Self, R>where
Self: Sized,
O: SingleArg,
N: PrimitiveResponse,
V: PrimitiveResponse,
R: KeyValueCollectionResponse<N, V>,
Retrieve configuration options Read more
source§fn ft_config_set<O, V>(
self,
option: O,
value: V
) -> PreparedCommand<'a, Self, ()>
fn ft_config_set<O, V>( self, option: O, value: V ) -> PreparedCommand<'a, Self, ()>
Set configuration options Read more
source§fn ft_create<I, S>(
self,
index: I,
options: FtCreateOptions,
schema: S
) -> PreparedCommand<'a, Self, ()>
fn ft_create<I, S>( self, index: I, options: FtCreateOptions, schema: S ) -> PreparedCommand<'a, Self, ()>
Create an index with the given specification Read more
source§fn ft_cursor_del<I>(
self,
index: I,
cursor_id: u64
) -> PreparedCommand<'a, Self, ()>
fn ft_cursor_del<I>( self, index: I, cursor_id: u64 ) -> PreparedCommand<'a, Self, ()>
Delete a cursor Read more
source§fn ft_cursor_read<I>(
self,
index: I,
cursor_id: u64
) -> PreparedCommand<'a, Self, FtAggregateResult>
fn ft_cursor_read<I>( self, index: I, cursor_id: u64 ) -> PreparedCommand<'a, Self, FtAggregateResult>
Read next results from an existing cursor Read more
source§fn ft_dictadd<D, T, TT>(
self,
dict: D,
terms: TT
) -> PreparedCommand<'a, Self, usize>
fn ft_dictadd<D, T, TT>( self, dict: D, terms: TT ) -> PreparedCommand<'a, Self, usize>
Add terms to a dictionary Read more
source§fn ft_dictdel<D, T, TT>(
self,
dict: D,
terms: TT
) -> PreparedCommand<'a, Self, usize>
fn ft_dictdel<D, T, TT>( self, dict: D, terms: TT ) -> PreparedCommand<'a, Self, usize>
Delete terms from a dictionary Read more
source§fn ft_dictdump<D, T, TT>(self, dict: D) -> PreparedCommand<'a, Self, TT>where
Self: Sized,
D: SingleArg,
T: PrimitiveResponse + DeserializeOwned,
TT: CollectionResponse<T>,
fn ft_dictdump<D, T, TT>(self, dict: D) -> PreparedCommand<'a, Self, TT>where
Self: Sized,
D: SingleArg,
T: PrimitiveResponse + DeserializeOwned,
TT: CollectionResponse<T>,
Dump all terms in the given dictionary Read more
source§fn ft_dropindex<I>(self, index: I, dd: bool) -> PreparedCommand<'a, Self, ()>
fn ft_dropindex<I>(self, index: I, dd: bool) -> PreparedCommand<'a, Self, ()>
Delete an index Read more
source§fn ft_explain<I, Q, R>(
self,
index: I,
query: Q,
dialect_version: Option<u64>
) -> PreparedCommand<'a, Self, R>
fn ft_explain<I, Q, R>( self, index: I, query: Q, dialect_version: Option<u64> ) -> PreparedCommand<'a, Self, R>
Return the execution plan for a complex query Read more
source§fn ft_explaincli<I, Q, R, RR>(
self,
index: I,
query: Q,
dialect_version: Option<u64>
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
I: SingleArg,
Q: SingleArg,
R: PrimitiveResponse + DeserializeOwned,
RR: CollectionResponse<R>,
fn ft_explaincli<I, Q, R, RR>(
self,
index: I,
query: Q,
dialect_version: Option<u64>
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
I: SingleArg,
Q: SingleArg,
R: PrimitiveResponse + DeserializeOwned,
RR: CollectionResponse<R>,
Return the execution plan for a complex query but formatted for easier reading without using
redis-cli --raw
Read moresource§fn ft_info(
self,
index: impl SingleArg
) -> PreparedCommand<'a, Self, FtInfoResult>where
Self: Sized,
fn ft_info(
self,
index: impl SingleArg
) -> PreparedCommand<'a, Self, FtInfoResult>where
Self: Sized,
Return information and statistics on the index Read more
source§fn ft_list<R, RR>(self) -> PreparedCommand<'a, Self, RR>
fn ft_list<R, RR>(self) -> PreparedCommand<'a, Self, RR>
Returns a list of all existing indexes. Read more
source§fn ft_profile_search<I, Q, QQ>(
self,
index: I,
limited: bool,
query: QQ
) -> PreparedCommand<'a, Self, FtProfileSearchResult>
fn ft_profile_search<I, Q, QQ>( self, index: I, limited: bool, query: QQ ) -> PreparedCommand<'a, Self, FtProfileSearchResult>
source§fn ft_profile_aggregate<I, Q, QQ>(
self,
index: I,
limited: bool,
query: QQ
) -> PreparedCommand<'a, Self, FtProfileAggregateResult>
fn ft_profile_aggregate<I, Q, QQ>( self, index: I, limited: bool, query: QQ ) -> PreparedCommand<'a, Self, FtProfileAggregateResult>
Perform a
ft_aggregate
command and collects performance information Read moresource§fn ft_search<I, Q>(
self,
index: I,
query: Q,
options: FtSearchOptions
) -> PreparedCommand<'a, Self, FtSearchResult>
fn ft_search<I, Q>( self, index: I, query: Q, options: FtSearchOptions ) -> PreparedCommand<'a, Self, FtSearchResult>
Search the index with a textual query, returning either documents or just ids Read more
source§fn ft_spellcheck<I, Q>(
self,
index: I,
query: Q,
options: FtSpellCheckOptions
) -> PreparedCommand<'a, Self, FtSpellCheckResult>
fn ft_spellcheck<I, Q>( self, index: I, query: Q, options: FtSpellCheckOptions ) -> PreparedCommand<'a, Self, FtSpellCheckResult>
Perform spelling correction on a query, returning suggestions for misspelled terms Read more
source§fn ft_syndump<I, R>(self, index: I) -> PreparedCommand<'a, Self, R>
fn ft_syndump<I, R>(self, index: I) -> PreparedCommand<'a, Self, R>
Dump the contents of a synonym group Read more
source§fn ft_synupdate<T: SingleArg>(
self,
index: impl SingleArg,
synonym_group_id: impl SingleArg,
skip_initial_scan: bool,
terms: impl SingleArgCollection<T>
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn ft_synupdate<T: SingleArg>(
self,
index: impl SingleArg,
synonym_group_id: impl SingleArg,
skip_initial_scan: bool,
terms: impl SingleArgCollection<T>
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Update a synonym group Read more
source§fn ft_tagvals<R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
index: impl SingleArg,
field_name: impl SingleArg
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
fn ft_tagvals<R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
index: impl SingleArg,
field_name: impl SingleArg
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
Return a distinct set of values indexed in a Tag field Read more
source§fn ft_sugadd(
self,
key: impl SingleArg,
string: impl SingleArg,
score: f64,
options: FtSugAddOptions
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
fn ft_sugadd(
self,
key: impl SingleArg,
string: impl SingleArg,
score: f64,
options: FtSugAddOptions
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
Add a suggestion string to an auto-complete suggestion dictionary Read more
source§fn ft_sugdel(
self,
key: impl SingleArg,
string: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
fn ft_sugdel(
self,
key: impl SingleArg,
string: impl SingleArg
) -> PreparedCommand<'a, Self, bool>where
Self: Sized,
Delete a string from a suggestion index Read more
source§fn ft_sugget(
self,
key: impl SingleArg,
prefix: impl SingleArg,
options: FtSugGetOptions
) -> PreparedCommand<'a, Self, Vec<FtSuggestion>>where
Self: Sized,
fn ft_sugget(
self,
key: impl SingleArg,
prefix: impl SingleArg,
options: FtSugGetOptions
) -> PreparedCommand<'a, Self, Vec<FtSuggestion>>where
Self: Sized,
Get completion suggestions for a prefix Read more
source§impl<'a> ServerCommands<'a> for &'a mut Transaction
impl<'a> ServerCommands<'a> for &'a mut Transaction
source§fn acl_cat<C, CC>(self, options: AclCatOptions) -> PreparedCommand<'a, Self, CC>
fn acl_cat<C, CC>(self, options: AclCatOptions) -> PreparedCommand<'a, Self, CC>
The command shows the available ACL categories if called without arguments.
If a category name is given, the command shows all the Redis commands in the specified category. Read more
source§fn acl_deluser<U, UU>(self, usernames: UU) -> PreparedCommand<'a, Self, usize>
fn acl_deluser<U, UU>(self, usernames: UU) -> PreparedCommand<'a, Self, usize>
Delete all the specified ACL users and terminate all
the connections that are authenticated with such users. Read more
source§fn acl_dryrun<U, C, R>(
self,
username: U,
command: C,
options: AclDryRunOptions
) -> PreparedCommand<'a, Self, R>
fn acl_dryrun<U, C, R>( self, username: U, command: C, options: AclDryRunOptions ) -> PreparedCommand<'a, Self, R>
Simulate the execution of a given command by a given user. Read more
source§fn acl_genpass<R: PrimitiveResponse>(
self,
options: AclGenPassOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn acl_genpass<R: PrimitiveResponse>(
self,
options: AclGenPassOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Generates a password starting from /dev/urandom if available,
otherwise (in systems without /dev/urandom) it uses a weaker
system that is likely still better than picking a weak password by hand. Read more
source§fn acl_getuser<U, RR>(self, username: U) -> PreparedCommand<'a, Self, RR>
fn acl_getuser<U, RR>(self, username: U) -> PreparedCommand<'a, Self, RR>
The command returns all the rules defined for an existing ACL user. Read more
source§fn acl_list(self) -> PreparedCommand<'a, Self, Vec<String>>where
Self: Sized,
fn acl_list(self) -> PreparedCommand<'a, Self, Vec<String>>where
Self: Sized,
The command shows the currently active ACL rules in the Redis server. Read more
source§fn acl_load(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn acl_load(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
When Redis is configured to use an ACL file (with the aclfile configuration option),
this command will reload the ACLs from the file, replacing all the current ACL rules
with the ones defined in the file. Read more
source§fn acl_log<EE>(
self,
options: AclLogOptions
) -> PreparedCommand<'a, Self, Vec<EE>>
fn acl_log<EE>( self, options: AclLogOptions ) -> PreparedCommand<'a, Self, Vec<EE>>
The command shows a list of recent ACL security events Read more
source§fn acl_save(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn acl_save(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
When Redis is configured to use an ACL file (with the aclfile configuration option),
this command will save the currently defined ACLs from the server memory to the ACL file. Read more
source§fn acl_setuser<U, R, RR>(
self,
username: U,
rules: RR
) -> PreparedCommand<'a, Self, ()>
fn acl_setuser<U, R, RR>( self, username: U, rules: RR ) -> PreparedCommand<'a, Self, ()>
Create an ACL user with the specified rules or modify the rules of an existing user. Read more
source§fn acl_users<U, UU>(self) -> PreparedCommand<'a, Self, UU>
fn acl_users<U, UU>(self) -> PreparedCommand<'a, Self, UU>
The command shows a list of all the usernames of the currently configured users in the Redis ACL system. Read more
source§fn acl_whoami<U: PrimitiveResponse>(self) -> PreparedCommand<'a, Self, U>where
Self: Sized,
fn acl_whoami<U: PrimitiveResponse>(self) -> PreparedCommand<'a, Self, U>where
Self: Sized,
Return the username the current connection is authenticated with. Read more
source§fn command(self) -> PreparedCommand<'a, Self, Vec<CommandInfo>>where
Self: Sized,
fn command(self) -> PreparedCommand<'a, Self, Vec<CommandInfo>>where
Self: Sized,
Return an array with details about every Redis command. Read more
source§fn command_count(self) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
fn command_count(self) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
Number of total commands in this Redis server. Read more
source§fn command_docs<N, NN, DD>(
self,
command_names: NN
) -> PreparedCommand<'a, Self, DD>where
Self: Sized,
N: SingleArg,
NN: SingleArgCollection<N>,
DD: KeyValueCollectionResponse<String, CommandDoc>,
fn command_docs<N, NN, DD>(
self,
command_names: NN
) -> PreparedCommand<'a, Self, DD>where
Self: Sized,
N: SingleArg,
NN: SingleArgCollection<N>,
DD: KeyValueCollectionResponse<String, CommandDoc>,
Number of total commands in this Redis server. Read more
source§fn command_getkeys<A, AA, KK>(self, args: AA) -> PreparedCommand<'a, Self, KK>
fn command_getkeys<A, AA, KK>(self, args: AA) -> PreparedCommand<'a, Self, KK>
A helper command to let you find the keys from a full Redis command. Read more
source§fn command_getkeysandflags<A, AA, KK>(
self,
args: AA
) -> PreparedCommand<'a, Self, KK>where
Self: Sized,
A: SingleArg,
AA: SingleArgCollection<A>,
KK: KeyValueCollectionResponse<String, Vec<String>>,
fn command_getkeysandflags<A, AA, KK>(
self,
args: AA
) -> PreparedCommand<'a, Self, KK>where
Self: Sized,
A: SingleArg,
AA: SingleArgCollection<A>,
KK: KeyValueCollectionResponse<String, Vec<String>>,
A helper command to let you find the keys from a full Redis command together with flags indicating what each key is used for. Read more
source§fn command_info<N, NN>(
self,
command_names: NN
) -> PreparedCommand<'a, Self, Vec<CommandInfo>>
fn command_info<N, NN>( self, command_names: NN ) -> PreparedCommand<'a, Self, Vec<CommandInfo>>
Return an array with details about multiple Redis command. Read more
source§fn command_list<CC>(
self,
options: CommandListOptions
) -> PreparedCommand<'a, Self, CC>
fn command_list<CC>( self, options: CommandListOptions ) -> PreparedCommand<'a, Self, CC>
Return an array of the server’s command names based on optional filters Read more
source§fn config_get<P, PP, V, VV>(self, params: PP) -> PreparedCommand<'a, Self, VV>where
Self: Sized,
P: SingleArg,
PP: SingleArgCollection<P>,
V: PrimitiveResponse,
VV: KeyValueCollectionResponse<String, V>,
fn config_get<P, PP, V, VV>(self, params: PP) -> PreparedCommand<'a, Self, VV>where
Self: Sized,
P: SingleArg,
PP: SingleArgCollection<P>,
V: PrimitiveResponse,
VV: KeyValueCollectionResponse<String, V>,
Used to read the configuration parameters of a running Redis server. Read more
source§fn config_resetstat(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn config_resetstat(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
source§fn config_rewrite(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn config_rewrite(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Rewrites the redis.conf file the server was started with,
applying the minimal changes needed to make it reflect the configuration currently used by the server,
which may be different compared to the original one because of the use of the
config_set
command. Read moresource§fn config_set<P, V, C>(self, configs: C) -> PreparedCommand<'a, Self, ()>
fn config_set<P, V, C>(self, configs: C) -> PreparedCommand<'a, Self, ()>
Used in order to reconfigure the server at run time without the need to restart Redis. Read more
source§fn dbsize(self) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
fn dbsize(self) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
Return the number of keys in the currently-selected database. Read more
source§fn failover(self, options: FailOverOptions) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn failover(self, options: FailOverOptions) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
This command will start a coordinated failover between
the currently-connected-to master and one of its replicas. Read more
source§fn flushdb(self, flushing_mode: FlushingMode) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn flushdb(self, flushing_mode: FlushingMode) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Delete all the keys of the currently selected DB. Read more
source§fn flushall(self, flushing_mode: FlushingMode) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn flushall(self, flushing_mode: FlushingMode) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Delete all the keys of all the existing databases, not just the currently selected one. Read more
source§fn info<SS>(self, sections: SS) -> PreparedCommand<'a, Self, String>
fn info<SS>(self, sections: SS) -> PreparedCommand<'a, Self, String>
This command returns information and statistics about the server
in a format that is simple to parse by computers and easy to read by humans. Read more
source§fn lastsave(self) -> PreparedCommand<'a, Self, u64>where
Self: Sized,
fn lastsave(self) -> PreparedCommand<'a, Self, u64>where
Self: Sized,
Return the UNIX TIME of the last DB save executed with success. Read more
source§fn latency_doctor(self) -> PreparedCommand<'a, Self, String>where
Self: Sized,
fn latency_doctor(self) -> PreparedCommand<'a, Self, String>where
Self: Sized,
This command reports about different latency-related issues and advises about possible remedies. Read more
source§fn latency_graph(
self,
event: LatencyHistoryEvent
) -> PreparedCommand<'a, Self, String>where
Self: Sized,
fn latency_graph(
self,
event: LatencyHistoryEvent
) -> PreparedCommand<'a, Self, String>where
Self: Sized,
Produces an ASCII-art style graph for the specified event. Read more
source§fn latency_histogram<C, CC, RR>(
self,
commands: CC
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
C: SingleArg,
CC: SingleArgCollection<C>,
RR: KeyValueCollectionResponse<String, CommandHistogram>,
fn latency_histogram<C, CC, RR>(
self,
commands: CC
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
C: SingleArg,
CC: SingleArgCollection<C>,
RR: KeyValueCollectionResponse<String, CommandHistogram>,
This command reports a cumulative distribution of latencies
in the format of a histogram for each of the specified command names. Read more
source§fn latency_history<RR>(
self,
event: LatencyHistoryEvent
) -> PreparedCommand<'a, Self, RR>
fn latency_history<RR>( self, event: LatencyHistoryEvent ) -> PreparedCommand<'a, Self, RR>
This command returns the raw data of the event’s latency spikes time series. Read more
source§fn latency_latest<RR>(self) -> PreparedCommand<'a, Self, RR>
fn latency_latest<RR>(self) -> PreparedCommand<'a, Self, RR>
This command reports the latest latency events logged. Read more
source§fn latency_reset<EE>(self, events: EE) -> PreparedCommand<'a, Self, usize>
fn latency_reset<EE>(self, events: EE) -> PreparedCommand<'a, Self, usize>
This command resets the latency spikes time series of all, or only some, events. Read more
source§fn lolwut(self, options: LolWutOptions) -> PreparedCommand<'a, Self, String>where
Self: Sized,
fn lolwut(self, options: LolWutOptions) -> PreparedCommand<'a, Self, String>where
Self: Sized,
The LOLWUT command displays the Redis version: however as a side effect of doing so,
it also creates a piece of generative computer art that is different with each version of Redis. Read more
source§fn memory_doctor(self) -> PreparedCommand<'a, Self, String>where
Self: Sized,
fn memory_doctor(self) -> PreparedCommand<'a, Self, String>where
Self: Sized,
This command reports about different memory-related issues that
the Redis server experiences, and advises about possible remedies. Read more
source§fn memory_malloc_stats(self) -> PreparedCommand<'a, Self, String>where
Self: Sized,
fn memory_malloc_stats(self) -> PreparedCommand<'a, Self, String>where
Self: Sized,
This command provides an internal statistics report from the memory allocator. Read more
source§fn memory_purge(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn memory_purge(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
This command attempts to purge dirty pages so these can be reclaimed by the allocator. Read more
source§fn memory_stats(self) -> PreparedCommand<'a, Self, MemoryStats>where
Self: Sized,
fn memory_stats(self) -> PreparedCommand<'a, Self, MemoryStats>where
Self: Sized,
This command returns information about the memory usage of the server. Read more
source§fn memory_usage<K>(
self,
key: K,
options: MemoryUsageOptions
) -> PreparedCommand<'a, Self, Option<usize>>
fn memory_usage<K>( self, key: K, options: MemoryUsageOptions ) -> PreparedCommand<'a, Self, Option<usize>>
This command reports the number of bytes that a key and its value require to be stored in RAM. Read more
source§fn module_list<MM>(self) -> PreparedCommand<'a, Self, MM>
fn module_list<MM>(self) -> PreparedCommand<'a, Self, MM>
Returns information about the modules loaded to the server. Read more
source§fn module_load<P>(
self,
path: P,
options: ModuleLoadOptions
) -> PreparedCommand<'a, Self, ()>
fn module_load<P>( self, path: P, options: ModuleLoadOptions ) -> PreparedCommand<'a, Self, ()>
Loads a module from a dynamic library at runtime. Read more
source§fn module_unload<N>(self, name: N) -> PreparedCommand<'a, Self, ()>
fn module_unload<N>(self, name: N) -> PreparedCommand<'a, Self, ()>
Unloads a module. Read more
source§fn replicaof(self, options: ReplicaOfOptions) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn replicaof(self, options: ReplicaOfOptions) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
This command can change the replication settings of a replica on the fly. Read more
source§fn role(self) -> PreparedCommand<'a, Self, RoleResult>where
Self: Sized,
fn role(self) -> PreparedCommand<'a, Self, RoleResult>where
Self: Sized,
Provide information on the role of a Redis instance in the context of replication,
by returning if the instance is currently a
master
, slave
, or sentinel
. Read moresource§fn save(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn save(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
This command performs a synchronous save of the dataset producing a point in time snapshot
of all the data inside the Redis instance, in the form of an RDB file. Read more
source§fn shutdown(self, options: ShutdownOptions) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn shutdown(self, options: ShutdownOptions) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Shutdown the server Read more
source§fn slowlog_get(
self,
options: SlowLogOptions
) -> PreparedCommand<'a, Self, Vec<SlowLogEntry>>where
Self: Sized,
fn slowlog_get(
self,
options: SlowLogOptions
) -> PreparedCommand<'a, Self, Vec<SlowLogEntry>>where
Self: Sized,
This command returns entries from the slow log in chronological order. Read more
source§fn slowlog_len(self) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
fn slowlog_len(self) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
This command returns the current number of entries in the slow log. Read more
source§fn slowlog_reset(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn slowlog_reset(self) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
This command resets the slow log, clearing all entries in it. Read more
source§impl<'a> SetCommands<'a> for &'a mut Transaction
impl<'a> SetCommands<'a> for &'a mut Transaction
source§fn sadd<K, M, C>(self, key: K, members: C) -> PreparedCommand<'a, Self, usize>
fn sadd<K, M, C>(self, key: K, members: C) -> PreparedCommand<'a, Self, usize>
Add the specified members to the set stored at key. Read more
source§fn scard<K>(self, key: K) -> PreparedCommand<'a, Self, usize>
fn scard<K>(self, key: K) -> PreparedCommand<'a, Self, usize>
Returns the set cardinality (number of elements) of the set stored at key. Read more
source§fn sdiff<K, M, C, A>(self, keys: C) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
C: SingleArgCollection<K>,
A: CollectionResponse<M> + DeserializeOwned,
fn sdiff<K, M, C, A>(self, keys: C) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
C: SingleArgCollection<K>,
A: CollectionResponse<M> + DeserializeOwned,
Returns the members of the set resulting from the difference
between the first set and all the successive sets. Read more
source§fn sdiffstore<D, K, C>(
self,
destination: D,
keys: C
) -> PreparedCommand<'a, Self, usize>
fn sdiffstore<D, K, C>( self, destination: D, keys: C ) -> PreparedCommand<'a, Self, usize>
source§fn sinter<K, M, C, A>(self, keys: C) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
C: SingleArgCollection<K>,
A: CollectionResponse<M> + DeserializeOwned,
fn sinter<K, M, C, A>(self, keys: C) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
C: SingleArgCollection<K>,
A: CollectionResponse<M> + DeserializeOwned,
Returns the members of the set resulting from the intersection of all the given sets. Read more
source§fn sintercard<K, C>(
self,
keys: C,
limit: usize
) -> PreparedCommand<'a, Self, usize>
fn sintercard<K, C>( self, keys: C, limit: usize ) -> PreparedCommand<'a, Self, usize>
source§fn sinterstore<D, K, C>(
self,
destination: D,
keys: C
) -> PreparedCommand<'a, Self, usize>
fn sinterstore<D, K, C>( self, destination: D, keys: C ) -> PreparedCommand<'a, Self, usize>
source§fn sismember<K, M>(self, key: K, member: M) -> PreparedCommand<'a, Self, bool>
fn sismember<K, M>(self, key: K, member: M) -> PreparedCommand<'a, Self, bool>
Returns if member is a member of the set stored at key. Read more
source§fn smembers<K, M, A>(self, key: K) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
A: CollectionResponse<M> + DeserializeOwned,
fn smembers<K, M, A>(self, key: K) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
A: CollectionResponse<M> + DeserializeOwned,
Returns all the members of the set value stored at key. Read more
source§fn smismember<K, M, C>(
self,
key: K,
members: C
) -> PreparedCommand<'a, Self, Vec<bool>>
fn smismember<K, M, C>( self, key: K, members: C ) -> PreparedCommand<'a, Self, Vec<bool>>
Returns whether each member is a member of the set stored at key. Read more
source§fn smove<S, D, M>(
self,
source: S,
destination: D,
member: M
) -> PreparedCommand<'a, Self, bool>
fn smove<S, D, M>( self, source: S, destination: D, member: M ) -> PreparedCommand<'a, Self, bool>
Move member from the set at source to the set at destination. Read more
source§fn spop<K, M, A>(self, key: K, count: usize) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
A: CollectionResponse<M> + DeserializeOwned,
fn spop<K, M, A>(self, key: K, count: usize) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
A: CollectionResponse<M> + DeserializeOwned,
Removes and returns one or more random members from the set value store at key. Read more
source§fn srandmember<K, M, A>(
self,
key: K,
count: usize
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
A: CollectionResponse<M> + DeserializeOwned,
fn srandmember<K, M, A>(
self,
key: K,
count: usize
) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
A: CollectionResponse<M> + DeserializeOwned,
Removes and returns one or more random members from the set value store at key. Read more
source§fn srem<K, M, C>(self, key: K, members: C) -> PreparedCommand<'a, Self, usize>
fn srem<K, M, C>(self, key: K, members: C) -> PreparedCommand<'a, Self, usize>
Remove the specified members from the set stored at key. Read more
source§fn sscan<K, M>(
self,
key: K,
cursor: u64,
options: SScanOptions
) -> PreparedCommand<'a, Self, (u64, Vec<M>)>
fn sscan<K, M>( self, key: K, cursor: u64, options: SScanOptions ) -> PreparedCommand<'a, Self, (u64, Vec<M>)>
Iterates elements of Sets types. Read more
source§fn sunion<K, M, C, A>(self, keys: C) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
C: SingleArgCollection<K>,
A: CollectionResponse<M> + DeserializeOwned,
fn sunion<K, M, C, A>(self, keys: C) -> PreparedCommand<'a, Self, A>where
Self: Sized,
K: SingleArg,
M: PrimitiveResponse + Eq + Hash + DeserializeOwned,
C: SingleArgCollection<K>,
A: CollectionResponse<M> + DeserializeOwned,
Returns the members of the set resulting from the union of all the given sets. Read more
source§fn sunionstore<D, K, C>(
self,
destination: D,
keys: C
) -> PreparedCommand<'a, Self, usize>
fn sunionstore<D, K, C>( self, destination: D, keys: C ) -> PreparedCommand<'a, Self, usize>
source§impl<'a> SortedSetCommands<'a> for &'a mut Transaction
impl<'a> SortedSetCommands<'a> for &'a mut Transaction
source§fn zadd<K, M, I>(
self,
key: K,
items: I,
options: ZAddOptions
) -> PreparedCommand<'a, Self, usize>
fn zadd<K, M, I>( self, key: K, items: I, options: ZAddOptions ) -> PreparedCommand<'a, Self, usize>
Adds all the specified members with the specified scores
to the sorted set stored at key. Read more
source§fn zadd_incr<K, M>(
self,
key: K,
condition: ZAddCondition,
comparison: ZAddComparison,
change: bool,
score: f64,
member: M
) -> PreparedCommand<'a, Self, Option<f64>>
fn zadd_incr<K, M>( self, key: K, condition: ZAddCondition, comparison: ZAddComparison, change: bool, score: f64, member: M ) -> PreparedCommand<'a, Self, Option<f64>>
In this mode ZADD acts like ZINCRBY.
Only one score-element pair can be specified in this mode. Read more
source§fn zcard<K>(self, key: K) -> PreparedCommand<'a, Self, usize>
fn zcard<K>(self, key: K) -> PreparedCommand<'a, Self, usize>
Returns the sorted set cardinality (number of elements)
of the sorted set stored at key. Read more
source§fn zcount<K, M1, M2>(
self,
key: K,
min: M1,
max: M2
) -> PreparedCommand<'a, Self, usize>
fn zcount<K, M1, M2>( self, key: K, min: M1, max: M2 ) -> PreparedCommand<'a, Self, usize>
Returns the number of elements in the sorted set at key with a score between min and max. Read more
source§fn zdiff<K, C, E>(self, keys: C) -> PreparedCommand<'a, Self, Vec<E>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
E: PrimitiveResponse + DeserializeOwned,
fn zdiff<K, C, E>(self, keys: C) -> PreparedCommand<'a, Self, Vec<E>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
E: PrimitiveResponse + DeserializeOwned,
This command is similar to zdiffstore, but instead of storing the resulting sorted set,
it is returned to the client. Read more
source§fn zdiff_with_scores<K, C, E>(
self,
keys: C
) -> PreparedCommand<'a, Self, Vec<(E, f64)>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
E: PrimitiveResponse + DeserializeOwned,
fn zdiff_with_scores<K, C, E>(
self,
keys: C
) -> PreparedCommand<'a, Self, Vec<(E, f64)>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
E: PrimitiveResponse + DeserializeOwned,
This command is similar to zdiffstore, but instead of storing the resulting sorted set,
it is returned to the client. Read more
source§fn zdiffstore<D, K, C>(
self,
destination: D,
keys: C
) -> PreparedCommand<'a, Self, usize>
fn zdiffstore<D, K, C>( self, destination: D, keys: C ) -> PreparedCommand<'a, Self, usize>
Computes the difference between the first and all successive
input sorted sets and stores the result in destination. Read more
source§fn zincrby<K, M>(
self,
key: K,
increment: f64,
member: M
) -> PreparedCommand<'a, Self, f64>
fn zincrby<K, M>( self, key: K, increment: f64, member: M ) -> PreparedCommand<'a, Self, f64>
Increments the score of member in the sorted set stored at key by increment. Read more
source§fn zinter<K, C, W, E>(
self,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, Vec<E>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
E: PrimitiveResponse + DeserializeOwned,
fn zinter<K, C, W, E>(
self,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, Vec<E>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
E: PrimitiveResponse + DeserializeOwned,
This command is similar to zinterstore,
but instead of storing the resulting sorted set, it is returned to the client. Read more
source§fn zinter_with_scores<K, C, W, E>(
self,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, Vec<(E, f64)>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
E: PrimitiveResponse + DeserializeOwned,
fn zinter_with_scores<K, C, W, E>(
self,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, Vec<(E, f64)>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
E: PrimitiveResponse + DeserializeOwned,
This command is similar to zinterstore,
but instead of storing the resulting sorted set, it is returned to the client. Read more
source§fn zintercard<K, C>(
self,
keys: C,
limit: usize
) -> PreparedCommand<'a, Self, usize>
fn zintercard<K, C>( self, keys: C, limit: usize ) -> PreparedCommand<'a, Self, usize>
source§fn zinterstore<D, K, C, W>(
self,
destination: D,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
D: SingleArg,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
fn zinterstore<D, K, C, W>(
self,
destination: D,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
D: SingleArg,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
Computes the intersection of numkeys sorted sets given by the specified keys,
and stores the result in destination. Read more
source§fn zlexcount<K, M1, M2>(
self,
key: K,
min: M1,
max: M2
) -> PreparedCommand<'a, Self, usize>
fn zlexcount<K, M1, M2>( self, key: K, min: M1, max: M2 ) -> PreparedCommand<'a, Self, usize>
When all the elements in a sorted set are inserted with the same score,
in order to force lexicographical ordering, this command returns the number
of elements in the sorted set at key with a value between min and max. Read more
source§fn zmpop<K, C, E>(
self,
keys: C,
where_: ZWhere,
count: usize
) -> PreparedCommand<'a, Self, Option<ZMPopResult<E>>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
E: PrimitiveResponse + DeserializeOwned,
fn zmpop<K, C, E>(
self,
keys: C,
where_: ZWhere,
count: usize
) -> PreparedCommand<'a, Self, Option<ZMPopResult<E>>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
E: PrimitiveResponse + DeserializeOwned,
Pops one or more elements, that are member-score pairs,
from the first non-empty sorted set in the provided list of key names. Read more
source§fn zmscore<K, M, C>(
self,
key: K,
members: C
) -> PreparedCommand<'a, Self, Vec<Option<f64>>>
fn zmscore<K, M, C>( self, key: K, members: C ) -> PreparedCommand<'a, Self, Vec<Option<f64>>>
Returns the scores associated with the specified members in the sorted set stored at key. Read more
source§fn zpopmax<K, M>(
self,
key: K,
count: usize
) -> PreparedCommand<'a, Self, Vec<(M, f64)>>
fn zpopmax<K, M>( self, key: K, count: usize ) -> PreparedCommand<'a, Self, Vec<(M, f64)>>
Removes and returns up to count members with the highest scores in the sorted set stored at key. Read more
source§fn zpopmin<K, M>(
self,
key: K,
count: usize
) -> PreparedCommand<'a, Self, Vec<(M, f64)>>
fn zpopmin<K, M>( self, key: K, count: usize ) -> PreparedCommand<'a, Self, Vec<(M, f64)>>
Removes and returns up to count members with the lowest scores in the sorted set stored at key. Read more
source§fn zrandmember<K, E>(self, key: K) -> PreparedCommand<'a, Self, E>
fn zrandmember<K, E>(self, key: K) -> PreparedCommand<'a, Self, E>
Return a random element from the sorted set value stored at key. Read more
source§fn zrandmembers<K, E>(
self,
key: K,
count: isize
) -> PreparedCommand<'a, Self, Vec<E>>
fn zrandmembers<K, E>( self, key: K, count: isize ) -> PreparedCommand<'a, Self, Vec<E>>
Return random elements from the sorted set value stored at key. Read more
source§fn zrandmembers_with_scores<K, E>(
self,
key: K,
count: isize
) -> PreparedCommand<'a, Self, Vec<E>>
fn zrandmembers_with_scores<K, E>( self, key: K, count: isize ) -> PreparedCommand<'a, Self, Vec<E>>
Return random elements with their scores from the sorted set value stored at key. Read more
source§fn zrange<K, S, E>(
self,
key: K,
start: S,
stop: S,
options: ZRangeOptions
) -> PreparedCommand<'a, Self, Vec<E>>
fn zrange<K, S, E>( self, key: K, start: S, stop: S, options: ZRangeOptions ) -> PreparedCommand<'a, Self, Vec<E>>
Returns the specified range of elements in the sorted set stored at
key
. Read moresource§fn zrange_with_scores<K, S, E>(
self,
key: K,
start: S,
stop: S,
options: ZRangeOptions
) -> PreparedCommand<'a, Self, Vec<(E, f64)>>
fn zrange_with_scores<K, S, E>( self, key: K, start: S, stop: S, options: ZRangeOptions ) -> PreparedCommand<'a, Self, Vec<(E, f64)>>
Returns the specified range of elements in the sorted set stored at
key
. Read moresource§fn zrangestore<D, S, SS>(
self,
dst: D,
src: S,
start: SS,
stop: SS,
options: ZRangeOptions
) -> PreparedCommand<'a, Self, usize>
fn zrangestore<D, S, SS>( self, dst: D, src: S, start: SS, stop: SS, options: ZRangeOptions ) -> PreparedCommand<'a, Self, usize>
source§fn zrank<K, M>(
self,
key: K,
member: M
) -> PreparedCommand<'a, Self, Option<usize>>
fn zrank<K, M>( self, key: K, member: M ) -> PreparedCommand<'a, Self, Option<usize>>
Returns the rank of member in the sorted set stored at key,
with the scores ordered from low to high. Read more
source§fn zrem<K, M, C>(self, key: K, members: C) -> PreparedCommand<'a, Self, usize>
fn zrem<K, M, C>(self, key: K, members: C) -> PreparedCommand<'a, Self, usize>
Removes the specified members from the sorted set stored at key. Read more
source§fn zremrangebylex<K, S>(
self,
key: K,
start: S,
stop: S
) -> PreparedCommand<'a, Self, usize>
fn zremrangebylex<K, S>( self, key: K, start: S, stop: S ) -> PreparedCommand<'a, Self, usize>
When all the elements in a sorted set are inserted with the same score,
in order to force lexicographical ordering,
this command removes all elements in the sorted set stored at key
between the lexicographical range specified by min and max. Read more
source§fn zremrangebyrank<K>(
self,
key: K,
start: isize,
stop: isize
) -> PreparedCommand<'a, Self, usize>
fn zremrangebyrank<K>( self, key: K, start: isize, stop: isize ) -> PreparedCommand<'a, Self, usize>
Removes all elements in the sorted set stored at key with rank between start and stop. Read more
source§fn zremrangebyscore<K, S>(
self,
key: K,
start: S,
stop: S
) -> PreparedCommand<'a, Self, usize>
fn zremrangebyscore<K, S>( self, key: K, start: S, stop: S ) -> PreparedCommand<'a, Self, usize>
Removes all elements in the sorted set stored at key with a score between min and max (inclusive). Read more
source§fn zrevrank<K, M>(
self,
key: K,
member: M
) -> PreparedCommand<'a, Self, Option<usize>>
fn zrevrank<K, M>( self, key: K, member: M ) -> PreparedCommand<'a, Self, Option<usize>>
Returns the rank of member in the sorted set stored at key, with the scores ordered from high to low. Read more
source§fn zscan<K, M>(
self,
key: K,
cursor: usize,
options: ZScanOptions
) -> PreparedCommand<'a, Self, ZScanResult<M>>
fn zscan<K, M>( self, key: K, cursor: usize, options: ZScanOptions ) -> PreparedCommand<'a, Self, ZScanResult<M>>
Iterates elements of Sorted Set types and their associated scores. Read more
source§fn zscore<K, M>(
self,
key: K,
member: M
) -> PreparedCommand<'a, Self, Option<f64>>
fn zscore<K, M>( self, key: K, member: M ) -> PreparedCommand<'a, Self, Option<f64>>
Returns the score of member in the sorted set at key. Read more
source§fn zunion<K, C, W, E>(
self,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, Vec<E>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
E: PrimitiveResponse + DeserializeOwned,
fn zunion<K, C, W, E>(
self,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, Vec<E>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
E: PrimitiveResponse + DeserializeOwned,
This command is similar to zunionstore,
but instead of storing the resulting sorted set, it is returned to the client. Read more
source§fn zunion_with_scores<K, C, W, E>(
self,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, Vec<(E, f64)>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
E: PrimitiveResponse + DeserializeOwned,
fn zunion_with_scores<K, C, W, E>(
self,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, Vec<(E, f64)>>where
Self: Sized,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
E: PrimitiveResponse + DeserializeOwned,
This command is similar to zunionstore,
but instead of storing the resulting sorted set, it is returned to the client. Read more
source§fn zunionstore<D, K, C, W>(
self,
destination: D,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
D: SingleArg,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
fn zunionstore<D, K, C, W>(
self,
destination: D,
keys: C,
weights: Option<W>,
aggregate: ZAggregate
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
D: SingleArg,
K: SingleArg,
C: SingleArgCollection<K>,
W: SingleArgCollection<f64>,
Computes the unionsection of numkeys sorted sets given by the specified keys,
and stores the result in destination. Read more
source§impl<'a> StreamCommands<'a> for &'a mut Transaction
impl<'a> StreamCommands<'a> for &'a mut Transaction
source§fn xack<K, G, I, II>(
self,
key: K,
group: G,
ids: II
) -> PreparedCommand<'a, Self, usize>
fn xack<K, G, I, II>( self, key: K, group: G, ids: II ) -> PreparedCommand<'a, Self, usize>
The XACK command removes one or multiple messages
from the Pending Entries List (PEL) of a stream consumer group Read more
source§fn xadd<K, I, F, V, FFVV, R>(
self,
key: K,
stream_id: I,
items: FFVV,
options: XAddOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
K: SingleArg,
I: SingleArg,
F: SingleArg,
V: SingleArg,
FFVV: KeyValueArgsCollection<F, V>,
R: PrimitiveResponse,
fn xadd<K, I, F, V, FFVV, R>(
self,
key: K,
stream_id: I,
items: FFVV,
options: XAddOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
K: SingleArg,
I: SingleArg,
F: SingleArg,
V: SingleArg,
FFVV: KeyValueArgsCollection<F, V>,
R: PrimitiveResponse,
Appends the specified stream entry to the stream at the specified key. Read more
source§fn xautoclaim<K, G, C, I, V>(
self,
key: K,
group: G,
consumer: C,
min_idle_time: u64,
start: I,
options: XAutoClaimOptions
) -> PreparedCommand<'a, Self, XAutoClaimResult<V>>where
Self: Sized,
K: SingleArg,
G: SingleArg,
C: SingleArg,
I: SingleArg,
V: PrimitiveResponse + DeserializeOwned,
fn xautoclaim<K, G, C, I, V>(
self,
key: K,
group: G,
consumer: C,
min_idle_time: u64,
start: I,
options: XAutoClaimOptions
) -> PreparedCommand<'a, Self, XAutoClaimResult<V>>where
Self: Sized,
K: SingleArg,
G: SingleArg,
C: SingleArg,
I: SingleArg,
V: PrimitiveResponse + DeserializeOwned,
This command transfers ownership of pending stream entries that match the specified criteria. Read more
source§fn xclaim<K, G, C, I, II, V>(
self,
key: K,
group: G,
consumer: C,
min_idle_time: u64,
ids: II,
options: XClaimOptions
) -> PreparedCommand<'a, Self, Vec<StreamEntry<V>>>where
Self: Sized,
K: SingleArg,
G: SingleArg,
C: SingleArg,
I: SingleArg,
II: SingleArgCollection<I>,
V: PrimitiveResponse + DeserializeOwned,
fn xclaim<K, G, C, I, II, V>(
self,
key: K,
group: G,
consumer: C,
min_idle_time: u64,
ids: II,
options: XClaimOptions
) -> PreparedCommand<'a, Self, Vec<StreamEntry<V>>>where
Self: Sized,
K: SingleArg,
G: SingleArg,
C: SingleArg,
I: SingleArg,
II: SingleArgCollection<I>,
V: PrimitiveResponse + DeserializeOwned,
In the context of a stream consumer group, this command changes the ownership of a pending message,
so that the new owner is the consumer specified as the command argument. Read more
source§fn xdel<K, I, II>(self, key: K, ids: II) -> PreparedCommand<'a, Self, usize>
fn xdel<K, I, II>(self, key: K, ids: II) -> PreparedCommand<'a, Self, usize>
Removes the specified entries from a stream, and returns the number of entries deleted. Read more
source§fn xgroup_create<K, G, I>(
self,
key: K,
groupname: G,
id: I,
options: XGroupCreateOptions
) -> PreparedCommand<'a, Self, bool>
fn xgroup_create<K, G, I>( self, key: K, groupname: G, id: I, options: XGroupCreateOptions ) -> PreparedCommand<'a, Self, bool>
This command creates a new consumer group uniquely identified by
groupname
for the stream stored at key
. Read moresource§fn xgroup_createconsumer<K, G, C>(
self,
key: K,
groupname: G,
consumername: C
) -> PreparedCommand<'a, Self, bool>
fn xgroup_createconsumer<K, G, C>( self, key: K, groupname: G, consumername: C ) -> PreparedCommand<'a, Self, bool>
Create a consumer named
consumername
in the consumer group groupname`` of the stream that's stored at
key. Read moresource§fn xgroup_delconsumer<K, G, C>(
self,
key: K,
groupname: G,
consumername: C
) -> PreparedCommand<'a, Self, usize>
fn xgroup_delconsumer<K, G, C>( self, key: K, groupname: G, consumername: C ) -> PreparedCommand<'a, Self, usize>
The XGROUP DELCONSUMER command deletes a consumer from the consumer group. Read more
source§fn xgroup_destroy<K, G>(
self,
key: K,
groupname: G
) -> PreparedCommand<'a, Self, bool>
fn xgroup_destroy<K, G>( self, key: K, groupname: G ) -> PreparedCommand<'a, Self, bool>
The XGROUP DESTROY command completely destroys a consumer group. Read more
source§fn xgroup_setid<K, G, I>(
self,
key: K,
groupname: G,
id: I,
entries_read: Option<usize>
) -> PreparedCommand<'a, Self, ()>
fn xgroup_setid<K, G, I>( self, key: K, groupname: G, id: I, entries_read: Option<usize> ) -> PreparedCommand<'a, Self, ()>
Set the last delivered ID for a consumer group. Read more
source§fn xinfo_consumers<K, G>(
self,
key: K,
groupname: G
) -> PreparedCommand<'a, Self, Vec<XConsumerInfo>>
fn xinfo_consumers<K, G>( self, key: K, groupname: G ) -> PreparedCommand<'a, Self, Vec<XConsumerInfo>>
This command returns the list of consumers that belong to the
groupname
consumer group of the stream stored at key
. Read moresource§fn xinfo_groups<K>(self, key: K) -> PreparedCommand<'a, Self, Vec<XGroupInfo>>
fn xinfo_groups<K>(self, key: K) -> PreparedCommand<'a, Self, Vec<XGroupInfo>>
This command returns the list of consumers that belong
to the
groupname
consumer group of the stream stored at key
. Read moresource§fn xinfo_stream<K>(
self,
key: K,
options: XInfoStreamOptions
) -> PreparedCommand<'a, Self, XStreamInfo>
fn xinfo_stream<K>( self, key: K, options: XInfoStreamOptions ) -> PreparedCommand<'a, Self, XStreamInfo>
This command returns information about the stream stored at
key
. Read moresource§fn xlen<K>(self, key: K) -> PreparedCommand<'a, Self, usize>
fn xlen<K>(self, key: K) -> PreparedCommand<'a, Self, usize>
Returns the number of entries inside a stream. Read more
source§fn xpending<K, G>(
self,
key: K,
group: G
) -> PreparedCommand<'a, Self, XPendingResult>
fn xpending<K, G>( self, key: K, group: G ) -> PreparedCommand<'a, Self, XPendingResult>
The XPENDING command is the interface to inspect the list of pending messages. Read more
source§fn xpending_with_options<K, G>(
self,
key: K,
group: G,
options: XPendingOptions
) -> PreparedCommand<'a, Self, Vec<XPendingMessageResult>>
fn xpending_with_options<K, G>( self, key: K, group: G, options: XPendingOptions ) -> PreparedCommand<'a, Self, Vec<XPendingMessageResult>>
The XPENDING command is the interface to inspect the list of pending messages. Read more
source§fn xrange<K, S, E, V>(
self,
key: K,
start: S,
end: E,
count: Option<usize>
) -> PreparedCommand<'a, Self, Vec<StreamEntry<V>>>where
Self: Sized,
K: SingleArg,
S: SingleArg,
E: SingleArg,
V: PrimitiveResponse + DeserializeOwned,
fn xrange<K, S, E, V>(
self,
key: K,
start: S,
end: E,
count: Option<usize>
) -> PreparedCommand<'a, Self, Vec<StreamEntry<V>>>where
Self: Sized,
K: SingleArg,
S: SingleArg,
E: SingleArg,
V: PrimitiveResponse + DeserializeOwned,
The command returns the stream entries matching a given range of IDs. Read more
source§fn xread<K, KK, I, II, V, R>(
self,
options: XReadOptions,
keys: KK,
ids: II
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
K: SingleArg,
KK: SingleArgCollection<K>,
I: SingleArg,
II: SingleArgCollection<I>,
V: PrimitiveResponse + DeserializeOwned,
R: KeyValueCollectionResponse<String, Vec<StreamEntry<V>>>,
fn xread<K, KK, I, II, V, R>(
self,
options: XReadOptions,
keys: KK,
ids: II
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
K: SingleArg,
KK: SingleArgCollection<K>,
I: SingleArg,
II: SingleArgCollection<I>,
V: PrimitiveResponse + DeserializeOwned,
R: KeyValueCollectionResponse<String, Vec<StreamEntry<V>>>,
Read data from one or multiple streams,
only returning entries with an ID greater than the last received ID reported by the caller. Read more
source§fn xreadgroup<G, C, K, KK, I, II, V, R>(
self,
group: G,
consumer: C,
options: XReadGroupOptions,
keys: KK,
ids: II
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
G: SingleArg,
C: SingleArg,
K: SingleArg,
KK: SingleArgCollection<K>,
I: SingleArg,
II: SingleArgCollection<I>,
V: PrimitiveResponse + DeserializeOwned,
R: KeyValueCollectionResponse<String, Vec<StreamEntry<V>>>,
fn xreadgroup<G, C, K, KK, I, II, V, R>(
self,
group: G,
consumer: C,
options: XReadGroupOptions,
keys: KK,
ids: II
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
G: SingleArg,
C: SingleArg,
K: SingleArg,
KK: SingleArgCollection<K>,
I: SingleArg,
II: SingleArgCollection<I>,
V: PrimitiveResponse + DeserializeOwned,
R: KeyValueCollectionResponse<String, Vec<StreamEntry<V>>>,
source§fn xrevrange<K, E, S, V>(
self,
key: K,
end: E,
start: S,
count: Option<usize>
) -> PreparedCommand<'a, Self, Vec<StreamEntry<V>>>where
Self: Sized,
K: SingleArg,
E: SingleArg,
S: SingleArg,
V: PrimitiveResponse + DeserializeOwned,
fn xrevrange<K, E, S, V>(
self,
key: K,
end: E,
start: S,
count: Option<usize>
) -> PreparedCommand<'a, Self, Vec<StreamEntry<V>>>where
Self: Sized,
K: SingleArg,
E: SingleArg,
S: SingleArg,
V: PrimitiveResponse + DeserializeOwned,
source§fn xtrim<K>(
self,
key: K,
options: XTrimOptions
) -> PreparedCommand<'a, Self, usize>
fn xtrim<K>( self, key: K, options: XTrimOptions ) -> PreparedCommand<'a, Self, usize>
XTRIM trims the stream by evicting older entries (entries with lower IDs) if needed. Read more
source§impl<'a> StringCommands<'a> for &'a mut Transaction
impl<'a> StringCommands<'a> for &'a mut Transaction
source§fn append<K, V>(self, key: K, value: V) -> PreparedCommand<'a, Self, usize>
fn append<K, V>(self, key: K, value: V) -> PreparedCommand<'a, Self, usize>
If key already exists and is a string,
this command appends the value at the end of the string.
If key does not exist it is created and set as an empty string,
so APPEND will be similar to SET in this special case. Read more
source§fn decr<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
fn decr<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
Decrements the number stored at key by one. Read more
source§fn decrby<K>(self, key: K, decrement: i64) -> PreparedCommand<'a, Self, i64>
fn decrby<K>(self, key: K, decrement: i64) -> PreparedCommand<'a, Self, i64>
Decrements the number stored at key by one. Read more
source§fn get<K, V>(self, key: K) -> PreparedCommand<'a, Self, V>
fn get<K, V>(self, key: K) -> PreparedCommand<'a, Self, V>
Get the value of key. Read more
source§fn getdel<K, V>(self, key: K) -> PreparedCommand<'a, Self, V>
fn getdel<K, V>(self, key: K) -> PreparedCommand<'a, Self, V>
Get the value of key and delete the key. Read more
source§fn getex<K, V>(
self,
key: K,
options: GetExOptions
) -> PreparedCommand<'a, Self, V>
fn getex<K, V>( self, key: K, options: GetExOptions ) -> PreparedCommand<'a, Self, V>
Get the value of key and optionally set its expiration. GETEX is similar to GET, but is a write command with additional options. Read more
source§fn getrange<K, V>(
self,
key: K,
start: usize,
end: isize
) -> PreparedCommand<'a, Self, V>
fn getrange<K, V>( self, key: K, start: usize, end: isize ) -> PreparedCommand<'a, Self, V>
Returns the substring of the string value stored at key, determined by the offsets start and end (both are inclusive). Read more
source§fn getset<K, V, R>(self, key: K, value: V) -> PreparedCommand<'a, Self, R>
fn getset<K, V, R>(self, key: K, value: V) -> PreparedCommand<'a, Self, R>
Atomically sets key to value and returns the old value stored at key.
Returns an error when key exists but does not hold a string value.
Any previous time to live associated with the key is discarded on successful SET operation. Read more
source§fn incr<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
fn incr<K>(self, key: K) -> PreparedCommand<'a, Self, i64>
Increments the number stored at key by one. Read more
source§fn incrby<K>(self, key: K, increment: i64) -> PreparedCommand<'a, Self, i64>
fn incrby<K>(self, key: K, increment: i64) -> PreparedCommand<'a, Self, i64>
Increments the number stored at key by increment. Read more
source§fn incrbyfloat<K>(
self,
key: K,
increment: f64
) -> PreparedCommand<'a, Self, f64>
fn incrbyfloat<K>( self, key: K, increment: f64 ) -> PreparedCommand<'a, Self, f64>
Increment the string representing a floating point number stored at key by the specified increment.
By using a negative increment value, the result is that the value stored at the key is decremented (by the obvious properties of addition).
If the key does not exist, it is set to 0 before performing the operation.
An error is returned if one of the following conditions occur: Read more
source§fn lcs<K, V>(self, key1: K, key2: K) -> PreparedCommand<'a, Self, V>
fn lcs<K, V>(self, key1: K, key2: K) -> PreparedCommand<'a, Self, V>
The LCS command implements the longest common subsequence algorithm Read more
source§fn lcs_len<K>(self, key1: K, key2: K) -> PreparedCommand<'a, Self, usize>
fn lcs_len<K>(self, key1: K, key2: K) -> PreparedCommand<'a, Self, usize>
The LCS command implements the longest common subsequence algorithm Read more
source§fn lcs_idx<K>(
self,
key1: K,
key2: K,
min_match_len: Option<usize>,
with_match_len: bool
) -> PreparedCommand<'a, Self, LcsResult>
fn lcs_idx<K>( self, key1: K, key2: K, min_match_len: Option<usize>, with_match_len: bool ) -> PreparedCommand<'a, Self, LcsResult>
The LCS command implements the longest common subsequence algorithm Read more
source§fn mget<K, KK, V, VV>(self, keys: KK) -> PreparedCommand<'a, Self, VV>where
Self: Sized,
K: SingleArg,
KK: SingleArgCollection<K>,
V: PrimitiveResponse + DeserializeOwned,
VV: CollectionResponse<V>,
fn mget<K, KK, V, VV>(self, keys: KK) -> PreparedCommand<'a, Self, VV>where
Self: Sized,
K: SingleArg,
KK: SingleArgCollection<K>,
V: PrimitiveResponse + DeserializeOwned,
VV: CollectionResponse<V>,
Returns the values of all specified keys. Read more
source§fn mset<K, V, C>(self, items: C) -> PreparedCommand<'a, Self, ()>
fn mset<K, V, C>(self, items: C) -> PreparedCommand<'a, Self, ()>
Sets the given keys to their respective values. Read more
source§fn msetnx<K, V, C>(self, items: C) -> PreparedCommand<'a, Self, bool>
fn msetnx<K, V, C>(self, items: C) -> PreparedCommand<'a, Self, bool>
Sets the given keys to their respective values.
MSETNX will not perform any operation at all even if just a single key already exists. Read more
source§fn psetex<K, V>(
self,
key: K,
milliseconds: u64,
value: V
) -> PreparedCommand<'a, Self, ()>
fn psetex<K, V>( self, key: K, milliseconds: u64, value: V ) -> PreparedCommand<'a, Self, ()>
source§fn set<K, V>(self, key: K, value: V) -> PreparedCommand<'a, Self, ()>
fn set<K, V>(self, key: K, value: V) -> PreparedCommand<'a, Self, ()>
Set key to hold the string value. Read more
source§fn set_with_options<K, V>(
self,
key: K,
value: V,
condition: SetCondition,
expiration: SetExpiration,
keep_ttl: bool
) -> PreparedCommand<'a, Self, bool>
fn set_with_options<K, V>( self, key: K, value: V, condition: SetCondition, expiration: SetExpiration, keep_ttl: bool ) -> PreparedCommand<'a, Self, bool>
Set key to hold the string value. Read more
source§fn set_get_with_options<K, V1, V2>(
self,
key: K,
value: V1,
condition: SetCondition,
expiration: SetExpiration,
keep_ttl: bool
) -> PreparedCommand<'a, Self, V2>
fn set_get_with_options<K, V1, V2>( self, key: K, value: V1, condition: SetCondition, expiration: SetExpiration, keep_ttl: bool ) -> PreparedCommand<'a, Self, V2>
Set key to hold the string value wit GET option enforced Read more
source§fn setex<K, V>(
self,
key: K,
seconds: u64,
value: V
) -> PreparedCommand<'a, Self, ()>
fn setex<K, V>( self, key: K, seconds: u64, value: V ) -> PreparedCommand<'a, Self, ()>
Set key to hold the string value and set key to timeout after a given number of seconds. Read more
source§fn setnx<K, V>(self, key: K, value: V) -> PreparedCommand<'a, Self, bool>
fn setnx<K, V>(self, key: K, value: V) -> PreparedCommand<'a, Self, bool>
Set key to hold string value if key does not exist. Read more
source§impl<'a> TDigestCommands<'a> for &'a mut Transaction
Available on crate feature redis-bloom
only.
impl<'a> TDigestCommands<'a> for &'a mut Transaction
Available on crate feature
redis-bloom
only.source§fn tdigest_add(
self,
key: impl SingleArg,
values: impl SingleArgCollection<f64>
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn tdigest_add(
self,
key: impl SingleArg,
values: impl SingleArgCollection<f64>
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Adds one or more observations to a t-digest sketch. Read more
source§fn tdigest_byrank<R: CollectionResponse<f64>>(
self,
key: impl SingleArg,
ranks: impl SingleArgCollection<usize>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn tdigest_byrank<R: CollectionResponse<f64>>(
self,
key: impl SingleArg,
ranks: impl SingleArgCollection<usize>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Returns, for each input rank, an estimation of the value (floating-point) with that rank. Read more
source§fn tdigest_byrevrank<R: CollectionResponse<f64>>(
self,
key: impl SingleArg,
ranks: impl SingleArgCollection<usize>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn tdigest_byrevrank<R: CollectionResponse<f64>>(
self,
key: impl SingleArg,
ranks: impl SingleArgCollection<usize>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Returns, for each input reverse rank, an estimation of the value (floating-point) with that reverse rank. Read more
source§fn tdigest_cdf<V: SingleArg, R: CollectionResponse<f64>>(
self,
key: impl SingleArg,
values: impl SingleArgCollection<V>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn tdigest_cdf<V: SingleArg, R: CollectionResponse<f64>>(
self,
key: impl SingleArg,
values: impl SingleArgCollection<V>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Returns, for each input reverse rank, an estimation of the value (floating-point) with that reverse rank. Read more
source§fn tdigest_create(
self,
key: impl SingleArg,
compression: Option<i64>
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn tdigest_create(
self,
key: impl SingleArg,
compression: Option<i64>
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Allocates memory and initializes a new t-digest sketch. Read more
source§fn tdigest_info(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, TDigestInfoResult>where
Self: Sized,
fn tdigest_info(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, TDigestInfoResult>where
Self: Sized,
Returns information and statistics about a t-digest sketch Read more
source§fn tdigest_max(self, key: impl SingleArg) -> PreparedCommand<'a, Self, f64>where
Self: Sized,
fn tdigest_max(self, key: impl SingleArg) -> PreparedCommand<'a, Self, f64>where
Self: Sized,
Returns the maximum observation value from a t-digest sketch. Read more
source§fn tdigest_merge<S: SingleArg>(
self,
destination: impl SingleArg,
sources: impl SingleArgCollection<S>,
options: TDigestMergeOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn tdigest_merge<S: SingleArg>(
self,
destination: impl SingleArg,
sources: impl SingleArgCollection<S>,
options: TDigestMergeOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Merges multiple t-digest sketches into a single sketch. Read more
source§fn tdigest_min(self, key: impl SingleArg) -> PreparedCommand<'a, Self, f64>where
Self: Sized,
fn tdigest_min(self, key: impl SingleArg) -> PreparedCommand<'a, Self, f64>where
Self: Sized,
Returns the minimum observation value from a t-digest sketch. Read more
source§fn tdigest_quantile<Q: SingleArg, R: CollectionResponse<f64>>(
self,
key: impl SingleArg,
quantiles: impl SingleArgCollection<Q>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn tdigest_quantile<Q: SingleArg, R: CollectionResponse<f64>>(
self,
key: impl SingleArg,
quantiles: impl SingleArgCollection<Q>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Returns, for each input fraction, an estimation of the value
(floating point) that is smaller than the given fraction of observations. Read more
source§fn tdigest_rank<V: SingleArg, R: CollectionResponse<isize>>(
self,
key: impl SingleArg,
values: impl SingleArgCollection<V>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn tdigest_rank<V: SingleArg, R: CollectionResponse<isize>>(
self,
key: impl SingleArg,
values: impl SingleArgCollection<V>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Returns, for each input value (floating-point), the estimated rank of the value
(the number of observations in the sketch that are smaller than the value + half the number of observations that are equal to the value). Read more
source§fn tdigest_reset(self, key: impl SingleArg) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn tdigest_reset(self, key: impl SingleArg) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Resets a t-digest sketch: empty the sketch and re-initializes it. Read more
source§fn tdigest_revrank<V: SingleArg, R: CollectionResponse<isize>>(
self,
key: impl SingleArg,
values: impl SingleArgCollection<V>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn tdigest_revrank<V: SingleArg, R: CollectionResponse<isize>>(
self,
key: impl SingleArg,
values: impl SingleArgCollection<V>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Returns, for each input value (floating-point), the estimated reverse rank of the value
(the number of observations in the sketch that are smaller than the value + half the number of observations that are equal to the value). Read more
source§fn tdigest_trimmed_mean(
self,
key: impl SingleArg,
low_cut_quantile: f64,
high_cut_quantile: f64
) -> PreparedCommand<'a, Self, f64>where
Self: Sized,
fn tdigest_trimmed_mean(
self,
key: impl SingleArg,
low_cut_quantile: f64,
high_cut_quantile: f64
) -> PreparedCommand<'a, Self, f64>where
Self: Sized,
Returns an estimation of the mean value from the sketch, excluding observation values outside the low and high cutoff quantiles. Read more
source§impl<'a> TimeSeriesCommands<'a> for &'a mut Transaction
Available on crate feature redis-time-series
only.
impl<'a> TimeSeriesCommands<'a> for &'a mut Transaction
Available on crate feature
redis-time-series
only.source§fn ts_add(
self,
key: impl SingleArg,
timestamp: impl SingleArg,
value: f64,
options: TsAddOptions
) -> PreparedCommand<'a, Self, u64>where
Self: Sized,
fn ts_add(
self,
key: impl SingleArg,
timestamp: impl SingleArg,
value: f64,
options: TsAddOptions
) -> PreparedCommand<'a, Self, u64>where
Self: Sized,
Append a sample to a time series Read more
source§fn ts_alter(
self,
key: impl SingleArg,
options: TsCreateOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn ts_alter(
self,
key: impl SingleArg,
options: TsCreateOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Update the retention, chunk size, duplicate policy, and labels of an existing time series Read more
source§fn ts_create(
self,
key: impl SingleArg,
options: TsCreateOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn ts_create(
self,
key: impl SingleArg,
options: TsCreateOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Create a new time series Read more
source§fn ts_createrule(
self,
src_key: impl SingleArg,
dst_key: impl SingleArg,
aggregator: TsAggregationType,
bucket_duration: u64,
options: TsCreateRuleOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn ts_createrule(
self,
src_key: impl SingleArg,
dst_key: impl SingleArg,
aggregator: TsAggregationType,
bucket_duration: u64,
options: TsCreateRuleOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Create a compaction rule Read more
source§fn ts_decrby(
self,
key: impl SingleArg,
value: f64,
options: TsIncrByDecrByOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn ts_decrby(
self,
key: impl SingleArg,
value: f64,
options: TsIncrByDecrByOptions
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Decrease the value of the sample with the maximum existing timestamp,
or create a new sample with a value equal to the value of the sample with the maximum existing timestamp with a given decrement Read more
source§fn ts_del(
self,
key: impl SingleArg,
from_timestamp: u64,
to_timestamp: u64
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
fn ts_del(
self,
key: impl SingleArg,
from_timestamp: u64,
to_timestamp: u64
) -> PreparedCommand<'a, Self, usize>where
Self: Sized,
Delete all samples between two timestamps for a given time series Read more
source§fn ts_deleterule(
self,
src_key: impl SingleArg,
dst_key: impl SingleArg
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
fn ts_deleterule(
self,
src_key: impl SingleArg,
dst_key: impl SingleArg
) -> PreparedCommand<'a, Self, ()>where
Self: Sized,
Delete a compaction rule Read more
source§fn ts_get(
self,
key: impl SingleArg,
options: TsGetOptions
) -> PreparedCommand<'a, Self, Option<(u64, f64)>>where
Self: Sized,
fn ts_get(
self,
key: impl SingleArg,
options: TsGetOptions
) -> PreparedCommand<'a, Self, Option<(u64, f64)>>where
Self: Sized,
Get the last sample Read more
source§fn ts_incrby(
self,
key: impl SingleArg,
value: f64,
options: TsIncrByDecrByOptions
) -> PreparedCommand<'a, Self, u64>where
Self: Sized,
fn ts_incrby(
self,
key: impl SingleArg,
value: f64,
options: TsIncrByDecrByOptions
) -> PreparedCommand<'a, Self, u64>where
Self: Sized,
Increase the value of the sample with the maximum existing timestamp,
or create a new sample with a value equal to the value of the sample
with the maximum existing timestamp with a given increment Read more
source§fn ts_info(
self,
key: impl SingleArg,
debug: bool
) -> PreparedCommand<'a, Self, TsInfoResult>where
Self: Sized,
fn ts_info(
self,
key: impl SingleArg,
debug: bool
) -> PreparedCommand<'a, Self, TsInfoResult>where
Self: Sized,
Return information and statistics for a time series. Read more
source§fn ts_madd<K: SingleArg, T: SingleArg, R: CollectionResponse<u64>>(
self,
items: impl MultipleArgsCollection<(K, T, f64)>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn ts_madd<K: SingleArg, T: SingleArg, R: CollectionResponse<u64>>(
self,
items: impl MultipleArgsCollection<(K, T, f64)>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Append new samples to one or more time series Read more
source§fn ts_mget<F: SingleArg, R: CollectionResponse<TsSample>>(
self,
options: TsMGetOptions,
filters: impl SingleArgCollection<F>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn ts_mget<F: SingleArg, R: CollectionResponse<TsSample>>(
self,
options: TsMGetOptions,
filters: impl SingleArgCollection<F>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Get the last samples matching a specific filter Read more
source§fn ts_mrange<F: SingleArg, R: CollectionResponse<TsRangeSample>>(
self,
from_timestamp: impl SingleArg,
to_timestamp: impl SingleArg,
options: TsMRangeOptions,
filters: impl SingleArgCollection<F>,
groupby_options: TsGroupByOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn ts_mrange<F: SingleArg, R: CollectionResponse<TsRangeSample>>(
self,
from_timestamp: impl SingleArg,
to_timestamp: impl SingleArg,
options: TsMRangeOptions,
filters: impl SingleArgCollection<F>,
groupby_options: TsGroupByOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Query a range across multiple time series by filters in forward direction Read more
source§fn ts_mrevrange<F: SingleArg, R: CollectionResponse<TsRangeSample>>(
self,
from_timestamp: impl SingleArg,
to_timestamp: impl SingleArg,
options: TsMRangeOptions,
filters: impl SingleArgCollection<F>,
groupby_options: TsGroupByOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn ts_mrevrange<F: SingleArg, R: CollectionResponse<TsRangeSample>>(
self,
from_timestamp: impl SingleArg,
to_timestamp: impl SingleArg,
options: TsMRangeOptions,
filters: impl SingleArgCollection<F>,
groupby_options: TsGroupByOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Query a range across multiple time series by filters in reverse direction Read more
source§fn ts_queryindex<F: SingleArg, R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
filters: impl SingleArgCollection<F>
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
fn ts_queryindex<F: SingleArg, R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
filters: impl SingleArgCollection<F>
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
Get all time series keys matching a filter list Read more
source§fn ts_range<R: CollectionResponse<(u64, f64)>>(
self,
key: impl SingleArg,
from_timestamp: impl SingleArg,
to_timestamp: impl SingleArg,
options: TsRangeOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn ts_range<R: CollectionResponse<(u64, f64)>>(
self,
key: impl SingleArg,
from_timestamp: impl SingleArg,
to_timestamp: impl SingleArg,
options: TsRangeOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Query a range in forward direction Read more
source§fn ts_revrange<R: CollectionResponse<(u64, f64)>>(
self,
key: impl SingleArg,
from_timestamp: impl SingleArg,
to_timestamp: impl SingleArg,
options: TsRangeOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn ts_revrange<R: CollectionResponse<(u64, f64)>>(
self,
key: impl SingleArg,
from_timestamp: impl SingleArg,
to_timestamp: impl SingleArg,
options: TsRangeOptions
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Query a range in reverse direction Read more
source§impl<'a> TopKCommands<'a> for &'a mut Transaction
Available on crate feature redis-bloom
only.
impl<'a> TopKCommands<'a> for &'a mut Transaction
Available on crate feature
redis-bloom
only.source§fn topk_add<I: SingleArg, R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
fn topk_add<I: SingleArg, R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
Adds an item to the data structure. Read more
source§fn topk_incrby<I: SingleArg, R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
key: impl SingleArg,
items: impl KeyValueArgsCollection<I, i64>
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
fn topk_incrby<I: SingleArg, R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
key: impl SingleArg,
items: impl KeyValueArgsCollection<I, i64>
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
Increase the score of an item in the data structure by increment. Read more
source§fn topk_info(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, TopKInfoResult>where
Self: Sized,
fn topk_info(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, TopKInfoResult>where
Self: Sized,
Returns number of required items (k), width, depth and decay values. Read more
source§fn topk_list<R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
fn topk_list<R: PrimitiveResponse + DeserializeOwned, RR: CollectionResponse<R>>(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, RR>where
Self: Sized,
Return full list of items in Top K list. Read more
source§fn topk_list_with_count<N: PrimitiveResponse + DeserializeOwned>(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, TopKListWithCountResult<N>>where
Self: Sized,
fn topk_list_with_count<N: PrimitiveResponse + DeserializeOwned>(
self,
key: impl SingleArg
) -> PreparedCommand<'a, Self, TopKListWithCountResult<N>>where
Self: Sized,
Return full list of items in Top K list. Read more
source§fn topk_query<I: SingleArg, R: CollectionResponse<bool>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
fn topk_query<I: SingleArg, R: CollectionResponse<bool>>(
self,
key: impl SingleArg,
items: impl SingleArgCollection<I>
) -> PreparedCommand<'a, Self, R>where
Self: Sized,
Return full list of items in Top K list. Read more
Auto Trait Implementations§
impl Freeze for Transaction
impl !RefUnwindSafe for Transaction
impl Send for Transaction
impl Sync for Transaction
impl Unpin for Transaction
impl !UnwindSafe for Transaction
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more