ClusterCommands

rustis::commands

Trait ClusterCommands 

Source 
pub trait ClusterCommands<'a>: Sized {

Show 28 methods    // Provided methods
    fn asking(self) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_addslots<S>(
        self,
        slots: impl Serialize,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_addslotsrange<S>(
        self,
        slots: impl Serialize,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_bumpepoch(
        self,
    ) -> PreparedCommand<'a, Self, ClusterBumpEpochResult> { ... }
    fn cluster_count_failure_reports<I>(
        self,
        node_id: impl Serialize,
    ) -> PreparedCommand<'a, Self, usize> { ... }
    fn cluster_countkeysinslot(
        self,
        slot: usize,
    ) -> PreparedCommand<'a, Self, usize> { ... }
    fn cluster_delslots<S>(
        self,
        slots: impl Serialize,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_delslotsrange<S>(
        self,
        slots: impl Serialize,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_failover(
        self,
        option: Option<ClusterFailoverOption>,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_flushslots(self) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_forget<I>(
        self,
        node_id: impl Serialize,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_getkeysinslot(
        self,
        slot: u16,
        count: usize,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_info(
        self,
        slot: u16,
        count: usize,
    ) -> PreparedCommand<'a, Self, ClusterInfo> { ... }
    fn cluster_keyslot(
        self,
        key: impl Serialize,
    ) -> PreparedCommand<'a, Self, u16> { ... }
    fn cluster_links<R: Response>(self) -> PreparedCommand<'a, Self, R> { ... }
    fn cluster_meet(
        self,
        ip: impl Serialize,
        port: u16,
        cluster_bus_port: Option<u16>,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_myid<R: Response>(self) -> PreparedCommand<'a, Self, R> { ... }
    fn cluster_nodes<R: Response>(self) -> PreparedCommand<'a, Self, R> { ... }
    fn cluster_replicas<R: Response>(
        self,
        node_id: impl Serialize,
    ) -> PreparedCommand<'a, Self, R> { ... }
    fn cluster_replicate(
        self,
        node_id: impl Serialize,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_reset(
        self,
        reset_type: ClusterResetType,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_saveconfig(self) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_set_config_epoch(
        self,
        config_epoch: u64,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_setslot(
        self,
        slot: u16,
        subcommand: ClusterSetSlotSubCommand<'_>,
    ) -> PreparedCommand<'a, Self, ()> { ... }
    fn cluster_shards<R: Response>(self) -> PreparedCommand<'a, Self, R> { ... }
    fn cluster_slots<R: Response>(self) -> PreparedCommand<'a, Self, R> { ... }
    fn readonly(self) -> PreparedCommand<'a, Self, ()> { ... }
    fn readwrite(self) -> PreparedCommand<'a, Self, ()> { ... }

}
Expand description

A group of Redis commands related to Cluster Management

§See Also

Redis Cluster Management commands Redis cluster specification

Provided Methods§

Source

fn asking(self) -> PreparedCommand<'a, Self, ()>

When a cluster client receives an -ASK redirect, the ASKING command is sent to the target node followed by the command which was redirected. This is normally done automatically by cluster clients.

§See Also

https://redis.io/commands/asking/

Source

fn cluster_addslots<S>( self, slots: impl Serialize, ) -> PreparedCommand<'a, Self, ()>

This command is useful in order to modify a node’s view of the cluster configuration.

Specifically it assigns a set of hash slots to the node receiving the command. If the command is successful, the node will map the specified hash slots to itself, and will start broadcasting the new configuration.

§See Also

https://redis.io/commands/cluster-addslots/

Source

fn cluster_addslotsrange<S>( self, slots: impl Serialize, ) -> PreparedCommand<'a, Self, ()>

This command is similar to the cluster_addslots command in that they both assign hash slots to nodes.

The difference between the two commands is that cluster_addslots takes a list of slots to assign to the node, while this command takes a list of slot ranges (specified by a tuple containing start and end slots) to assign to the node.

§See Also

https://redis.io/commands/cluster-addslotsrange/

Source

fn cluster_bumpepoch(self) -> PreparedCommand<'a, Self, ClusterBumpEpochResult>

Advances the cluster config epoch.

§Return
  • Bumped if the epoch was incremented, or
  • Still if the node already has the greatest config epoch in the cluster.
§See Also

https://redis.io/commands/cluster-bumpepoch/

Source

fn cluster_count_failure_reports<I>( self, node_id: impl Serialize, ) -> PreparedCommand<'a, Self, usize>

The command returns the number of failure reports for the specified node.

§Return

The number of active failure reports for the node.

§See Also

https://redis.io/commands/cluster-count-failure-reports/

Source

fn cluster_countkeysinslot( self, slot: usize, ) -> PreparedCommand<'a, Self, usize>

Returns the number of keys in the specified Redis Cluster hash slot.

§Return

The number of keys in the specified hash slot, or an error if the hash slot is invalid.

§See Also

https://redis.io/commands/cluster-countkeysinslot/

Source

fn cluster_delslots<S>( self, slots: impl Serialize, ) -> PreparedCommand<'a, Self, ()>

In Redis Cluster, each node keeps track of which master is serving a particular hash slot. This command asks a particular Redis Cluster node to forget which master is serving the hash slots specified as arguments.

§See Also

https://redis.io/commands/cluster-delslots/

Source

fn cluster_delslotsrange<S>( self, slots: impl Serialize, ) -> PreparedCommand<'a, Self, ()>

This command is similar to the cluster_delslotsrange command in that they both remove hash slots from the node.

The difference is that cluster_delslotsrange takes a list of hash slots to remove from the node, while this command takes a list of slot ranges (specified by a tuple containing start and end slots) to remove from the node.

§See Also

https://redis.io/commands/cluster-delslotsrange/

Source

fn cluster_failover( self, option: Option<ClusterFailoverOption>, ) -> PreparedCommand<'a, Self, ()>

This command, that can only be sent to a Redis Cluster replica node, forces the replica to start a manual failover of its master instance.

§Errors

An error cann occured if the operation cannot be executed, for example if we are talking with a node which is already a master.

§See Also

https://redis.io/commands/cluster-failover/

Source

fn cluster_flushslots(self) -> PreparedCommand<'a, Self, ()>

Deletes all slots from a node.

§See Also

https://redis.io/commands/cluster-flushslots/

Source

fn cluster_forget<I>( self, node_id: impl Serialize, ) -> PreparedCommand<'a, Self, ()>

The command is used in order to remove a node, specified via its node ID, from the set of known nodes of the Redis Cluster node receiving the command. In other words the specified node is removed from the nodes table of the node receiving the command.

§See Also

https://redis.io/commands/cluster-forget/

Source

fn cluster_getkeysinslot( self, slot: u16, count: usize, ) -> PreparedCommand<'a, Self, ()>

The command returns an array of keys names stored in the contacted node and hashing to the specified hash slot.

The maximum number of keys to return is specified via the count argument, so that it is possible for the user of this API to batch-processing keys.

§See Also

https://redis.io/commands/cluster-getkeysinslot/

Source

fn cluster_info( self, slot: u16, count: usize, ) -> PreparedCommand<'a, Self, ClusterInfo>

This command provides info style information about Redis Cluster vital parameters.

§Return

The Cluster information

§See Also

https://redis.io/commands/cluster-info/

Source

fn cluster_keyslot(self, key: impl Serialize) -> PreparedCommand<'a, Self, u16>

Returns an integer identifying the hash slot the specified key hashes to.

§Return

The hash slot number.

§See Also

https://redis.io/commands/cluster-keyslot/

Each node in a Redis Cluster maintains a pair of long-lived TCP link with each peer in the cluster:

  • One for sending outbound messages towards the peer
  • and one for receiving inbound messages from the peer.

This command outputs information of all such peer links as an array, where each array element is a struct that contains attributes and their values for an individual link.

§Return

An array of structs where each struct contains various attributes and their values of a cluster link.

§See Also

https://redis.io/commands/cluster-links/

Source

fn cluster_meet( self, ip: impl Serialize, port: u16, cluster_bus_port: Option<u16>, ) -> PreparedCommand<'a, Self, ()>

This command is used in order to connect different Redis nodes with cluster support enabled, into a working cluster.

§Return

An array of structs where each struct contains various attributes and their values of a cluster link.

§See Also

https://redis.io/commands/cluster-meet/

Source

fn cluster_myid<R: Response>(self) -> PreparedCommand<'a, Self, R>

This command returns the unique, auto-generated identifier that is associated with the connected cluster node.

§Return

The node id.

§See Also

https://redis.io/commands/cluster-myid/

Source

fn cluster_nodes<R: Response>(self) -> PreparedCommand<'a, Self, R>

Each node in a Redis Cluster has its view of the current cluster configuration, given by the set of known nodes, the state of the connection we have with such nodes, their flags, properties and assigned slots, and so forth.

This command provides all this information, that is, the current cluster configuration of the node we are contacting, in a serialization format which happens to be exactly the same as the one used by Redis Cluster itself in order to store on disk the cluster state (however the on disk cluster state has a few additional info appended at the end).

§Return

The serialized cluster configuration. The output of the command is just a space-separated CSV string, where each line represents a node in the cluster.

§See Also

https://redis.io/commands/cluster-nodes/

Source

fn cluster_replicas<R: Response>( self, node_id: impl Serialize, ) -> PreparedCommand<'a, Self, R>

The command provides a list of replica nodes replicating from the specified master node.

§Return

The command returns data in the same format as cluster_nodes.

§See Also

https://redis.io/commands/cluster-replicas/

Source

fn cluster_replicate( self, node_id: impl Serialize, ) -> PreparedCommand<'a, Self, ()>

The command reconfigures a node as a replica of the specified master. If the node receiving the command is an empty master, as a side effect of the command, the node role is changed from master to replica.

§See Also

https://redis.io/commands/cluster-replicate/

Source

fn cluster_reset( self, reset_type: ClusterResetType, ) -> PreparedCommand<'a, Self, ()>

Reset a Redis Cluster node, in a more or less drastic way depending on the reset type, that can be hard or soft.

§See Also

https://redis.io/commands/cluster-reset/

Source

fn cluster_saveconfig(self) -> PreparedCommand<'a, Self, ()>

Forces a node to save the nodes.conf configuration on disk. Before to return the command calls fsync(2) in order to make sure the configuration is flushed on the computer disk.

§See Also

https://redis.io/commands/cluster-saveconfig/

Source

fn cluster_set_config_epoch( self, config_epoch: u64, ) -> PreparedCommand<'a, Self, ()>

This command sets a specific config epoch in a fresh node.

§See Also

https://redis.io/commands/cluster-set-config-epoch/

Source

fn cluster_setslot( self, slot: u16, subcommand: ClusterSetSlotSubCommand<'_>, ) -> PreparedCommand<'a, Self, ()>

This command is responsible of changing the state of a hash slot in the receiving node in different ways.

§See Also

https://redis.io/commands/cluster-setslot/

Source

fn cluster_shards<R: Response>(self) -> PreparedCommand<'a, Self, R>

This command returns details about the shards of the cluster.

§Return

A list of shard information for each shard (slot ranges & shard nodes)

§See Also

https://redis.io/commands/cluster-shards/

Source

fn cluster_slots<R: Response>(self) -> PreparedCommand<'a, Self, R>

This command returns details details about which cluster slots map to which Redis instances.

§Return

A nested list of slot ranges with networking information.

§See Also

https://redis.io/commands/cluster-slots/

Source

fn readonly(self) -> PreparedCommand<'a, Self, ()>

Enables read queries for a connection to a Redis Cluster replica node.

§See Also

https://redis.io/commands/readonly/

Source

fn readwrite(self) -> PreparedCommand<'a, Self, ()>

Disables read queries for a connection to a Redis Cluster replica node.

§See Also

https://redis.io/commands/readwrite/

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§

Source§

impl<'a> ClusterCommands<'a> for &'a Client

Source§

impl<'a> ClusterCommands<'a> for &'a mut Pipeline<'_>