クラスの使用
org.springframework.data.redis.connection.stream.ReadOffset
ReadOffset を使用するパッケージ
パッケージ
説明
さまざまな Redis ' ドライバー '/libraries と対話するための低レベルの抽象化を提供する接続パッケージ。
Redis ストリームと対話するためのデータ構造とインターフェース。
Redis を Spring の概念と統合するためのコアパッケージ。
org.springframework.data.redis.connection 内の ReadOffset 使用
型 ReadOffset のパラメーターを持つ org.springframework.data.redis.connection のメソッド修飾子と型メソッド説明ReactiveStreamCommands.GroupCommand.at(ReadOffset offset) default StringSEDefaultedRedisConnection.xGroupCreate(byte[] key, StringSE groupName, ReadOffset readOffset) 使用すべきではありません。default StringSEDefaultedRedisConnection.xGroupCreate(byte[] key, StringSE groupName, ReadOffset readOffset, boolean mkStream) 使用すべきではありません。DefaultStringRedisConnection.xGroupCreate(byte[] key, StringSE groupName, ReadOffset readOffset) DefaultStringRedisConnection.xGroupCreate(byte[] key, StringSE groupName, ReadOffset readOffset, boolean mkStream) DefaultStringRedisConnection.xGroupCreate(StringSE key, ReadOffset readOffset, StringSE group) DefaultStringRedisConnection.xGroupCreate(StringSE key, ReadOffset readOffset, StringSE group, boolean mkStream) ReactiveStreamCommands.xGroupCreate(ByteBufferSE key, StringSE groupName, ReadOffset readOffset) コンシューマーグループを作成します。ReactiveStreamCommands.xGroupCreate(ByteBufferSE key, StringSE groupName, ReadOffset readOffset, boolean mkStream) コンシューマーグループを作成します。RedisStreamCommands.xGroupCreate(byte @NonNull[] key, @NonNull StringSE groupName, @NonNull ReadOffset readOffset) コンシューマーグループを作成します。RedisStreamCommands.xGroupCreate(byte @NonNull[] key, @NonNull StringSE groupName, @NonNull ReadOffset readOffset, boolean mkStream) コンシューマーグループを作成します。StringRedisConnection.xGroupCreate(@NonNull StringSE key, @NonNull ReadOffset readOffset, @NonNull StringSE group) コンシューマーグループを作成します。StringRedisConnection.xGroupCreate(@NonNull StringSE key, @NonNull ReadOffset readOffset, @NonNull StringSE group, boolean mkStream) コンシューマーグループを作成します。型 ReadOffset のパラメーターを持つ org.springframework.data.redis.connection のコンストラクター修飾子コンストラクター説明GroupCommand(@Nullable ByteBufferSE key, ReactiveStreamCommands.GroupCommand.GroupCommandAction action, @Nullable StringSE groupName, @Nullable StringSE consumerName, @Nullable ReadOffset offset) GroupCommand(@Nullable ByteBufferSE key, ReactiveStreamCommands.GroupCommand.GroupCommandAction action, @Nullable StringSE groupName, @Nullable StringSE consumerName, @Nullable ReadOffset offset, boolean mkStream) org.springframework.data.redis.connection.stream 内の ReadOffset 使用
修飾子と型メソッド説明static ReadOffsetoffsetから始まるストリームから到着するすべての要素を読み取ります。static ReadOffsetRecordIdで始まるストリームから到着するすべての要素を読み取ります。StreamOffset.getOffset()static ReadOffsetReadOffset.lastConsumed()コンシューマーグループによって消費された最後の要素よりも大きい ID を持つすべての新着要素を読み取ります。static ReadOffsetReadOffset.latest()最新のオフセットから読み取ります。型 ReadOffset のパラメーターを持つ org.springframework.data.redis.connection.stream のメソッドorg.springframework.data.redis.core 内の ReadOffset 使用
型 ReadOffset のパラメーターを持つ org.springframework.data.redis.core のメソッド修飾子と型メソッド説明BoundStreamOperations.createGroup(@NonNull ReadOffset readOffset, @NonNull StringSE group) コンシューマーグループを作成します。ReactiveStreamOperations.createGroup(@NonNull K key, @NonNull ReadOffset readOffset, @NonNull StringSE group) コンシューマーグループを作成します。StreamOperations.createGroup(@NonNull K key, @NonNull ReadOffset readOffset, @NonNull StringSE group) コンシューマーグループを作成します。BoundStreamOperations.read(@NonNull Consumer consumer, @NonNull ReadOffset readOffset) ReadOffsetから始まるレコードを読み取ります。コンシューマーグループを使用します。BoundStreamOperations.read(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull ReadOffset readOffset) ReadOffsetから始まるレコードを読み取ります。コンシューマーグループを使用します。BoundStreamOperations.read(@NonNull ReadOffset readOffset) ReadOffsetからレコードを読み取ります。BoundStreamOperations.read(@NonNull StreamReadOptions readOptions, @NonNull ReadOffset readOffset) ReadOffsetから始まるレコードを読み取ります。
RedisCommandsProvider.streamCommands()を推奨。