インターフェース ReactiveListOperations<K,V>


public interface ReactiveListOperations<K,V>
リストコマンドに対するリアクティブな Redis 操作。

Reactive Streams が null 値の使用を禁止しているため、RedisElementReader.read(ByteBuffer) が特定の要素に対して null を返す場合、Mono<K> または Flux<M> を返すメソッドのストリームは InvalidDataAccessApiUsageException で終了します。

導入:
2.0
作成者:
Mark Paluch, Christoph Strobl, John Blum
関連事項:
  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    reactor.core.publisher.Mono<BooleanSE>
    delete(K key)
    指定されたキーを削除します。
    reactor.core.publisher.Mono<V>
    index(K key, long index)
    key の index フォームリストで要素を取得します。
    reactor.core.publisher.Mono<LongSE>
    indexOf(K key, V value)
    key のリストで指定された値が最初に出現するインデックスを返します。
    reactor.core.publisher.Mono<LongSE>
    lastIndexOf(K key, V value)
    key のリストで指定された値が最後に出現したインデックスを返します。
    reactor.core.publisher.Mono<V>
    leftPop(K key)
    key に保存されているリストの最初の要素を削除して返します。
    reactor.core.publisher.Flux<V>
    leftPop(K key, long count)
    key に格納されている Redis リストの左側から countSE 要素を削除します。
    reactor.core.publisher.Mono<V>
    leftPop(K key, DurationSE timeout)
    key に格納されているリストから最初の要素を削除して返します。
    reactor.core.publisher.Mono<LongSE>
    leftPush(K key, V value)
    value を key の前に追加します。
    reactor.core.publisher.Mono<LongSE>
    leftPush(K key, V pivot, V value)
    pivot の前に value を key に挿入します。
    reactor.core.publisher.Mono<LongSE>
    leftPushAll(K key, CollectionSE<V> values)
    values を key の前に追加します。
    reactor.core.publisher.Mono<LongSE>
    leftPushAll(K key, V... values)
    values を key の前に追加します。
    reactor.core.publisher.Mono<LongSE>
    leftPushIfPresent(K key, V value)
    リストが存在する場合にのみ、values を key の前に付加します。
    reactor.core.publisher.Mono<V>
    sourceKey に格納されたリストの最初 / 最後の要素 (引数 from に応じてヘッド / テール) をアトミックに 返して削除し、destinationKey に格納されたリストの最初 / 最後の要素 (引数 to に応じてヘッド / テール) に要素をプッシュします。
    reactor.core.publisher.Mono<V>
    move(K sourceKey, ReactiveListCommands.Direction from, K destinationKey, ReactiveListCommands.Direction to, DurationSE timeout)
    sourceKey に格納されたリストの最初 / 最後の要素 (引数 from に応じてヘッド / テール) をアトミックに 返して削除し、destinationKey に格納されたリストの最初 / 最後の要素 (引数 to に応じてヘッド / テール) に要素をプッシュします。
    default reactor.core.publisher.Mono<V>
    sourceKey に格納されたリストの最初 / 最後の要素 (引数 from に応じてヘッド / テール) をアトミックに 返して削除し、destinationKey に格納されたリストの最初 / 最後の要素 (引数 to に応じてヘッド / テール) に要素をプッシュします。
    default reactor.core.publisher.Mono<V>
    sourceKey に格納されたリストの最初 / 最後の要素 (引数 from に応じてヘッド / テール) をアトミックに 返して削除し、destinationKey に格納されたリストの最初 / 最後の要素 (引数 to に応じてヘッド / テール) に要素をプッシュします。
    reactor.core.publisher.Flux<V>
    range(K key, long start, long end)
    key のリストから begin と end の間の要素を取得します。
    reactor.core.publisher.Mono<LongSE>
    remove(K key, long count, ObjectSE value)
    key に格納されているリストから value の最初の count 出現箇所を削除します。
    reactor.core.publisher.Mono<V>
    rightPop(K key)
    key に保存されているリストの最後の要素を削除して返します。
    reactor.core.publisher.Flux<V>
    rightPop(K key, long count)
    key に格納されている Redis リストの右側から countSE 要素を削除します。
    reactor.core.publisher.Mono<V>
    rightPop(K key, DurationSE timeout)
    key に格納されているリストから最後の要素を削除して返します。
    reactor.core.publisher.Mono<V>
    rightPopAndLeftPush(K sourceKey, K destinationKey)
    sourceKey のリストから最後の要素を削除し、それを destinationKey に追加して、その値を返します。
    reactor.core.publisher.Mono<V>
    rightPopAndLeftPush(K sourceKey, K destinationKey, DurationSE timeout)
    srcKey のリストから最後の要素を削除し、それを dstKey に追加してその値を返します。
    要素が利用可能になるか timeout に到達すると、結果が返されます
    reactor.core.publisher.Mono<LongSE>
    rightPush(K key, V value)
    value を key に追加します。
    reactor.core.publisher.Mono<LongSE>
    rightPush(K key, V pivot, V value)
    pivot の後に value を key に挿入します。
    reactor.core.publisher.Mono<LongSE>
    values を key に追加します。
    reactor.core.publisher.Mono<LongSE>
    rightPushAll(K key, V... values)
    values を key に追加します。
    reactor.core.publisher.Mono<LongSE>
    rightPushIfPresent(K key, V value)
    リストが存在する場合にのみ、values を key に追加します。
    reactor.core.publisher.Mono<BooleanSE>
    set(K key, long index, V value)
    value リスト要素を index に設定します。
    reactor.core.publisher.Mono<LongSE>
    size(K key)
    key に保存されているリストのサイズを取得します。
    reactor.core.publisher.Mono<BooleanSE>
    trim(K key, long start, long end)
    key のリストを start と end の間の要素にトリムします。
  • メソッドの詳細

    • range

      reactor.core.publisher.Flux<V> range(K key, long start, long end)
      key のリストから begin と end の間の要素を取得します。
      パラメーター:
      key - null であってはなりません。
      start -
      end -
      戻り値:
      関連事項:
    • trim

      reactor.core.publisher.Mono<BooleanSE> trim(K key, long start, long end)
      key のリストを start と end の間の要素にトリムします。
      パラメーター:
      key - null であってはなりません。
      start -
      end -
      関連事項:
    • size

      reactor.core.publisher.Mono<LongSE> size(K key)
      key に保存されているリストのサイズを取得します。
      パラメーター:
      key - null であってはなりません。
      戻り値:
      関連事項:
    • leftPush

      reactor.core.publisher.Mono<LongSE> leftPush(K key, V value)
      value を key の前に追加します。
      パラメーター:
      key - null であってはなりません。
      value -
      戻り値:
      関連事項:
    • leftPushAll

      reactor.core.publisher.Mono<LongSE> leftPushAll(K key, V... values)
      values を key の前に追加します。
      パラメーター:
      key - null であってはなりません。
      values -
      戻り値:
      関連事項:
    • leftPushAll

      reactor.core.publisher.Mono<LongSE> leftPushAll(K key, CollectionSE<V> values)
      values を key の前に追加します。
      パラメーター:
      key - null であってはなりません。
      values - null であってはなりません。
      戻り値:
      導入:
      1.5
      関連事項:
    • leftPushIfPresent

      reactor.core.publisher.Mono<LongSE> leftPushIfPresent(K key, V value)
      リストが存在する場合にのみ、values を key の前に付加します。
      パラメーター:
      key - null であってはなりません。
      value -
      戻り値:
      関連事項:
    • leftPush

      reactor.core.publisher.Mono<LongSE> leftPush(K key, V pivot, V value)
      pivot の前に value を key に挿入します。
      パラメーター:
      key - null であってはなりません。
      pivot - null であってはなりません。
      value -
      戻り値:
      関連事項:
    • rightPush

      reactor.core.publisher.Mono<LongSE> rightPush(K key, V value)
      value を key に追加します。
      パラメーター:
      key - null であってはなりません。
      value -
      戻り値:
      関連事項:
    • rightPushAll

      reactor.core.publisher.Mono<LongSE> rightPushAll(K key, V... values)
      values を key に追加します。
      パラメーター:
      key - null であってはなりません。
      values -
      戻り値:
      関連事項:
    • rightPushAll

      reactor.core.publisher.Mono<LongSE> rightPushAll(K key, CollectionSE<V> values)
      values を key に追加します。
      パラメーター:
      key - null であってはなりません。
      values -
      戻り値:
      導入:
      1.5
      関連事項:
    • rightPushIfPresent

      reactor.core.publisher.Mono<LongSE> rightPushIfPresent(K key, V value)
      リストが存在する場合にのみ、values を key に追加します。
      パラメーター:
      key - null であってはなりません。
      value -
      戻り値:
      関連事項:
    • rightPush

      reactor.core.publisher.Mono<LongSE> rightPush(K key, V pivot, V value)
      pivot の後に value を key に挿入します。
      パラメーター:
      key - null であってはなりません。
      pivot - null であってはなりません。
      value -
      戻り値:
      関連事項:
    • move

      default reactor.core.publisher.Mono<V> move(ListOperations.MoveFrom<K> from, ListOperations.MoveTo<K> to)
      sourceKey に格納されたリストの最初 / 最後の要素 (引数 from に応じてヘッド / テール) をアトミックに 返して削除し、destinationKey に格納されたリストの最初 / 最後の要素 (引数 to に応じてヘッド / テール) に要素をプッシュします。
      パラメーター:
      from - null であってはなりません。
      to - null であってはなりません。
      戻り値:
      導入:
      2.6
      関連事項:
    • move

      reactor.core.publisher.Mono<V> move(K sourceKey, ReactiveListCommands.Direction from, K destinationKey, ReactiveListCommands.Direction to)
      sourceKey に格納されたリストの最初 / 最後の要素 (引数 from に応じてヘッド / テール) をアトミックに 返して削除し、destinationKey に格納されたリストの最初 / 最後の要素 (引数 to に応じてヘッド / テール) に要素をプッシュします。
      パラメーター:
      sourceKey - null であってはなりません。
      from - null であってはなりません。
      destinationKey - null であってはなりません。
      to - null であってはなりません。
      戻り値:
      導入:
      2.6
      関連事項:
    • move

      default reactor.core.publisher.Mono<V> move(ListOperations.MoveFrom<K> from, ListOperations.MoveTo<K> to, DurationSE timeout)
      sourceKey に格納されたリストの最初 / 最後の要素 (引数 from に応じてヘッド / テール) をアトミックに 返して削除し、destinationKey に格納されたリストの最初 / 最後の要素 (引数 to に応じてヘッド / テール) に要素をプッシュします。

      要素が使用可能になるか、timeout に達するまで、 接続をブロックします。

      パラメーター:
      from - null であってはなりません。
      to - null であってはなりません。
      timeout -
      戻り値:
      導入:
      2.6
      関連事項:
    • move

      reactor.core.publisher.Mono<V> move(K sourceKey, ReactiveListCommands.Direction from, K destinationKey, ReactiveListCommands.Direction to, DurationSE timeout)
      sourceKey に格納されたリストの最初 / 最後の要素 (引数 from に応じてヘッド / テール) をアトミックに 返して削除し、destinationKey に格納されたリストの最初 / 最後の要素 (引数 to に応じてヘッド / テール) に要素をプッシュします。

      要素が使用可能になるか、timeout に達するまで、 接続をブロックします。

      パラメーター:
      sourceKey - null であってはなりません。
      from - null であってはなりません。
      destinationKey - null であってはなりません。
      to - null であってはなりません。
      timeout -
      戻り値:
      パイプライン / トランザクションで使用される場合は null。
      導入:
      2.6
      関連事項:
    • set

      reactor.core.publisher.Mono<BooleanSE> set(K key, long index, V value)
      value リスト要素を index に設定します。
      パラメーター:
      key - null であってはなりません。
      index -
      value -
      関連事項:
    • remove

      reactor.core.publisher.Mono<LongSE> remove(K key, long count, ObjectSE value)
      key に格納されているリストから value の最初の count 出現箇所を削除します。
      パラメーター:
      key - null であってはなりません。
      count -
      value -
      戻り値:
      関連事項:
    • index

      reactor.core.publisher.Mono<V> index(K key, long index)
      key の index フォームリストで要素を取得します。
      パラメーター:
      key - null であってはなりません。
      index -
      戻り値:
      関連事項:
    • indexOf

      reactor.core.publisher.Mono<LongSE> indexOf(K key, V value)
      key のリスト内で指定された値が最初に出現するインデックスを返します。
      Redis 6.0.6 以降が必要です。
      パラメーター:
      key - null であってはなりません。
      value - null であってはなりません。
      戻り値:
      導入:
      2.4
      関連事項:
    • lastIndexOf

      reactor.core.publisher.Mono<LongSE> lastIndexOf(K key, V value)
      key のリストで、指定された値が最後に出現するインデックスを返します。
      Redis 6.0.6 以降が必要です。
      パラメーター:
      key - null であってはなりません。
      value - null であってはなりません。
      戻り値:
      導入:
      2.4
      関連事項:
    • leftPop

      reactor.core.publisher.Mono<V> leftPop(K key)
      key に保存されているリストの最初の要素を削除して返します。
      パラメーター:
      key - null であってはなりません。
      戻り値:
      関連事項:
    • leftPop

      reactor.core.publisher.Flux<V> leftPop(K key, long count)
      key に格納されている Redis リストの左側から countSE 要素を削除します。
      パラメーター:
      key - null であってはなりません。
      count - Redis リストの左側から削除する要素の数の countSE
      戻り値:
      Redis リストから削除された要素を含む Flux
      導入:
      3.2
      関連事項:
    • leftPop

      reactor.core.publisher.Mono<V> leftPop(K key, DurationSE timeout)
      key に格納されているリストから最初の要素を削除して返します。
      要素が利用可能になるか timeout に到達すると、結果が返されます
      パラメーター:
      key - null であってはなりません。
      timeout - key のリスト内のエントリが利用可能になるまで待機する最大期間。Duration.ZEROSE 以上 {@link 1 second} である必要があり、null であってはなりません。ゼロのタイムアウトを使用すると、無期限に待機できます。0 ~ 1 秒の期間はサポートされていません。
      戻り値:
      関連事項:
    • rightPop

      reactor.core.publisher.Mono<V> rightPop(K key)
      key に保存されているリストの最後の要素を削除して返します。
      パラメーター:
      key - null であってはなりません。
      戻り値:
      関連事項:
    • rightPop

      reactor.core.publisher.Flux<V> rightPop(K key, long count)
      key に格納されている Redis リストの右側から countSE 要素を削除します。
      パラメーター:
      key - null であってはなりません。
      count - Redis リストの右側から削除する要素の数の countSE
      戻り値:
      Redis リストから削除された要素を含む Flux
      導入:
      3.2
      関連事項:
    • rightPop

      reactor.core.publisher.Mono<V> rightPop(K key, DurationSE timeout)
      key に格納されているリストから最後の要素を削除して返します。
      要素が利用可能になるか timeout に到達すると、結果が返されます
      パラメーター:
      key - null であってはなりません。
      timeout - key のリスト内のエントリが利用可能になるまで待機する最大期間。Duration.ZEROSE 以上 {@link 1 second} である必要があり、null であってはなりません。ゼロのタイムアウトを使用すると、無期限に待機できます。0 ~ 1 秒の期間はサポートされていません。
      戻り値:
      関連事項:
    • rightPopAndLeftPush

      reactor.core.publisher.Mono<V> rightPopAndLeftPush(K sourceKey, K destinationKey)
      sourceKey のリストから最後の要素を削除し、それを destinationKey に追加して、その値を返します。
      パラメーター:
      sourceKey - null であってはなりません。
      destinationKey - null であってはなりません。
      戻り値:
      関連事項:
    • rightPopAndLeftPush

      reactor.core.publisher.Mono<V> rightPopAndLeftPush(K sourceKey, K destinationKey, DurationSE timeout)
      srcKey のリストから最後の要素を削除し、それを dstKey に追加してその値を返します。
      要素が利用可能になるか timeout に到達すると、結果が返されます
      パラメーター:
      sourceKey - null であってはなりません。
      destinationKey - null であってはなりません。
      timeout - sourceKey のリスト内のエントリが利用可能になるまで待機する最大期間。Duration.ZEROSE 以上 {@link 1 second} である必要があり、null であってはなりません。ゼロのタイムアウトを使用すると、無期限に待機できます。0 ~ 1 秒の期間はサポートされていません。
      戻り値:
      関連事項:
    • delete

      reactor.core.publisher.Mono<BooleanSE> delete(K key)
      指定されたキーを削除します。
      パラメーター:
      key - null であってはなりません。