クラスの使用
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 Flux<ByteBufferRecord> ReactiveStreamCommands.xRead(StreamOffset<ByteBufferSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default Flux<ByteBufferRecord> ReactiveStreamCommands.xRead(StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。ListSE<@NonNull ByteRecord> RedisStreamCommands.xRead(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<byte[]> @NonNull... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<@NonNull ByteRecord> RedisStreamCommands.xRead(StreamOffset<byte @NonNull[]> @NonNull... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions, StreamOffset<StringSE>... streams) default ListSE<StringRecord> StringRedisConnection.xReadAsString(@NonNull StreamOffset<StringSE> stream) 1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<StringRecord> StringRedisConnection.xReadAsString(@NonNull StreamOffset<StringSE>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<StringRecord> StringRedisConnection.xReadAsString(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<StringSE> stream) 1 つ以上のStreamOffsetからレコードを読み取ります。StringRedisConnection.xReadAsString(@NonNull StreamReadOptions readOptions, @NonNull 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 Flux<ByteBufferRecord> ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamOffset<ByteBufferSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default Flux<ByteBufferRecord> ReactiveStreamCommands.xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBufferSE>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<@NonNull ByteRecord> RedisStreamCommands.xReadGroup(@NonNull Consumer consumer, @NonNull StreamOffset<byte[]> @NonNull... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。ListSE<@NonNull ByteRecord> RedisStreamCommands.xReadGroup(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<byte[]> @NonNull... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。DefaultStringRedisConnection.xReadGroupAsString(Consumer consumer, StreamReadOptions readOptions, StreamOffset<StringSE>... streams) default ListSE<StringRecord> StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamOffset<StringSE> stream) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<StringRecord> StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamOffset<StringSE> @NonNull... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default ListSE<StringRecord> StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<StringSE> stream) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。StringRedisConnection.xReadGroupAsString(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<StringSE> @NonNull... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。型の型引数を持つ org.springframework.data.redis.connection のコンストラクターパラメーター StreamOffset修飾子コンストラクター説明ReadCommand(ListSE<StreamOffset<ByteBufferSE>> streamOffsets, @Nullable StreamReadOptions readOptions, @Nullable 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> Flux<ObjectRecord<K, V>> ReactiveStreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull Consumer consumer, @NonNull StreamOffset<K> @NonNull... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> Flux<ObjectRecord<K, V>> ReactiveStreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> Flux<ObjectRecord<K, V>> ReactiveStreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull StreamOffset<K> stream) StreamOffsetからのレコードをObjectRecordとして読み取ります。default <V> Flux<ObjectRecord<K, V>> ReactiveStreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull StreamOffset<K>... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。default <V> Flux<ObjectRecord<K, V>> ReactiveStreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。ReactiveStreamOperations.read(@NonNull Consumer consumer, @NonNull StreamOffset<K> @NonNull... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。ReactiveStreamOperations.read(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K>... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。ReactiveStreamOperations.read(@NonNull StreamOffset<K> stream) StreamOffsetからのレコードをObjectRecordとして読み取ります。ReactiveStreamOperations.read(@NonNull StreamOffset<K>... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。ReactiveStreamOperations.read(@NonNull StreamReadOptions readOptions, @NonNull StreamOffset<K> @NonNull... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。default <V> ListSE<ObjectRecord<K, V>> StreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> ListSE<ObjectRecord<K, V>> StreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull Consumer consumer, StreamOffset<@NonNull K> @NonNull... streams) コンシューマーグループをObjectRecordとして使用して、1 つ以上のStreamOffsetからレコードを読み取ります。default <V> ListSE<@NonNull ObjectRecord<K, V>> StreamOperations.read(@NonNull ClassSE<V> targetType, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。default <V> ListSE<@NonNull ObjectRecord<K, V>> StreamOperations.read(@NonNull ClassSE<V> targetType, StreamOffset<@NonNull K> @NonNull... streams) 1 つ以上のStreamOffsetからのレコードをObjectRecordとして読み取ります。StreamOperations.read(@NonNull Consumer consumer, @NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。StreamOperations.read(@NonNull Consumer consumer, StreamOffset<@NonNull K> @NonNull... streams) コンシューマーグループを使用して、1 つ以上のStreamOffsetからレコードを読み取ります。StreamOperations.read(@NonNull StreamReadOptions readOptions, StreamOffset<@NonNull K> @NonNull... streams) 1 つ以上のStreamOffsetからレコードを読み取ります。StreamOperations.read(StreamOffset<@NonNull K> @NonNull... 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 ストリームの新しいサブスクリプションを登録します。StreamReceiver.receive(Consumer consumer, StreamOffset<K> streamOffset) StreamReceiver.receive(StreamOffset<K> streamOffset) default SubscriptionStreamMessageListenerContainer.receiveAutoAck(Consumer consumer, StreamOffset<K> streamOffset, StreamListener<K, V> listener) Redis ストリームの新しいサブスクリプションを登録します。StreamReceiver.receiveAutoAck(Consumer consumer, StreamOffset<K> streamOffset)
RedisCommandsProvider.streamCommands()を推奨。