クラスの使用
org.springframework.data.redis.connection.stream.StreamOffset
StreamOffset を使用するパッケージ
パッケージ
説明
さまざまな Redis ' ドライバー '/libraries と対話するための低レベルの抽象化を提供する接続パッケージ。
Redis ストリームと対話するためのデータ構造とインターフェース。
Redis を Spring の概念と統合するためのコアパッケージ。
org.springframework.data.redis.connection 内の StreamOffset 使用
型 StreamOffset の引数を持つ型を返す org.springframework.data.redis.connection のメソッド型 StreamOffset のパラメーターを持つ org.springframework.data.redis.connection のメソッド修飾子と型メソッド説明ReactiveStreamCommands.ReadCommand.from(StreamOffset<ByteBufferSE> streamOffset) StreamOffsetを指定して新しいReactiveStreamCommands.ReadCommandを作成します。ReactiveStreamCommands.ReadCommand.from(StreamOffset<ByteBufferSE>... streamOffsets) StreamOffsetを指定して、新しいReactiveStreamCommands.ReadCommandを作成します。default ListSE<ByteRecord>DefaultedRedisConnection.xRead(StreamOffset<byte[]>... streams) 使用すべきではありません。default ListSE<ByteRecord>DefaultedRedisConnection.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) 使用すべきではありません。DefaultStringRedisConnection.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) default reactor.core.publisher.Flux<ByteBufferRecord>ReactiveStreamCommands.xRead(StreamOffset<ByteBufferSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default reactor.core.publisher.Flux<ByteBufferRecord>ReactiveStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<ByteRecord>RedisStreamCommands.xRead(StreamOffset<byte[]>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。RedisStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<StringSE>... streams) default ListSE<StringRecord>StringRedisConnection.xReadAsString(StreamOffset<StringSE> stream) 1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<StringRecord>StringRedisConnection.xReadAsString(StreamOffset<StringSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<StringRecord>StringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<StringSE> stream) 1 つ以上のStreamOffsetからレコードを読み取ります。StringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<StringSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<ByteRecord>DefaultedRedisConnection.xReadGroup(Consumer consumer, StreamOffset<byte[]>... streams) 使用すべきではありません。default ListSE<ByteRecord>DefaultedRedisConnection.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) 使用すべきではありません。DefaultStringRedisConnection.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) default reactor.core.publisher.Flux<ByteBufferRecord>ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamOffset<ByteBufferSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default reactor.core.publisher.Flux<ByteBufferRecord>ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<ByteRecord>RedisStreamCommands.xReadGroup(Consumer consumer, StreamOffset<byte[]>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。RedisStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。DefaultStringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<StringSE>... streams) default ListSE<StringRecord>StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamOffset<StringSE> stream) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<StringRecord>StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamOffset<StringSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<StringRecord>StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<StringSE> stream) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。StringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<StringSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。型の型引数を持つ org.springframework.data.redis.connection のコンストラクターパラメーター StreamOffset修飾子コンストラクター説明ReadCommand(ListSE<StreamOffset<ByteBufferSE>> streamOffsets, StreamReadOptions readOptions, Consumer consumer) org.springframework.data.redis.connection.stream 内の StreamOffset 使用
修飾子と型メソッド説明static <K> StreamOffset<K>StreamOffset.create(K stream, ReadOffset readOffset) static <K> StreamOffset<K>static <K> StreamOffset<K>StreamOffset.fromStart(K stream) static <K> StreamOffset<K>StreamOffset.latest(K stream) org.springframework.data.redis.core 内の StreamOffset 使用
型 StreamOffset のパラメーターを持つ org.springframework.data.redis.core のメソッド修飾子と型メソッド説明default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> ReactiveStreamOperations.read(ClassSE<V> targetType, Consumer consumer, StreamOffset<K>... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> ReactiveStreamOperations.read(ClassSE<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> ReactiveStreamOperations.read(ClassSE<V> targetType, StreamOffset<K> stream) StreamOffsetからのレコードをObjectRecordとして読み取ります。default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> ReactiveStreamOperations.read(ClassSE<V> targetType, StreamOffset<K>... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> ReactiveStreamOperations.read(ClassSE<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。ReactiveStreamOperations.read(Consumer consumer, StreamOffset<K>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。ReactiveStreamOperations.read(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。ReactiveStreamOperations.read(StreamOffset<K> stream) StreamOffsetからのレコードをObjectRecordとして読み取ります。ReactiveStreamOperations.read(StreamOffset<K>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。ReactiveStreamOperations.read(StreamReadOptions readOptions, StreamOffset<K>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default <V> ListSE<ObjectRecord<K,V>> StreamOperations.read(ClassSE<V> targetType, Consumer consumer, StreamOffset<K>... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> ListSE<ObjectRecord<K,V>> StreamOperations.read(ClassSE<V> targetType, Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> ListSE<ObjectRecord<K,V>> StreamOperations.read(ClassSE<V> targetType, StreamOffset<K>... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。default <V> ListSE<ObjectRecord<K,V>> StreamOperations.read(ClassSE<V> targetType, StreamReadOptions readOptions, StreamOffset<K>... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。StreamOperations.read(Consumer consumer, StreamOffset<K>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。StreamOperations.read(Consumer consumer, StreamReadOptions readOptions, StreamOffset<K>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。StreamOperations.read(StreamOffset<K>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。StreamOperations.read(StreamReadOptions readOptions, StreamOffset<K>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。org.springframework.data.redis.stream 内の StreamOffset 使用
型 StreamOffset のパラメーターを持つ org.springframework.data.redis.stream のメソッド修飾子と型メソッド説明static <K> StreamMessageListenerContainer.StreamReadRequestBuilder<K>StreamMessageListenerContainer.StreamReadRequest.builder(StreamOffset<K> offset) default SubscriptionStreamMessageListenerContainer.receive(Consumer consumer, StreamOffset<K> streamOffset, StreamListener<K, V> listener) Redis ストリームの新しいサブスクリプションを登録します。default SubscriptionStreamMessageListenerContainer.receive(StreamOffset<K> streamOffset, StreamListener<K, V> listener) Redis ストリームの新しいサブスクリプションを登録します。reactor.core.publisher.Flux<V>StreamReceiver.receive(Consumer consumer, StreamOffset<K> streamOffset) reactor.core.publisher.Flux<V>StreamReceiver.receive(StreamOffset<K> streamOffset) default SubscriptionStreamMessageListenerContainer.receiveAutoAck(Consumer consumer, StreamOffset<K> streamOffset, StreamListener<K, V> listener) Redis ストリームの新しいサブスクリプションを登録します。reactor.core.publisher.Flux<V>StreamReceiver.receiveAutoAck(Consumer consumer, StreamOffset<K> streamOffset)
RedisCommandsProvider.streamCommands()を推奨。