パッケージ org.springframework.data.redis.core

インターフェース BoundStreamOperations<K,HK,HV>

public interface BoundStreamOperations<K,HK,HV>
Redis は、特定のキーにバインドされた特定の操作をストリームします。
導入:
2.2
作成者:
Mark Paluch, Christoph Strobl, Dengliming

  • メソッドの詳細

    • acknowledge

      @Nullable LongSE acknowledge(StringSE group, StringSE... recordIds)
      1 つ以上のレコードを処理済みとして確認します。
      パラメーター:
      group - コンシューマーグループの名前。
      recordIds - 確認する ID を記録します。
      戻り値:
      確認済みレコードの長さ。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • add

      @Nullable RecordId add(MapSE<HK,HV> body)
      ストリーム key にレコードを追加します。
      パラメーター:
      body - レコード本文。
      戻り値:
      レコード ID。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • delete

      @Nullable LongSE delete(StringSE... recordIds)
      指定されたエントリをストリームから削除します。削除されたアイテムの数を返します。特定の ID が存在しない場合に渡される ID の数とは異なる場合があります。
      パラメーター:
      recordIds - ストリームレコード ID。
      戻り値:
      削除されたエントリの数。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • createGroup

      @Nullable StringSE createGroup(ReadOffset readOffset, StringSE group)
      コンシューマーグループを作成します。
      パラメーター:
      readOffset -
      group - コンシューマーグループの名前。
      戻り値:
      成功した場合は true。パイプライン / トランザクションで使用される場合は null。

    • deleteConsumer

      @Nullable BooleanSE deleteConsumer(Consumer consumer)
      コンシューマーグループからコンシューマーを削除します。
      パラメーター:
      consumer - グループ名とコンシューマーキーで識別されるコンシューマー。
      戻り値:
      成功した場合は true。パイプライン / トランザクションで使用される場合は null。

    • destroyGroup

      @Nullable BooleanSE destroyGroup(StringSE group)
      コンシューマーグループを破棄します。
      パラメーター:
      group - コンシューマーグループの名前。
      戻り値:
      成功した場合は true。パイプライン / トランザクションで使用される場合は null。

    • size

      @Nullable LongSE size()
      ストリームの長さを取得します。
      戻り値:
      ストリームの長さ。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • range

      @Nullable default ListSE<MapRecord<K,HK,HV>> range(Range<StringSE> range)
      特定の Range 内のストリームからレコードを読み取ります。
      パラメーター:
      range - null であってはなりません。
      戻り値:
      結果のストリームのメンバーをリストします。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • range

      @Nullable ListSE<MapRecord<K,HK,HV>> range(Range<StringSE> range, Limit limit)
      Limit を適用して、特定の Range 内のストリームからレコードを読み取ります。
      パラメーター:
      range - null であってはなりません。
      limit - null であってはなりません。
      戻り値:
      結果のストリームのメンバーをリストします。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • read

      @Nullable default ListSE<MapRecord<K,HK,HV>> read(ReadOffset readOffset)
      ReadOffset からレコードを読み取ります。
      パラメーター:
      readOffset - 読み取るオフセット。
      戻り値:
      結果のストリームのメンバーをリストします。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • read

      @Nullable ListSE<MapRecord<K,HK,HV>> read(StreamReadOptions readOptions, ReadOffset readOffset)
      ReadOffset から始まるレコードを読み取ります。
      パラメーター:
      readOptions - 引数を読み取ります。
      readOffset - 読み取るオフセット。
      戻り値:
      結果のストリームのメンバーをリストします。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • read

      @Nullable default ListSE<MapRecord<K,HK,HV>> read(Consumer consumer, ReadOffset readOffset)
      ReadOffset から始まるレコードを読み取ります。コンシューマーグループを使用します。
      パラメーター:
      consumer - コンシューマー / グループ。
      readOffset - 読み取るオフセット。
      戻り値:
      結果のストリームのメンバーをリストします。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • read

      @Nullable ListSE<MapRecord<K,HK,HV>> read(Consumer consumer, StreamReadOptions readOptions, ReadOffset readOffset)
      ReadOffset から始まるレコードを読み取ります。コンシューマーグループを使用します。
      パラメーター:
      consumer - コンシューマー / グループ。
      readOptions - 引数を読み取ります。
      readOffset - 読み取るオフセット。
      戻り値:
      結果のストリームのメンバーをリストします。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • reverseRange

      @Nullable default ListSE<MapRecord<K,HK,HV>> reverseRange(Range<StringSE> range)
      特定の Range 内のストリームからレコードを逆の順序で読み取ります。
      パラメーター:
      range - null であってはなりません。
      戻り値:
      結果のストリームのメンバーをリストします。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • reverseRange

      @Nullable ListSE<MapRecord<K,HK,HV>> reverseRange(Range<StringSE> range, Limit limit)
      Limit を逆の順序で適用して、特定の Range 内のストリームからレコードを読み取ります。
      パラメーター:
      range - null であってはなりません。
      limit - null であってはなりません。
      戻り値:
      結果のストリームのメンバーをリストします。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • trim

      @Nullable LongSE trim(long count)
      ストリームを count 要素にトリミングします。
      パラメーター:
      count - ストリームの長さ。
      戻り値:
      削除されたエントリの数。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • trim

      @Nullable LongSE trim(long count, boolean approximateTrimming)
      ストリームを count 要素にトリミングします。
      パラメーター:
      count - ストリームの長さ。
      approximateTrimming - パフォーマンスを最大化するには、おおよその方法でトリミングを実行する必要があります。
      戻り値:
      削除されたエントリの数。パイプライン / トランザクションで使用される場合は null。
      導入:
      2.4
      関連事項: