Package org.springframework.data.redis.connection

Interface ReactiveClusterCommands

All Known Subinterfaces:

ReactiveRedisClusterConnection

public interface ReactiveClusterCommands

Interface for the cluster commands supported by Redis executed using reactive infrastructure. A RedisClusterNode can be obtained from clusterGetNodes() or it can be constructed using either host and RedisNode.getPort() or the node Id.

Since:

2.3.2

Author:

Mark Paluch, Christoph Strobl

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	ReactiveClusterCommands.AddSlots

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<Void>	clusterAddSlots(RedisClusterNode node, int... slots)	Assign slots to given RedisClusterNode.
reactor.core.publisher.Mono<Void>	clusterAddSlots(RedisClusterNode node, RedisClusterNode.SlotRange range)	Assign RedisClusterNode.SlotRange.getSlotsArray() to given RedisClusterNode.
reactor.core.publisher.Mono<Long>	clusterCountKeysInSlot(int slot)	Count the number of keys assigned to one slot.
reactor.core.publisher.Mono<Void>	clusterDeleteSlots(RedisClusterNode node, int... slots)	Remove slots from RedisClusterNode.
reactor.core.publisher.Mono<Void>	clusterDeleteSlotsInRange(RedisClusterNode node, RedisClusterNode.SlotRange range)	Removes RedisClusterNode.SlotRange.getSlotsArray() from given RedisClusterNode.
reactor.core.publisher.Mono<Void>	clusterForget(RedisClusterNode node)	Remove given node from cluster.
reactor.core.publisher.Mono<ClusterInfo>	clusterGetClusterInfo()	Get cluster information.
reactor.core.publisher.Flux<ByteBuffer>	clusterGetKeysInSlot(int slot, int count)	Get keys served by slot.
reactor.core.publisher.Mono<Map<RedisClusterNode,Collection<RedisClusterNode>>>	clusterGetMasterReplicaMap()	Retrieve information about masters and their connected replicas.
reactor.core.publisher.Mono<RedisClusterNode>	clusterGetNodeForKey(ByteBuffer key)	Find the RedisClusterNode serving given key.
reactor.core.publisher.Mono<RedisClusterNode>	clusterGetNodeForSlot(int slot)	Find the RedisClusterNode serving given slot.
reactor.core.publisher.Flux<RedisClusterNode>	clusterGetNodes()	Retrieve cluster node information such as id, host, port and slots.
reactor.core.publisher.Flux<RedisClusterNode>	clusterGetReplicas(RedisClusterNode master)	Retrieve information about connected replicas for given master node.
reactor.core.publisher.Mono<Integer>	clusterGetSlotForKey(ByteBuffer key)	Find the slot for a given key.
reactor.core.publisher.Mono<Void>	clusterMeet(RedisClusterNode node)	Add given node to cluster.
reactor.core.publisher.Mono<Void>	clusterReplicate(RedisClusterNode master, RedisClusterNode replica)	Assign a replica to given master.
reactor.core.publisher.Mono<Void>	clusterSetSlot(RedisClusterNode node, int slot, ReactiveClusterCommands.AddSlots mode)

Method Details

clusterGetNodes

reactor.core.publisher.Flux<RedisClusterNode> clusterGetNodes()

Retrieve cluster node information such as id, host, port and slots.

Returns:

a Flux emitting cluster nodes, an empty one if none found.

See Also:

• Redis Documentation: CLUSTER NODES

clusterGetReplicas

reactor.core.publisher.Flux<RedisClusterNode> clusterGetReplicas(RedisClusterNode master)

Retrieve information about connected replicas for given master node.

Parameters:

master - must not be null.

Returns:

a Flux emitting cluster nodes, an empty one if none found.

See Also:

• Redis Documentation: CLUSTER REPLICAS

clusterGetMasterReplicaMap

reactor.core.publisher.Mono<Map<RedisClusterNode,Collection<RedisClusterNode>>> clusterGetMasterReplicaMap()

Retrieve information about masters and their connected replicas.

Returns:

never null.

See Also:

• Redis Documentation: CLUSTER REPLICAS

clusterGetSlotForKey

reactor.core.publisher.Mono<Integer> clusterGetSlotForKey(ByteBuffer key)

Find the slot for a given key.

Parameters:

key - must not be null.

Returns:

a Mono emitting the calculated slog.

See Also:

• Redis Documentation: CLUSTER KEYSLOT

clusterGetNodeForSlot

reactor.core.publisher.Mono<RedisClusterNode> clusterGetNodeForSlot(int slot)

Find the RedisClusterNode serving given slot.

Parameters:

slot -

Returns:

a Mono emitting the RedisClusterNode handling the given slot.

clusterGetNodeForKey

reactor.core.publisher.Mono<RedisClusterNode> clusterGetNodeForKey(ByteBuffer key)

Find the RedisClusterNode serving given key.

Parameters:

key - must not be null.

Returns:

a Mono emitting the RedisClusterNode handling the slot for the given key.

clusterGetClusterInfo

reactor.core.publisher.Mono<ClusterInfo> clusterGetClusterInfo()

Get cluster information.

Returns:

never null.

See Also:

• Redis Documentation: CLUSTER INFO

clusterAddSlots

reactor.core.publisher.Mono<Void> clusterAddSlots(RedisClusterNode node,
 int... slots)

Assign slots to given RedisClusterNode.

Parameters:

node - must not be null.

slots - must not be empty.

Returns:

a Mono signaling completion.

See Also:

• Redis Documentation: CLUSTER ADDSLOTS

clusterAddSlots

reactor.core.publisher.Mono<Void> clusterAddSlots(RedisClusterNode node,
 RedisClusterNode.SlotRange range)

Assign RedisClusterNode.SlotRange.getSlotsArray() to given RedisClusterNode.

Parameters:

node - must not be null.

range - must not be null.

Returns:

a Mono signaling completion.

See Also:

• Redis Documentation: CLUSTER ADDSLOTS

clusterCountKeysInSlot

reactor.core.publisher.Mono<Long> clusterCountKeysInSlot(int slot)

Count the number of keys assigned to one slot.

Parameters:

slot -

Returns:

a Mono emitting the number of keys stored at the given slot.

See Also:

• Redis Documentation: CLUSTER COUNTKEYSINSLOT

clusterDeleteSlots

reactor.core.publisher.Mono<Void> clusterDeleteSlots(RedisClusterNode node,
 int... slots)

Remove slots from RedisClusterNode.

Parameters:

node - must not be null.

Returns:

a Mono signaling completion.

See Also:

• Redis Documentation: CLUSTER DELSLOTS

clusterDeleteSlotsInRange

reactor.core.publisher.Mono<Void> clusterDeleteSlotsInRange(RedisClusterNode node,
 RedisClusterNode.SlotRange range)

Removes RedisClusterNode.SlotRange.getSlotsArray() from given RedisClusterNode.

Parameters:

node - must not be null.

range - must not be null.

Returns:

a Mono signaling completion.

See Also:

• Redis Documentation: CLUSTER DELSLOTS

clusterForget

reactor.core.publisher.Mono<Void> clusterForget(RedisClusterNode node)

Remove given node from cluster.

Parameters:

node - must not be null.

Returns:

a Mono signaling completion.

See Also:

• Redis Documentation: CLUSTER FORGET

clusterMeet

reactor.core.publisher.Mono<Void> clusterMeet(RedisClusterNode node)

Add given node to cluster.

Parameters:

node - must contain host and RedisNode.getPort() and must not be null.

Returns:

a Mono signaling completion.

See Also:

• Redis Documentation: CLUSTER MEET

clusterSetSlot

reactor.core.publisher.Mono<Void> clusterSetSlot(RedisClusterNode node,
 int slot,
 ReactiveClusterCommands.AddSlots mode)

Parameters:

node - must not be null.

slot -

mode - must not benull.

Returns:

a Mono signaling completion.

See Also:

• Redis Documentation: CLUSTER SETSLOT

clusterGetKeysInSlot

reactor.core.publisher.Flux<ByteBuffer> clusterGetKeysInSlot(int slot,
 int count)

Get keys served by slot.

Parameters:

slot -

count - must not be null.

Returns:

a Flux emitting the number of requested keys in the given slot, or signalling completion if none found.

See Also:

• Redis Documentation: CLUSTER GETKEYSINSLOT

clusterReplicate

reactor.core.publisher.Mono<Void> clusterReplicate(RedisClusterNode master,
 RedisClusterNode replica)

Assign a replica to given master.

Parameters:

master - must not be null.

replica - must not be null.

Returns:

a Mono signaling completion.

See Also:

• Redis Documentation: CLUSTER REPLICATE