インターフェース RedisStreamCommands

既知のすべてのサブインターフェース:
DefaultedRedisClusterConnection, DefaultedRedisConnection, RedisClusterConnection, RedisCommands, RedisConnection, RedisConnectionUtils.RedisConnectionProxy, StringRedisConnection
すべての既知の実装クラス:
AbstractRedisConnection, DefaultStringRedisConnection, JedisClusterConnection, JedisConnection, LettuceClusterConnection, LettuceConnection
@NullUnmarked public interface RedisStreamCommands
ストリーム固有の Redis コマンド。
導入:
2.2
作成者:
Mark Paluch, Christoph Strobl, Tugdual Grall, Dengliming, Mark John Moreno, Jeonggyu Choi
関連事項:

  • メソッドの詳細

    • xAck

      default LongSE xAck(byte @NonNull [] key, @NonNull StringSE group, @NonNull StringSE @NonNull ... recordIds)
      ID で識別された 1 つ以上のレコードを処理済みとして確認します。
      パラメーター:
      key - ストリームが保存されているキー。
      group - コンシューマーグループの名前。
      recordIds - 確認するレコードの ID の文字列表現。
      戻り値:
      確認応答されたメッセージの長さ。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • xAck

      LongSE xAck(byte @NonNull [] key, @NonNull StringSE group, @NonNull RecordId @NonNull ... recordIds)
      ID で識別された 1 つ以上のレコードを処理済みとして確認します。
      パラメーター:
      key - ストリームが保存されているキー。
      group - コンシューマーグループの名前。
      recordIds - 確認するレコードの ID。
      戻り値:
      確認応答されたメッセージの長さ。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • xAdd

      default RecordId xAdd(byte @NonNull [] key, @NonNull MapSE<byte @NonNull [], byte @NonNull []> content)
      指定された field/value pairsSE をコンテンツとして含む新しいレコードを key に保存されているストリームに追加します。
      パラメーター:
      key - ストリームが保存されているキー。
      content - field/value pairsSE としてモデル化されたレコードコンテンツ。
      戻り値:
      サーバーは id を生成しました。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • xAdd

      default RecordId xAdd(@NonNull MapRecord<byte[],byte[],byte[]> record)
      指定された record を Record#getStream に保存されているストリームに追加します。サーバーで生成されたものよりも手動で ID を割り当てる場合は、Record#withId を介して ID を指定してください。
      パラメーター:
      record - 追加する record。
      戻り値:
      保存後の id。パイプライン / トランザクションで使用される場合は null。

    • xAdd

      RecordId xAdd(MapRecord<byte[],byte[],byte[]> record, @NonNull RedisStreamCommands.XAddOptions options)
      指定された record を Record#getStream に保存されているストリームに追加します。サーバーで生成されたものよりも手動で ID を割り当てる場合は、Record#withId を介して ID を指定してください。
      パラメーター:
      record - 追加する record。
      options - 追加オプション（例: MAXLEN）。null であってはならず、代わりに RedisStreamCommands.XAddOptions.none() を使用してください。
      戻り値:
      保存後の id。パイプライン / トランザクションで使用される場合は null。
      導入:
      2.3

    • xClaimJustId

      ListSE<@NonNull RecordId> xClaimJustId(byte @NonNull [] key, @NonNull StringSE group, @NonNull StringSE newOwner, @NonNull RedisStreamCommands.XClaimOptions options)
      配信数を増やすことなく、指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。
      パラメーター:
      key - ストリームが保存されているキー。
      group - コンシューマーグループの名前。
      newOwner - 新しいコンシューマーの名前。
      options - null であってはなりません。
      戻り値:
      ユーザーを変更した ids のリスト。
      導入:
      2.3
      関連事項:

    • xClaim

      default ListSE<@NonNull ByteRecord> xClaim(byte @NonNull [] key, @NonNull StringSE group, @NonNull StringSE newOwner, @NonNull DurationSE minIdleTime, @NonNull RecordId @NonNull ... recordIds)
      指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。
      パラメーター:
      key - ストリームが保存されているキー。
      group - コンシューマーグループの名前。
      newOwner - 新しいコンシューマーの名前。
      minIdleTime - null であってはなりません。
      recordIds - null であってはなりません。
      戻り値:
      ユーザーを変更した ByteRecord のリスト。
      導入:
      2.3
      関連事項:

    • xClaim

      ListSE<@NonNull ByteRecord> xClaim(byte @NonNull [] key, @NonNull StringSE group, @NonNull StringSE newOwner, @NonNull RedisStreamCommands.XClaimOptions options)
      指定された新しいコンシューマーへの保留中のメッセージの所有権を変更します。
      パラメーター:
      key - ストリームが保存されているキー。
      group - コンシューマーグループの名前。
      newOwner - 新しいコンシューマーの名前。
      options - null であってはなりません。
      戻り値:
      ユーザーを変更した ByteRecord のリスト。
      導入:
      2.3
      関連事項:

    • xDel

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

    • xDel

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

    • xGroupCreate

      StringSE xGroupCreate(byte @NonNull [] key, @NonNull StringSE groupName, @NonNull ReadOffset readOffset)
      コンシューマーグループを作成します。
      パラメーター:
      key - ストリームが保存されているキー。
      groupName - 作成するコンシューマーグループの名前。
      readOffset - 開始するオフセット。
      戻り値:
      成功すれば大丈夫。パイプライン / トランザクションで使用される場合は null。

    • xGroupCreate

      StringSE xGroupCreate(byte @NonNull [] key, @NonNull StringSE groupName, @NonNull ReadOffset readOffset, boolean mkStream)
      コンシューマーグループを作成します。
      パラメーター:
      key - ストリームが保存されているキー。
      groupName - 作成するコンシューマーグループの名前。
      readOffset - 開始するオフセット。
      mkStream - true の場合、グループはまだ存在しない場合はストリームを作成します (MKSTREAM)
      戻り値:
      成功すれば大丈夫。パイプライン / トランザクションで使用される場合は null。
      導入:
      2.3

    • xGroupDelConsumer

      default BooleanSE xGroupDelConsumer(byte @NonNull [] key, @NonNull StringSE groupName, @NonNull StringSE consumerName)
      コンシューマーグループからコンシューマーを削除します。
      パラメーター:
      key - ストリームが保存されているキー。
      groupName - コンシューマーを削除するグループの名前。
      consumerName - グループから削除するコンシューマーの名前。
      戻り値:
      成功した場合は true。パイプライン / トランザクションで使用される場合は null。

    • xGroupDelConsumer

      BooleanSE xGroupDelConsumer(byte @NonNull [] key, @NonNull Consumer consumer)
      コンシューマーグループからコンシューマーを削除します。
      パラメーター:
      key - ストリームが保存されているキー。
      consumer - グループ名とコンシューマー名で識別されるコンシューマー。
      戻り値:
      成功した場合は true。パイプライン / トランザクションで使用される場合は null。

    • xGroupDestroy

      BooleanSE xGroupDestroy(byte @NonNull [] key, @NonNull StringSE groupName)
      コンシューマーグループを破棄します。
      パラメーター:
      key - ストリームが保存されているキー。
      groupName - コンシューマーグループの名前。
      戻り値:
      成功した場合は true。パイプライン / トランザクションで使用される場合は null。

    • xInfo

      StreamInfo.XInfoStream xInfo(byte @NonNull [] key)
      指定されたキーに保存されているストリームに関する一般情報を取得します。
      パラメーター:
      key - ストリームが保存されているキー。
      戻り値:
      パイプライン / トランザクションで使用される場合は null。
      導入:
      2.3

    • xInfoGroups

      StreamInfo.XInfoGroups xInfoGroups(byte @NonNull [] key)
      指定されたキーに格納されているストリームに関連付けられているコンシューマーグループに関する情報を取得します。
      パラメーター:
      key - ストリームが保存されているキー。
      戻り値:
      パイプライン / トランザクションで使用される場合は null。
      導入:
      2.3

    • xInfoConsumers

      StreamInfo.XInfoConsumers xInfoConsumers(byte @NonNull [] key, @NonNull StringSE groupName)
      指定されたキーに格納されているストリームの特定のコンシューマーグループ内のすべてのコンシューマーに関する情報を取得します。
      パラメーター:
      key - ストリームが保存されているキー。
      groupName - コンシューマーグループの名前。
      戻り値:
      パイプライン / トランザクションで使用される場合は null。
      導入:
      2.3

    • xLen

      LongSE xLen(byte @NonNull [] key)
      ストリームの長さを取得します。
      パラメーター:
      key - ストリームが保存されているキー。
      戻り値:
      ストリームの長さ。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • xPending

      @Nullable PendingMessagesSummary xPending(byte @NonNull [] key, @NonNull StringSE groupName)
      特定のコンシューマーグループの PendingMessagesSummary を取得します。
      パラメーター:
      key - ストリームが保存されているキー。null であってはなりません。
      groupName - コンシューマーグループの名前。null であってはなりません。
      戻り値:
      指定されたコンシューマーグループ内の保留中のメッセージの要約、またはパイプライン / トランザクションで使用される場合は null。
      導入:
      2.3
      関連事項:

    • xPending

      default PendingMessages xPending(byte @NonNull [] key, @NonNull Consumer consumer)
      特定の Consumer のすべての保留中のメッセージに関する詳細情報を取得しました。
      パラメーター:
      key - ストリームが保存されているキー。null であってはなりません。
      consumer - PendingMessages をフェッチするコンシューマー。null であってはなりません。
      戻り値:
      指定された Consumer の保留中のメッセージ、またはパイプライン / トランザクションで使用される場合は null。
      導入:
      2.3
      関連事項:

    • xPending

      default PendingMessages xPending(byte @NonNull [] key, @NonNull StringSE groupName, @NonNull StringSE consumerName)
      特定のコンシューマーのすべての保留中のメッセージに関する詳細情報を取得しました。
      パラメーター:
      key - ストリームが保存されているキー。null であってはなりません。
      groupName - コンシューマーグループの名前。null であってはなりません。
      consumerName - PendingMessages をフェッチするコンシューマー。null であってはなりません。
      戻り値:
      指定された Consumer の保留中のメッセージ、またはパイプライン / トランザクションで使用される場合は null。
      導入:
      2.3
      関連事項:

    • xPending

      default PendingMessages xPending(byte @NonNull [] key, @NonNull StringSE groupName, @NonNull Range<?> range, @NonNull LongSE count)
      コンシューマーグループ内の特定の Range の保留中の messages に関する詳細情報を取得します。
      パラメーター:
      key - ストリームが保存されているキー。null であってはなりません。
      groupName - コンシューマーグループの名前。null であってはなりません。
      range - 検索するメッセージ ID の範囲。null であってはなりません。
      count - 結果の数を制限します。null であってはなりません。
      戻り値:
      指定されたコンシューマーグループの保留中のメッセージ、またはパイプライン / トランザクションで使用される場合は null。
      導入:
      2.3
      関連事項:

    • xPending

      default PendingMessages xPending(byte[] key, StringSE groupName, Range<?> range, LongSE count, DurationSE idle)
      コンシューマーグループ内の特定の Range および特定の DurationSE のアイドル時間にわたって保留中の messages に関する詳細情報を取得します。
      パラメーター:
      key - ストリームが保存されているキー。null であってはなりません。
      groupName - コンシューマーグループの名前。null であってはなりません。
      range - 検索するメッセージ ID の範囲。null であってはなりません。
      count - 結果の数を制限します。null であってはなりません。
      idle - 保留中のメッセージをフィルタリングするための最小アイドル時間。null にすることはできません。
      戻り値:
      指定されたコンシューマーグループの保留中のメッセージ、またはパイプライン / トランザクションで使用される場合は null。
      導入:
      4.0
      関連事項:

    • xPending

      default PendingMessages xPending(byte @NonNull [] key, @NonNull Consumer consumer, @NonNull Range<?> range, @NonNull LongSE count)
      コンシューマーグループ内の特定の Range および Consumer の保留中の messages に関する詳細情報を取得します。
      パラメーター:
      key - ストリームが保存されているキー。null であってはなりません。
      consumer - Consumer の名前。null であってはなりません。
      range - 検索するメッセージ ID の範囲。null であってはなりません。
      count - 結果の数を制限します。null であってはなりません。
      戻り値:
      指定された Consumer の保留中のメッセージ、またはパイプライン / トランザクションで使用される場合は null。
      導入:
      2.3
      関連事項:

    • xPending

      default PendingMessages xPending(byte[] key, Consumer consumer, Range<?> range, LongSE count, DurationSE minIdleTime)
      コンシューマーグループ内の特定の Range および Consumer と、特定の DurationSE のアイドル時間にわたって保留中の messages に関する詳細情報を取得します。
      パラメーター:
      key - ストリームが保存されているキー。null であってはなりません。
      consumer - Consumer の名前。null であってはなりません。
      range - 検索するメッセージ ID の範囲。null であってはなりません。
      count - 結果の数を制限します。null であってはなりません。
      minIdleTime - 保留中のメッセージをフィルタリングするための最小アイドル時間。null にすることはできません。
      戻り値:
      指定された Consumer の保留中のメッセージ、またはパイプライン / トランザクションで使用される場合は null。
      導入:
      4.0
      関連事項:

    • xPending

      default PendingMessages xPending(byte @NonNull [] key, @NonNull StringSE groupName, @NonNull StringSE consumerName, @NonNull Range<?> range, @NonNull LongSE count)
      特定の Range およびコンシューマーグループ内のコンシューマーの保留中の messages に関する詳細情報を取得します。
      パラメーター:
      key - ストリームが保存されているキー。null であってはなりません。
      groupName - コンシューマーグループの名前。null であってはなりません。
      consumerName - コンシューマーの名前。null であってはなりません。
      range - 検索するメッセージ ID の範囲。null であってはなりません。
      count - 結果の数を制限します。null であってはなりません。
      戻り値:
      特定のコンシューマーグループ内の特定のコンシューマーに対する保留中のメッセージ、またはパイプライン / トランザクションで使用される場合は null。
      導入:
      2.3
      関連事項:

    • xPending

      default PendingMessages xPending(byte[] key, StringSE groupName, StringSE consumerName, Range<?> range, LongSE count, DurationSE idle)
      特定の Range およびコンシューマーグループ内の特定のコンシューマーと、特定の DurationSE のアイドル時間にわたって保留中の messages に関する詳細情報を取得します。
      パラメーター:
      key - ストリームが保存されているキー。null であってはなりません。
      groupName - コンシューマーグループの名前。null であってはなりません。
      consumerName - コンシューマーの名前。null であってはなりません。
      range - 検索するメッセージ ID の範囲。null であってはなりません。
      count - 結果の数を制限します。null であってはなりません。
      idle - 保留中のメッセージをフィルタリングするための最小アイドル時間。null にすることはできません。
      戻り値:
      特定のコンシューマーグループ内の特定のコンシューマーに対する保留中のメッセージ、またはパイプライン / トランザクションで使用される場合は null。
      導入:
      4.0
      関連事項:

    • xPending

      PendingMessages xPending(byte @NonNull [] key, @NonNull StringSE groupName, @NonNull RedisStreamCommands.XPendingOptions options)
      指定された options を適用する保留中の messages に関する詳細情報を取得します。
      パラメーター:
      key - ストリームが保存されているキー。null であってはなりません。
      groupName - コンシューマーグループの名前。null であってはなりません。
      options - 範囲、コンシューマー、カウントを含むオプション。null であってはなりません。
      戻り値:
      指定された条件に一致する保留中のメッセージ、またはパイプライン / トランザクションで使用される場合は null。
      導入:
      2.3
      関連事項:

    • xRange

      default ListSE<@NonNull ByteRecord> xRange(byte @NonNull [] key, @NonNull Range<@NonNull StringSE> range)
      キーに格納されているストリームから、特定の Range 内のすべての records を取得します。
      Range.unbounded() を使用して、可能な最小および最大 ID から読み取ります。
      パラメーター:
      key - ストリームが保存されているキー。
      range - null であってはなりません。
      戻り値:
      パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • xRange

      ListSE<@NonNull ByteRecord> xRange(byte @NonNull [] key, @NonNull Range<@NonNull StringSE> range, @NonNull Limit limit)
      キーに格納されているストリームから、特定の Range 内の records の limited number を取得します。
      Range.unbounded() を使用して、可能な最小 ID と最大 ID から読み取ります。
      すべてのレコードを読み取るには、Limit.unlimited() を使用します。
      パラメーター:
      key - ストリームが保存されているキー。
      range - null であってはなりません。
      limit - null であってはなりません。
      戻り値:
      パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • xRead

      default ListSE<@NonNull ByteRecord> xRead(StreamOffset<byte @NonNull []> @NonNull ... streams)
      1 つ以上の StreamOffset からレコードを読み取ります。
      パラメーター:
      streams - 読み取るストリーム。
      戻り値:
      パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • xRead

      ListSE<@NonNull ByteRecord> xRead(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<byte[]> @NonNull ... streams)
      1 つ以上の StreamOffset からレコードを読み取ります。
      パラメーター:
      readOptions - 引数を読み取ります。
      streams - 読み取るストリーム。
      戻り値:
      パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • xReadGroup

      default ListSE<@NonNull ByteRecord> xReadGroup(@NonNull Consumer consumer, @NonNull StreamOffset<byte[]> @NonNull ... streams)
      コンシューマーグループを使用して、1 つ以上の StreamOffset からレコードを読み取ります。
      パラメーター:
      consumer - コンシューマー / グループ。
      streams - 読み取るストリーム。
      戻り値:
      結果のストリームのメンバーをリストします。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • xReadGroup

      ListSE<@NonNull ByteRecord> xReadGroup(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<byte[]> @NonNull ... streams)
      コンシューマーグループを使用して、1 つ以上の StreamOffset からレコードを読み取ります。
      パラメーター:
      consumer - コンシューマー / グループ。
      readOptions - 引数を読み取ります。
      streams - 読み取るストリーム。
      戻り値:
      結果のストリームのメンバーをリストします。パイプライン / トランザクションで使用される場合は null。
      関連事項:

    • xRevRange

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

    • xRevRange

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

    • xTrim

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

    • xTrim

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