Struct fred::clients::Transaction
source · pub struct Transaction { /* private fields */ }Available on crate feature
transactions only.Expand description
A cheaply cloneable transaction block.
-Implementations§
source§impl Transaction
impl Transaction
sourcepub fn watched_len(&self) -> usize
pub fn watched_len(&self) -> usize
Read the number of keys to WATCH before the starting the transaction.
sourcepub async fn exec<R>(&self, abort_on_error: bool) -> Result<R, RedisError>where
+Transaction in fred::clients - Rust Struct fred::clients::Transaction
source · pub struct Transaction { /* private fields */ }
Available on crate feature transactions only.Expand description
A cheaply cloneable transaction block.
+Implementations§
source§impl Transaction
sourcepub fn pipeline(&self, val: bool)
Whether to pipeline commands in the transaction.
+Note: pipelined transactions should only be used with Redis version >=2.6.5.
+sourcepub fn watched_len(&self) -> usize
👎Deprecated since 9.2.0: Please use WATCH with clients from an ExclusivePool instead.
Read the number of keys to WATCH before the starting the transaction.
+sourcepub async fn exec<R>(&self, abort_on_error: bool) -> Result<R, RedisError>where
R: FromRedis,
Executes all previously queued commands in a transaction.
If abort_on_error is true the client will automatically send DISCARD if an error is received from
any of the commands prior to EXEC. This does not apply to MOVED or ASK errors, which wll be followed
@@ -22,11 +24,11 @@
assert_eq!((foo, bar), (1, 2));
Ok(())
}
-sourcepub fn watch_before<K>(&self, keys: K)where
- K: Into<MultipleKeys>,
Send the WATCH command with the provided keys before starting the transaction.
-sourcepub fn hash_slot(&self) -> Option<u16>
Read the hash slot against which this transaction will run, if known.
-sourcepub fn cluster_node(&self) -> Option<Server>
Read the server ID against which this transaction will run, if known.
-Trait Implementations§
source§impl AclInterface for Transaction
Available on crate feature i-acl only.
source§fn acl_setuser<S, V>(
+
sourcepub fn watch_before<K>(&self, keys: K)where
+ K: Into<MultipleKeys>,
👎Deprecated since 9.2.0: Please use WATCH with clients from an ExclusivePool instead.
Send the WATCH command with the provided keys before starting the transaction.
+sourcepub fn hash_slot(&self) -> Option<u16>
Read the hash slot against which this transaction will run, if known.
+sourcepub fn cluster_node(&self) -> Option<Server>
Read the server ID against which this transaction will run, if known.
+Trait Implementations§
source§impl AclInterface for Transaction
Available on crate feature i-acl only.
source§fn acl_setuser<S, V>(
&self,
username: S,
rules: V,
@@ -59,7 +61,7 @@
&self,
count: Option<u32>,
) -> impl Future<Output = RedisResult<R>>where
- R: FromRedis,
Read count recent ACL security events. Read moresource§fn acl_log_reset(&self) -> impl Future<Output = RedisResult<()>>
Clear the ACL security events logs. Read moresource§impl AuthInterface for Transaction
Read count recent ACL security events. Read moresource§fn acl_log_reset(&self) -> impl Future<Output = RedisResult<()>>
Clear the ACL security events logs. Read more
pub async fn exec<R>(&self, abort_on_error: bool) -> Result<R, RedisError>where
+Transaction in fred::clients - Rust Struct fred::clients::Transaction
source · pub struct Transaction { /* private fields */ }
Available on crate feature transactions only.Expand description
A cheaply cloneable transaction block.
+Implementations§
source§impl Transaction
sourcepub fn pipeline(&self, val: bool)
Whether to pipeline commands in the transaction.
+Note: pipelined transactions should only be used with Redis version >=2.6.5.
+sourcepub fn watched_len(&self) -> usize
👎Deprecated since 9.2.0: Please use WATCH with clients from an ExclusivePool instead.
Read the number of keys to WATCH before the starting the transaction.
+sourcepub async fn exec<R>(&self, abort_on_error: bool) -> Result<R, RedisError>where
R: FromRedis,
Executes all previously queued commands in a transaction.
If abort_on_error is true the client will automatically send DISCARD if an error is received from
any of the commands prior to EXEC. This does not apply to MOVED or ASK errors, which wll be followed
@@ -22,11 +24,11 @@
assert_eq!((foo, bar), (1, 2));
Ok(())
}
-sourcepub fn watch_before<K>(&self, keys: K)where
- K: Into<MultipleKeys>,
Send the WATCH command with the provided keys before starting the transaction.
-sourcepub fn hash_slot(&self) -> Option<u16>
Read the hash slot against which this transaction will run, if known.
-sourcepub fn cluster_node(&self) -> Option<Server>
Read the server ID against which this transaction will run, if known.
-Trait Implementations§
source§impl AclInterface for Transaction
Available on crate feature i-acl only.
source§fn acl_setuser<S, V>(
+
sourcepub fn watch_before<K>(&self, keys: K)where
+ K: Into<MultipleKeys>,
👎Deprecated since 9.2.0: Please use WATCH with clients from an ExclusivePool instead.
Send the WATCH command with the provided keys before starting the transaction.
+sourcepub fn hash_slot(&self) -> Option<u16>
Read the hash slot against which this transaction will run, if known.
+sourcepub fn cluster_node(&self) -> Option<Server>
Read the server ID against which this transaction will run, if known.
+Trait Implementations§
source§impl AclInterface for Transaction
Available on crate feature i-acl only.
source§fn acl_setuser<S, V>(
&self,
username: S,
rules: V,
@@ -59,7 +61,7 @@
&self,
count: Option<u32>,
) -> impl Future<Output = RedisResult<R>>where
- R: FromRedis,
Read count recent ACL security events. Read moresource§fn acl_log_reset(&self) -> impl Future<Output = RedisResult<()>>
Clear the ACL security events logs. Read moresource§impl AuthInterface for Transaction
Read count recent ACL security events. Read moresource§fn acl_log_reset(&self) -> impl Future<Output = RedisResult<()>>
Clear the ACL security events logs. Read more
Struct fred::clients::Transaction
source · pub struct Transaction { /* private fields */ }Available on crate feature
transactions only.Expand description
A cheaply cloneable transaction block.
+Implementations§
source§impl Transaction
impl Transaction
sourcepub fn pipeline(&self, val: bool)
pub fn pipeline(&self, val: bool)
Whether to pipeline commands in the transaction.
+Note: pipelined transactions should only be used with Redis version >=2.6.5.
+sourcepub fn watched_len(&self) -> usize
👎Deprecated since 9.2.0: Please use WATCH with clients from an ExclusivePool instead.
pub fn watched_len(&self) -> usize
WATCH with clients from an ExclusivePool instead.Read the number of keys to WATCH before the starting the transaction.
sourcepub async fn exec<R>(&self, abort_on_error: bool) -> Result<R, RedisError>where
R: FromRedis,
pub async fn exec<R>(&self, abort_on_error: bool) -> Result<R, RedisError>where
R: FromRedis,
Executes all previously queued commands in a transaction.
If abort_on_error is true the client will automatically send DISCARD if an error is received from
any of the commands prior to EXEC. This does not apply to MOVED or ASK errors, which wll be followed
@@ -22,11 +24,11 @@
assert_eq!((foo, bar), (1, 2));
Ok(())
}
sourcepub fn watch_before<K>(&self, keys: K)where
- K: Into<MultipleKeys>,
pub fn watch_before<K>(&self, keys: K)where
- K: Into<MultipleKeys>,
Send the WATCH command with the provided keys before starting the transaction.
sourcepub fn hash_slot(&self) -> Option<u16>
pub fn hash_slot(&self) -> Option<u16>
Read the hash slot against which this transaction will run, if known.
-sourcepub fn cluster_node(&self) -> Option<Server>
pub fn cluster_node(&self) -> Option<Server>
Read the server ID against which this transaction will run, if known.
-Trait Implementations§
source§impl AclInterface for Transaction
Available on crate feature i-acl only.
impl AclInterface for Transaction
Available on crate feature
i-acl only.source§fn acl_setuser<S, V>(
+
fn acl_setuser<S, V>( +
sourcepub fn watch_before<K>(&self, keys: K)where
+ K: Into<MultipleKeys>,
👎Deprecated since 9.2.0: Please use WATCH with clients from an ExclusivePool instead.
pub fn watch_before<K>(&self, keys: K)where
+ K: Into<MultipleKeys>,
WATCH with clients from an ExclusivePool instead.Send the WATCH command with the provided keys before starting the transaction.
sourcepub fn hash_slot(&self) -> Option<u16>
pub fn hash_slot(&self) -> Option<u16>
Read the hash slot against which this transaction will run, if known.
+sourcepub fn cluster_node(&self) -> Option<Server>
pub fn cluster_node(&self) -> Option<Server>
Read the server ID against which this transaction will run, if known.
+source§impl AclInterface for Transaction
Available on crate feature i-acl only.
impl AclInterface for Transaction
Available on crate feature
i-acl only.source§fn acl_setuser<S, V>(
&self,
username: S,
rules: V,
@@ -59,7 +61,7 @@
&self,
count: Option<u32>,
) -> impl Future<Output = RedisResult<R>>where
- R: FromRedis,
fn acl_setuser<S, V>(
&self,
username: S,
rules: V,
@@ -59,7 +61,7 @@
&self,
count: Option<u32>,
) -> impl Future<Output = RedisResult<R>>where
- R: FromRedis,
Read
count recent ACL security events. Read moresource§fn acl_log_reset(&self) -> impl Future<Output = RedisResult<()>>
fn acl_log_reset(&self) -> impl Future<Output = RedisResult<()>>
Clear the ACL security events logs. Read more
source§impl AuthInterface for Transaction
impl AuthInterface for Transaction
Read
count recent ACL security events. Read moresource§fn acl_log_reset(&self) -> impl Future<Output = RedisResult<()>>
fn acl_log_reset(&self) -> impl Future<Output = RedisResult<()>>
Clear the ACL security events logs. Read more
source§impl AuthInterface for Transaction
impl AuthInterface for Transaction
source§impl ClientInterface for Transaction
Available on crate feature i-client only.
impl ClientInterface for Transaction
Available on crate feature
i-client only.source§fn client_id<R>(&self) -> impl Future<Output = RedisResult<R>>where
+) -> impl Future<Output = RedisResult<()>>Switch to a different protocol, optionally authenticating in the process. Read more
fn client_id<R>(&self) -> impl Future<Output = RedisResult<R>>where
+) -> impl Future<Output = RedisResult<()>>Switch to a different protocol, optionally authenticating in the process. Read more
Switch to a different protocol, optionally authenticating in the process. Read more
source§impl ClientInterface for Transaction
Available on crate feature i-client only.
impl ClientInterface for Transaction
Available on crate feature
i-client only.source§fn client_id<R>(&self) -> impl Future<Output = RedisResult<R>>where
R: FromRedis,
fn client_id<R>(&self) -> impl Future<Output = RedisResult<R>>where
R: FromRedis,
Return the ID of the current connection. Read more
source§fn connection_ids(&self) -> impl Future<Output = HashMap<Server, i64>>
fn connection_ids(&self) -> impl Future<Output = HashMap<Server, i64>>
Read the connection IDs for the active connections to each server. Read more
source§fn client_info<R>(&self) -> impl Future<Output = RedisResult<R>>where
R: FromRedis,
fn client_info<R>(&self) -> impl Future<Output = RedisResult<R>>where
R: FromRedis,
The command returns information and statistics about the current client connection in a mostly human readable
format. Read more
source§fn client_kill<R>(
@@ -125,7 +127,7 @@
enabled: bool,
) -> impl Future<Output = RedisResult<R>>where
R: FromRedis,
fn client_kill<R>(
@@ -125,7 +127,7 @@
enabled: bool,
) -> impl Future<Output = RedisResult<R>>where
R: FromRedis,
Available on crate feature
i-tracking only.This command controls the tracking of the keys in the next command executed by the connection, when tracking is
-enabled in OPTIN or OPTOUT mode. Read more
source§impl ClientLike for Transaction
impl ClientLike for Transaction
source§fn client_config(&self) -> RedisConfig
fn client_config(&self) -> RedisConfig
Read the config used to initialize the client.
source§fn client_reconnect_policy(&self) -> Option<ReconnectPolicy>
fn client_reconnect_policy(&self) -> Option<ReconnectPolicy>
Read the reconnect policy used to initialize the client.
source§fn connection_config(&self) -> &ConnectionConfig
fn connection_config(&self) -> &ConnectionConfig
Read the connection config used to initialize the client.
source§fn protocol_version(&self) -> RespVersion
fn protocol_version(&self) -> RespVersion
Read the RESP version used by the client when communicating with the server.
source§fn has_reconnect_policy(&self) -> bool
fn has_reconnect_policy(&self) -> bool
Whether the client has a reconnection policy.
source§fn is_pipelined(&self) -> bool
fn is_pipelined(&self) -> bool
Whether the client will automatically pipeline commands.
source§fn is_clustered(&self) -> bool
fn is_clustered(&self) -> bool
Whether the client is connected to a cluster.
source§fn uses_sentinels(&self) -> bool
fn uses_sentinels(&self) -> bool
Whether the client uses the sentinel interface.
source§fn update_perf_config(&self, config: PerformanceConfig)
fn update_perf_config(&self, config: PerformanceConfig)
Update the internal PerformanceConfig in place with new values.
source§fn perf_config(&self) -> PerformanceConfig
fn perf_config(&self) -> PerformanceConfig
Read the PerformanceConfig associated with this client.
source§fn state(&self) -> ClientState
fn state(&self) -> ClientState
Read the state of the underlying connection(s). Read more
source§fn is_connected(&self) -> bool
fn is_connected(&self) -> bool
Whether all underlying connections are healthy.
source§fn active_connections(
+enabled in OPTIN or OPTOUT mode. Read more
fn active_connections( +enabled in OPTIN or OPTOUT mode. Read more
source§impl ClientLike for Transaction
impl ClientLike for Transaction
source§fn client_config(&self) -> RedisConfig
fn client_config(&self) -> RedisConfig
Read the config used to initialize the client.
source§fn client_reconnect_policy(&self) -> Option<ReconnectPolicy>
fn client_reconnect_policy(&self) -> Option<ReconnectPolicy>
Read the reconnect policy used to initialize the client.
source§fn connection_config(&self) -> &ConnectionConfig
fn connection_config(&self) -> &ConnectionConfig
Read the connection config used to initialize the client.
source§fn protocol_version(&self) -> RespVersion
fn protocol_version(&self) -> RespVersion
Read the RESP version used by the client when communicating with the server.
source§fn has_reconnect_policy(&self) -> bool
fn has_reconnect_policy(&self) -> bool
Whether the client has a reconnection policy.
source§fn is_pipelined(&self) -> bool
fn is_pipelined(&self) -> bool
Whether the client will automatically pipeline commands.
source§fn is_clustered(&self) -> bool
fn is_clustered(&self) -> bool
Whether the client is connected to a cluster.
source§fn uses_sentinels(&self) -> bool
fn uses_sentinels(&self) -> bool
Whether the client uses the sentinel interface.
source§fn update_perf_config(&self, config: PerformanceConfig)
fn update_perf_config(&self, config: PerformanceConfig)
Update the internal PerformanceConfig in place with new values.
source§fn perf_config(&self) -> PerformanceConfig
fn perf_config(&self) -> PerformanceConfig
Read the PerformanceConfig associated with this client.
source§fn state(&self) -> ClientState
fn state(&self) -> ClientState
Read the state of the underlying connection(s). Read more
source§fn is_connected(&self) -> bool
fn is_connected(&self) -> bool
Whether all underlying connections are healthy.
source§fn active_connections(
&self,
) -> impl Future<Output = Result<Vec<Server>, RedisError>>
fn active_connections( &self, ) -> impl Future<Output = Result<Vec<Server>, RedisError>>
Read the set of active connections managed by the client.
source§fn server_version(&self) -> Option<Version>
fn server_version(&self) -> Option<Version>
Read the server version, if known.
source§fn set_resolver(&self, resolver: Rc<dyn Resolve>) -> impl Future
fn set_resolver(&self, resolver: Rc<dyn Resolve>) -> impl Future
Available on crate feature
dns only.Override the DNS resolution logic for the client.
source§fn connect(&self) -> ConnectHandle
fn connect(&self) -> ConnectHandle
Connect to the server. Read more
source§fn force_reconnection(&self) -> impl Future<Output = RedisResult<()>>
fn force_reconnection(&self) -> impl Future<Output = RedisResult<()>>
Force a reconnection to the server(s). Read more
source§fn wait_for_connect(&self) -> impl Future<Output = RedisResult<()>>
fn wait_for_connect(&self) -> impl Future<Output = RedisResult<()>>
Wait for the result of the next connection attempt. Read more
source§fn init(&self) -> impl Future<Output = RedisResult<ConnectHandle>>
fn init(&self) -> impl Future<Output = RedisResult<ConnectHandle>>
Initialize a new routing and connection task and wait for it to connect successfully. Read more
source§fn quit(&self) -> impl Future<Output = RedisResult<()>>
fn quit(&self) -> impl Future<Output = RedisResult<()>>
Close the connection to the Redis server. The returned future resolves when the command has been written to the
socket, not when the connection has been fully closed. Some time after this future resolves the future
@@ -154,7 +156,7 @@
) -> impl Future<Output = RedisResult<Resp3Frame>>
Run a custom command similar to custom, but return the response frame directly without any
-parsing. Read more
source§fn with_options(&self, options: &Options) -> WithOptions<Self>
fn with_options(&self, options: &Options) -> WithOptions<Self>
Customize various configuration options on commands.
source§impl Clone for Transaction
impl Clone for Transaction
source§fn clone(&self) -> Transaction
fn clone(&self) -> Transaction
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moresource§impl ConfigInterface for Transaction
Available on crate feature i-config only.
impl ConfigInterface for Transaction
Available on crate feature
i-config only.source§fn config_resetstat(&self) -> impl Future<Output = RedisResult<()>>
fn config_resetstat(&self) -> impl Future<Output = RedisResult<()>>
Resets the statistics reported by Redis using the INFO command. Read more
source§fn config_rewrite(&self) -> impl Future<Output = RedisResult<()>>
fn config_rewrite(&self) -> impl Future<Output = RedisResult<()>>
The CONFIG REWRITE command rewrites the redis.conf file the server was started with, applying the minimal
+parsing. Read more
source§fn with_options(&self, options: &Options) -> WithOptions<Self>
fn with_options(&self, options: &Options) -> WithOptions<Self>
Customize various configuration options on commands.
source§impl Clone for Transaction
impl Clone for Transaction
source§fn clone(&self) -> Transaction
fn clone(&self) -> Transaction
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moresource§impl ConfigInterface for Transaction
Available on crate feature i-config only.
impl ConfigInterface for Transaction
Available on crate feature
i-config only.source§fn config_resetstat(&self) -> impl Future<Output = RedisResult<()>>
fn config_resetstat(&self) -> impl Future<Output = RedisResult<()>>
Resets the statistics reported by Redis using the INFO command. Read more
source§fn config_rewrite(&self) -> impl Future<Output = RedisResult<()>>
fn config_rewrite(&self) -> impl Future<Output = RedisResult<()>>
The CONFIG REWRITE command 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 more
source§fn config_get<R, S>(&self, parameter: S) -> impl Future<Output = RedisResult<R>>where
R: FromRedis,
@@ -165,7 +167,7 @@
) -> impl Future<Output = RedisResult<()>>The CONFIG SET command is used in order to reconfigure the server at run time without the need to restart Redis. Read more
fn config_get<R, S>(&self, parameter: S) -> impl Future<Output = RedisResult<R>>where
R: FromRedis,
@@ -165,7 +167,7 @@
) -> impl Future<Output = RedisResult<()>>The CONFIG SET command is used in order to reconfigure the server at run time without the need to restart Redis. Read more
The CONFIG SET command is used in order to reconfigure the server at run time without the need to restart Redis. Read more
source§impl Debug for Transaction
impl Debug for Transaction
source§impl FunctionInterface for Transaction
Available on crate feature i-scripts only.
impl FunctionInterface for Transaction
Available on crate feature
i-scripts only.The CONFIG SET command is used in order to reconfigure the server at run time without the need to restart Redis. Read more
source§impl Debug for Transaction
impl Debug for Transaction
source§impl FunctionInterface for Transaction
Available on crate feature i-scripts only.
impl FunctionInterface for Transaction
Available on crate feature
i-scripts only.Restore libraries from the serialized payload on all cluster nodes concurrently. Read more
source§fn function_stats<R>(&self) -> impl Future<Output = RedisResult<R>>where
R: FromRedis,
fn function_stats<R>(&self) -> impl Future<Output = RedisResult<R>>where
R: FromRedis,
Return information about the function that’s currently running and information about the available execution
-engines. Read more
source§impl GeoInterface for Transaction
Available on crate feature i-geo only.
impl GeoInterface for Transaction
Available on crate feature
i-geo only.source§impl GeoInterface for Transaction
Available on crate feature i-geo only.
impl GeoInterface for Transaction
Available on crate feature
i-geo only.This command is like GEOSEARCH, but stores the result in destination key. Returns the number of members added to
-the destination key. Read more
source§impl HashesInterface for Transaction
Available on crate feature i-hashes only.
impl HashesInterface for Transaction
Available on crate feature
i-hashes only.source§impl HashesInterface for Transaction
Available on crate feature i-hashes only.
impl HashesInterface for Transaction
Available on crate feature
i-hashes only.