インターフェース ReactiveSetCommands
- 既知のすべてのサブインターフェース:
ReactiveClusterSetCommands
public interface ReactiveSetCommands
Redis リアクティブインフラストラクチャを使用して実行されるコマンドを設定します。
- 導入:
- 2.0
- 作成者:
- Christoph Strobl, Mark Paluch
ネストされたクラスの概要
ネストされたクラス修飾子と型インターフェース説明static classSADDコマンドパラメーター。static classSDIFFコマンドパラメーター。static classSDIFFSTOREコマンドパラメーター。static classSINTERコマンドパラメーター。static classSINTERSTOREコマンドパラメーター。static classSISMEMBERコマンドパラメーター。static classSMISMEMBERコマンドパラメーター。static classSMOVEコマンドパラメーター。static classSPOPコマンドパラメーター。static classSRANDMEMBERコマンドパラメーター。static classSREMコマンドパラメーター。static classSUNIONコマンドパラメーター。static classSUNIONSTOREコマンドパラメーター。方法の概要
修飾子と型メソッド説明default reactor.core.publisher.Mono<LongSE>sAdd(ByteBufferSE key, ByteBufferSE value) 与えられた値を加算してキーに設定します。default reactor.core.publisher.Mono<LongSE>sAdd(ByteBufferSE key, CollectionSE<ByteBufferSE> values) キーに設定するために与えられた値を追加します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,LongSE>> sAdd(org.reactivestreams.Publisher<ReactiveSetCommands.SAddCommand> commands) default reactor.core.publisher.Mono<LongSE>sCard(ByteBufferSE key) キーでセットのサイズを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> sCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) セットのサイズをReactiveRedisConnection.KeyCommand.getKey()で取得します。default reactor.core.publisher.Flux<ByteBufferSE>sDiff(CollectionSE<ByteBufferSE> keys) キーで指定されたすべてのセットのメンバーの差分を返します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SDiffCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sDiff(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffCommand> commands) ReactiveSetCommands.SInterCommand.getKeys()で指定されたすべてのセットのメンバーの差分を返します。default reactor.core.publisher.Mono<LongSE>sDiffStore(ByteBufferSE destinationKey, CollectionSE<ByteBufferSE> keys) 指定されたすべてのセットをキーで比較し、結果を destinationKey に保存します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,LongSE>> sDiffStore(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffStoreCommand> commands) 指定されたすべてのセットをキーで比較し、結果を destinationKey に保存します。default reactor.core.publisher.Flux<ByteBufferSE>sInter(CollectionSE<ByteBufferSE> keys) キーで指定されたすべてのセットと交差するメンバーを返します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SInterCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sInter(org.reactivestreams.Publisher<ReactiveSetCommands.SInterCommand> commands) ReactiveSetCommands.SInterCommand.getKeys()で指定されたすべてのセットと交差するメンバーを返します。default reactor.core.publisher.Mono<LongSE>sInterStore(ByteBufferSE destinationKey, CollectionSE<ByteBufferSE> keys) 指定されたすべてのセットをキーで交差させ、結果を destinationKey に保存します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,LongSE>> sInterStore(org.reactivestreams.Publisher<ReactiveSetCommands.SInterStoreCommand> commands) 指定されたすべてのセットをキーで交差させ、結果を destinationKey に保存します。default reactor.core.publisher.Mono<BooleanSE>sIsMember(ByteBufferSE key, ByteBufferSE value) キーに設定されている値に値が含まれているか確認してください。reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SIsMemberCommand>>sIsMember(org.reactivestreams.Publisher<ReactiveSetCommands.SIsMemberCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に設定されているものにReactiveSetCommands.SIsMemberCommand.getValue()が含まれているかどうかを確認します。default reactor.core.publisher.Flux<ByteBufferSE>sMembers(ByteBufferSE key) キーでセットのすべての要素を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sMembers(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()でセットのすべての要素を取得します。sMIsMember(ByteBufferSE key, ListSE<ByteBufferSE> values) keyに設定されているものに 1 つ以上のvaluesが含まれているかどうかを確認します。reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SMIsMemberCommand,BooleanSE>> sMIsMember(org.reactivestreams.Publisher<ReactiveSetCommands.SMIsMemberCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に設定されているものにReactiveSetCommands.SMIsMemberCommand.getValues()が含まれているかどうかを確認します。default reactor.core.publisher.Mono<BooleanSE>sMove(ByteBufferSE sourceKey, ByteBufferSE destinationKey, ByteBufferSE value) sourceKey から destinationKey に値を移動するreactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SMoveCommand>>sMove(org.reactivestreams.Publisher<ReactiveSetCommands.SMoveCommand> commands) default reactor.core.publisher.Mono<ByteBufferSE>sPop(ByteBufferSE key) キーのセットからランダムなメンバーを削除して返します。default reactor.core.publisher.Flux<ByteBufferSE>sPop(ByteBufferSE key, long count) keyのセットからcountランダムメンバーを削除して返します。reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>sPop(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のセットからランダムなメンバーを削除して返しますreactor.core.publisher.Flux<ByteBufferSE>sPop(ReactiveSetCommands.SPopCommand command) キーのセットからランダムなメンバーを削除して返します。default reactor.core.publisher.Mono<ByteBufferSE>sRandMember(ByteBufferSE key) キーのセットからランダムな要素を取得します。default reactor.core.publisher.Flux<ByteBufferSE>sRandMember(ByteBufferSE key, LongSE count) キーのセットからランダムな要素の数を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sRandMember(org.reactivestreams.Publisher<ReactiveSetCommands.SRandMembersCommand> commands) default reactor.core.publisher.Mono<LongSE>sRem(ByteBufferSE key, ByteBufferSE value) キーのセットから指定された値を削除し、削除された要素の数を返します。default reactor.core.publisher.Mono<LongSE>sRem(ByteBufferSE key, CollectionSE<ByteBufferSE> values) キーのセットから指定された値を削除し、削除された要素の数を返します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,LongSE>> sRem(org.reactivestreams.Publisher<ReactiveSetCommands.SRemCommand> commands) 指定されたReactiveSetCommands.SRemCommand.getValues()をReactiveRedisConnection.KeyCommand.getKey()のセットから削除します。default reactor.core.publisher.Flux<ByteBufferSE>sScan(ByteBufferSE key) Fluxを使用して、keyのセット内のメンバーを反復処理します。default reactor.core.publisher.Flux<ByteBufferSE>sScan(ByteBufferSE key, ScanOptions options) reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Fluxを使用して、keyのセット内のメンバーを反復処理します。default reactor.core.publisher.Flux<ByteBufferSE>sUnion(CollectionSE<ByteBufferSE> keys) キーで指定されたすべてのセットと交差するメンバーを返します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SUnionCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sUnion(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionCommand> commands) ReactiveSetCommands.SInterCommand.getKeys()で指定されたすべてのセットと交差するメンバーを返します。default reactor.core.publisher.Mono<LongSE>sUnionStore(ByteBufferSE destinationKey, CollectionSE<ByteBufferSE> keys) 指定されたすべてのセットをキーで結合し、結果を destinationKey に格納します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,LongSE>> sUnionStore(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionStoreCommand> commands) 指定されたすべてのセットをキーで結合し、結果を destinationKey に格納します。
方法の詳細
sAdd
与えられた値を加算してキーに設定します。- パラメーター:
key- null であってはなりません。value- null であってはなりません。- 戻り値:
- 関連事項:
sAdd
default reactor.core.publisher.Mono<LongSE> sAdd(ByteBufferSE key, CollectionSE<ByteBufferSE> values) キーに設定するために与えられた値を追加します。- パラメーター:
key- null であってはなりません。values- null であってはなりません。- 戻り値:
- 関連事項:
sAdd
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,LongSE>> sAdd(org.reactivestreams.Publisher<ReactiveSetCommands.SAddCommand> commands) 指定されたReactiveSetCommands.SAddCommand.getValues()を追加してReactiveRedisConnection.KeyCommand.getKey()に設定します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sRem
キーのセットから指定された値を削除し、削除された要素の数を返します。- パラメーター:
key- null であってはなりません。value- null であってはなりません。- 戻り値:
- 関連事項:
sRem
default reactor.core.publisher.Mono<LongSE> sRem(ByteBufferSE key, CollectionSE<ByteBufferSE> values) キーのセットから指定された値を削除し、削除された要素の数を返します。- パラメーター:
key- null であってはなりません。values- null であってはなりません。- 戻り値:
- 関連事項:
sRem
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,LongSE>> sRem(org.reactivestreams.Publisher<ReactiveSetCommands.SRemCommand> commands) 指定されたReactiveSetCommands.SRemCommand.getValues()をReactiveRedisConnection.KeyCommand.getKey()のセットから削除します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sPop
キーのセットからランダムなメンバーを削除して返します。- パラメーター:
key- null であってはなりません。- 戻り値:
- 関連事項:
sPop
keyのセットからcountランダムメンバーを削除して返します。- パラメーター:
key- null であってはなりません。count- セットからポップするランダムメンバーの数。- 戻り値:
- 関連事項:
sPop
キーのセットからランダムなメンバーを削除して返します。- パラメーター:
command- null であってはなりません。- 戻り値:
- 関連事項:
sPop
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>> sPop(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のセットからランダムなメンバーを削除して返します- パラメーター:
commands-- 戻り値:
- 関連事項:
sMove
default reactor.core.publisher.Mono<BooleanSE> sMove(ByteBufferSE sourceKey, ByteBufferSE destinationKey, ByteBufferSE value) sourceKey から destinationKey に値を移動する- パラメーター:
sourceKey- null であってはなりません。destinationKey- null であってはなりません。value- null であってはなりません。- 戻り値:
- 関連事項:
sMove
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SMoveCommand>> sMove(org.reactivestreams.Publisher<ReactiveSetCommands.SMoveCommand> commands) ReactiveSetCommands.SMoveCommand.getValue()をReactiveRedisConnection.KeyCommand.getKey()からReactiveSetCommands.SMoveCommand.getDestination()に移動します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sCard
キーでセットのサイズを取得します。- パラメーター:
key- null であってはなりません。- 戻り値:
- 関連事項:
sCard
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> sCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) セットのサイズをReactiveRedisConnection.KeyCommand.getKey()で取得します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sIsMember
キーに設定されている値に値が含まれているか確認してください。- パラメーター:
key- null であってはなりません。value- null であってはなりません。- 戻り値:
- 関連事項:
sIsMember
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SIsMemberCommand>> sIsMember(org.reactivestreams.Publisher<ReactiveSetCommands.SIsMemberCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に設定されているものにReactiveSetCommands.SIsMemberCommand.getValue()が含まれているかどうかを確認します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sMIsMember
default reactor.core.publisher.Mono<ListSE<BooleanSE>> sMIsMember(ByteBufferSE key, ListSE<ByteBufferSE> values) keyに設定されているものに 1 つ以上のvaluesが含まれているかどうかを確認します。- パラメーター:
key- null であってはなりません。values- null であってはなりません。- 戻り値:
- パイプライン / トランザクションで使用される場合は null。
- 導入:
- 2.6
- 関連事項:
sMIsMember
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SMIsMemberCommand,BooleanSE>> sMIsMember(org.reactivestreams.Publisher<ReactiveSetCommands.SMIsMemberCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に設定されているものにReactiveSetCommands.SMIsMemberCommand.getValues()が含まれているかどうかを確認します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 導入:
- 2.6
- 関連事項:
sInter
キーで指定されたすべてのセットと交差するメンバーを返します。- パラメーター:
keys- null であってはなりません。- 戻り値:
- 関連事項:
sInter
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SInterCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sInter(org.reactivestreams.Publisher<ReactiveSetCommands.SInterCommand> commands) ReactiveSetCommands.SInterCommand.getKeys()で指定されたすべてのセットと交差するメンバーを返します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sInterStore
default reactor.core.publisher.Mono<LongSE> sInterStore(ByteBufferSE destinationKey, CollectionSE<ByteBufferSE> keys) 指定されたすべてのセットをキーで交差させ、結果を destinationKey に保存します。- パラメーター:
destinationKey- null であってはなりません。keys- null であってはなりません。- 戻り値:
- destinationKey に格納されたセットのサイズ。
- 関連事項:
sInterStore
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,LongSE>> sInterStore(org.reactivestreams.Publisher<ReactiveSetCommands.SInterStoreCommand> commands) 指定されたすべてのセットをキーで交差させ、結果を destinationKey に保存します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sUnion
キーで指定されたすべてのセットと交差するメンバーを返します。- パラメーター:
keys- null であってはなりません。- 戻り値:
- 関連事項:
sUnion
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SUnionCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sUnion(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionCommand> commands) ReactiveSetCommands.SInterCommand.getKeys()で指定されたすべてのセットと交差するメンバーを返します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sUnionStore
default reactor.core.publisher.Mono<LongSE> sUnionStore(ByteBufferSE destinationKey, CollectionSE<ByteBufferSE> keys) 指定されたすべてのセットをキーで結合し、結果を destinationKey に格納します。- パラメーター:
destinationKey- null であってはなりません。keys- null であってはなりません。- 戻り値:
- destinationKey に格納されたセットのサイズ。
- 関連事項:
sUnionStore
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,LongSE>> sUnionStore(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionStoreCommand> commands) 指定されたすべてのセットをキーで結合し、結果を destinationKey に格納します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sDiff
キーで指定されたすべてのセットのメンバーの差分を返します。- パラメーター:
keys- null であってはなりません。- 戻り値:
- 関連事項:
sDiff
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SDiffCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sDiff(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffCommand> commands) ReactiveSetCommands.SInterCommand.getKeys()で指定されたすべてのセットのメンバーの差分を返します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sDiffStore
default reactor.core.publisher.Mono<LongSE> sDiffStore(ByteBufferSE destinationKey, CollectionSE<ByteBufferSE> keys) 指定されたすべてのセットをキーで比較し、結果を destinationKey に保存します。- パラメーター:
destinationKey- null であってはなりません。keys- null であってはなりません。- 戻り値:
- destinationKey に格納されたセットのサイズ。
- 関連事項:
sDiffStore
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,LongSE>> sDiffStore(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffStoreCommand> commands) 指定されたすべてのセットをキーで比較し、結果を destinationKey に保存します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sMembers
キーでセットのすべての要素を取得します。- パラメーター:
key- null であってはなりません。- 戻り値:
- 関連事項:
sMembers
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sMembers(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()でセットのすべての要素を取得します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
sScan
Fluxを使用して、keyのセット内のメンバーを反復処理します。結果のFluxはカーソルとして機能し、サブスクライバーが要求を通知する限り、SSCANコマンド自体を発行します。- パラメーター:
key- null であってはなりません。- 戻り値:
Fluxは生のmembersSE を 1 つずつ放出します。- 例外:
IllegalArgumentExceptionSE- オプションが null の場合。- 導入:
- 2.1
- 関連事項:
sScan
Fluxを使用して、ScanOptionsが指定されたkeyのセット内のメンバーを反復処理します。結果のFluxはカーソルとして機能し、サブスクライバーが要求を通知する限り、SSCANコマンド自体を発行します。- パラメーター:
key- null であってはなりません。options- null であってはなりません。代わりにScanOptions.NONEを使用してください。- 戻り値:
Fluxは生のmembersSE を 1 つずつ放出します。- 例外:
IllegalArgumentExceptionSE- 必要な引数の 1 つが null の場合。- 導入:
- 2.1
- 関連事項:
sScan
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands) Fluxを使用して、keyのセット内のメンバーを反復処理します。結果のFluxはカーソルとして機能し、サブスクライバーが要求を通知する限り、SSCANコマンド自体を発行します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 導入:
- 2.1
- 関連事項:
sRandMember
キーのセットからランダムな要素を取得します。- パラメーター:
key- null であってはなりません。- 戻り値:
- 関連事項:
sRandMember
キーのセットからランダムな要素の数を取得します。- パラメーター:
key- null であってはなりません。count- null であってはなりません。- 戻り値:
- 関連事項:
sRandMember
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,reactor.core.publisher.Flux<ByteBufferSE>>> sRandMember(org.reactivestreams.Publisher<ReactiveSetCommands.SRandMembersCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のセットからReactiveSetCommands.SRandMembersCommand.getCount()ランダム要素を取得します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項: