インターフェース ReactiveClusterCommands
- すべての既知のサブインターフェース:
ReactiveRedisClusterConnection
public interface ReactiveClusterCommands
リアクティブインフラストラクチャを使用して実行される Redis でサポートされるクラスターコマンドのインターフェース。
RedisClusterNode
は、clusterGetNodes()
から取得することも、host
と RedisNode.getPort()
または node Id
を使用して構築することもできます。- 導入:
- 2.3.2
- 作成者:
- Mark Paluch, Christoph Strobl
ネストされたクラスのサマリー
ネストされたクラスメソッドのサマリー
修飾子と型メソッド説明reactor.core.publisher.Mono<VoidSE>
clusterAddSlots
(RedisClusterNode node, int... slots) 指定されたRedisClusterNode
にスロットを割り当てます。reactor.core.publisher.Mono<VoidSE>
clusterAddSlots
(RedisClusterNode node, RedisClusterNode.SlotRange range) 指定されたRedisClusterNode
にRedisClusterNode.SlotRange.getSlotsArray()
を割り当てます。reactor.core.publisher.Mono<LongSE>
clusterCountKeysInSlot
(int slot) 1 つのスロットに割り当てられたキーの数を数えます。reactor.core.publisher.Mono<VoidSE>
clusterDeleteSlots
(RedisClusterNode node, int... slots) RedisClusterNode
からスロットを取り外します。reactor.core.publisher.Mono<VoidSE>
指定されたRedisClusterNode
からRedisClusterNode.SlotRange.getSlotsArray()
を削除します。reactor.core.publisher.Mono<VoidSE>
指定されたノードをクラスターから削除します。reactor.core.publisher.Mono<ClusterInfo>
クラスター情報を取得します。reactor.core.publisher.Flux<ByteBufferSE>
clusterGetKeysInSlot
(int slot, int count) スロットによって提供されるキーを取得します。reactor.core.publisher.Mono<MapSE<RedisClusterNode,
CollectionSE<RedisClusterNode>>> マスターとそれに接続されたレプリカに関する情報を取得します。reactor.core.publisher.Mono<RedisClusterNode>
与えられたキーを提供するRedisClusterNode
を見つけます。reactor.core.publisher.Mono<RedisClusterNode>
clusterGetNodeForSlot
(int slot) 指定されたスロットにサービスを提供しているRedisClusterNode
を見つけます。reactor.core.publisher.Flux<RedisClusterNode>
ID、ホスト、ポート、スロットなどのクラスターノード情報を取得します。reactor.core.publisher.Flux<RedisClusterNode>
clusterGetReplicas
(RedisClusterNode master) 特定のマスターノードの接続されたレプリカに関する情報を取得します。reactor.core.publisher.Mono<IntegerSE>
特定のkey
のスロットを見つけます。reactor.core.publisher.Mono<VoidSE>
clusterMeet
(RedisClusterNode node) 指定されたノードをクラスターに追加します。reactor.core.publisher.Mono<VoidSE>
clusterReplicate
(RedisClusterNode master, RedisClusterNode replica) 指定されたマスターにレプリカを割り当てます。reactor.core.publisher.Mono<VoidSE>
clusterSetSlot
(RedisClusterNode node, int slot, ReactiveClusterCommands.AddSlots mode)
メソッドの詳細
clusterGetNodes
reactor.core.publisher.Flux<RedisClusterNode> clusterGetNodes()ID、ホスト、ポート、スロットなどのクラスターノード情報を取得します。- 戻り値:
cluster nodes
を放出するFlux
、見つからない場合はempty one
。- 関連事項:
clusterGetReplicas
特定のマスターノードの接続されたレプリカに関する情報を取得します。- パラメーター:
master
- null であってはなりません。- 戻り値:
cluster nodes
を放出するFlux
、見つからない場合はempty one
。- 関連事項:
clusterGetMasterReplicaMap
reactor.core.publisher.Mono<MapSE<RedisClusterNode,CollectionSE<RedisClusterNode>>> clusterGetMasterReplicaMap()マスターとそれに接続されたレプリカに関する情報を取得します。- 戻り値:
- 決して null にはなりません。
- 関連事項:
clusterGetSlotForKey
特定のkey
のスロットを見つけます。- パラメーター:
key
- null であってはなりません。- 戻り値:
- 計算された slog を放出する
Mono
。 - 関連事項:
clusterGetNodeForSlot
指定されたスロットにサービスを提供しているRedisClusterNode
を見つけます。- パラメーター:
slot
-- 戻り値:
- 指定されたスロットを処理する
RedisClusterNode
を放出するMono
。
clusterGetNodeForKey
与えられたキーを提供するRedisClusterNode
を見つけます。- パラメーター:
key
- null であってはなりません。- 戻り値:
- 指定されたキーのスロットを処理する
RedisClusterNode
を発行するMono
。
clusterGetClusterInfo
reactor.core.publisher.Mono<ClusterInfo> clusterGetClusterInfo()クラスター情報を取得します。- 戻り値:
- 決して null にはなりません。
- 関連事項:
clusterAddSlots
指定されたRedisClusterNode
にスロットを割り当てます。- パラメーター:
node
- null であってはなりません。slots
- 空であってはなりません。- 戻り値:
Mono
シグナリングの完了。- 関連事項:
clusterAddSlots
reactor.core.publisher.Mono<VoidSE> clusterAddSlots(RedisClusterNode node, RedisClusterNode.SlotRange range) 指定されたRedisClusterNode
にRedisClusterNode.SlotRange.getSlotsArray()
を割り当てます。- パラメーター:
node
- null であってはなりません。range
- null であってはなりません。- 戻り値:
Mono
シグナリングの完了。- 関連事項:
clusterCountKeysInSlot
1 つのスロットに割り当てられたキーの数を数えます。- パラメーター:
slot
-- 戻り値:
- 指定されたスロットに格納されているキーの数を放出する
Mono
。 - 関連事項:
clusterDeleteSlots
RedisClusterNode
からスロットを取り外します。- パラメーター:
node
- null であってはなりません。- 戻り値:
Mono
シグナリングの完了。- 関連事項:
clusterDeleteSlotsInRange
reactor.core.publisher.Mono<VoidSE> clusterDeleteSlotsInRange(RedisClusterNode node, RedisClusterNode.SlotRange range) 指定されたRedisClusterNode
からRedisClusterNode.SlotRange.getSlotsArray()
を削除します。- パラメーター:
node
- null であってはなりません。range
- null であってはなりません。- 戻り値:
Mono
シグナリングの完了。- 関連事項:
clusterForget
指定されたノードをクラスターから削除します。- パラメーター:
node
- null であってはなりません。- 戻り値:
Mono
シグナリングの完了。- 関連事項:
clusterMeet
指定されたノードをクラスターに追加します。- パラメーター:
node
-host
およびRedisNode.getPort()
を含む必要があり、null であってはなりません。- 戻り値:
Mono
シグナリングの完了。- 関連事項:
clusterSetSlot
reactor.core.publisher.Mono<VoidSE> clusterSetSlot(RedisClusterNode node, int slot, ReactiveClusterCommands.AddSlots mode) - パラメーター:
node
- null であってはなりません。slot
-mode
- null であってはなりません。- 戻り値:
Mono
シグナリングの完了。- 関連事項:
clusterGetKeysInSlot
スロットによって提供されるキーを取得します。- パラメーター:
slot
-count
- null であってはなりません。- 戻り値:
- 指定されたスロットでリクエストされたキーの数を発行する
Flux
、または見つからない場合は完了を通知します。 - 関連事項:
clusterReplicate
reactor.core.publisher.Mono<VoidSE> clusterReplicate(RedisClusterNode master, RedisClusterNode replica) 指定されたマスターにレプリカを割り当てます。- パラメーター:
master
- null であってはなりません。replica
- null であってはなりません。- 戻り値:
Mono
シグナリングの完了。- 関連事項: