Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
|
org.springframework.data.redis.connection.stream |
Data structures and interfaces to interact with Redis Streams.
|
org.springframework.data.redis.core |
Core package for integrating Redis with Spring concepts.
|
Modifier and Type | Method and Description |
---|---|
StreamReadOptions |
ReactiveStreamCommands.ReadCommand.getReadOptions() |
Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.ReadCommand |
ReactiveStreamCommands.ReadCommand.withOptions(StreamReadOptions options)
Applies the given
StreamReadOptions . |
List<ByteRecord> |
DefaultStringRedisConnection.xRead(StreamReadOptions readOptions,
StreamOffset<byte[]>... streams) |
default List<ByteRecord> |
DefaultedRedisConnection.xRead(StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<ByteRecord> |
RedisStreamCommands.xRead(StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xRead(StreamReadOptions readOptions,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s. |
List<StringRecord> |
DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions,
StreamOffset<String>... streams) |
List<StringRecord> |
StringRedisConnection.xReadAsString(StreamReadOptions readOptions,
StreamOffset<String>... streams)
Read records from one or more
StreamOffset s. |
default List<StringRecord> |
StringRedisConnection.xReadAsString(StreamReadOptions readOptions,
StreamOffset<String> stream)
Read records from one or more
StreamOffset s. |
List<ByteRecord> |
DefaultStringRedisConnection.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams) |
default List<ByteRecord> |
DefaultedRedisConnection.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<ByteRecord> |
RedisStreamCommands.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
List<StringRecord> |
DefaultStringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<String>... streams) |
List<StringRecord> |
StringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<String>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<StringRecord> |
StringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<String> stream)
Read records from one or more
StreamOffset s using a consumer group. |
Constructor and Description |
---|
ReadCommand(List<StreamOffset<ByteBuffer>> streamOffsets,
StreamReadOptions readOptions,
Consumer consumer) |
Modifier and Type | Method and Description |
---|---|
StreamReadOptions |
StreamReadOptions.autoAcknowledge()
Enable auto-acknowledgement by setting the
NOACK flag when reading in the context of a consumer group. |
StreamReadOptions |
StreamReadOptions.block(Duration timeout)
Use a blocking read and supply the
timeout after which the call will terminate if no message was
read. |
StreamReadOptions |
StreamReadOptions.count(long count)
Limit the number of messages returned per stream.
|
static StreamReadOptions |
StreamReadOptions.empty()
Creates an empty
StreamReadOptions instance. |
StreamReadOptions |
StreamReadOptions.noack()
Enable auto-acknowledgement by setting the
NOACK flag when reading in the context of a consumer group. |
Modifier and Type | Method and Description |
---|---|
default <V> List<ObjectRecord<K,V>> |
StreamOperations.read(Class<V> targetType,
Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group as ObjectRecord . |
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> |
ReactiveStreamOperations.read(Class<V> targetType,
Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group as ObjectRecord . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.read(Class<V> targetType,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s as ObjectRecord . |
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> |
ReactiveStreamOperations.read(Class<V> targetType,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s as ObjectRecord . |
List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(Consumer consumer,
StreamReadOptions readOptions,
ReadOffset readOffset)
Read records starting from
ReadOffset . using a consumer group. |
List<MapRecord<K,HK,HV>> |
StreamOperations.read(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(StreamReadOptions readOptions,
ReadOffset readOffset)
Read records starting from
ReadOffset . |
List<MapRecord<K,HK,HV>> |
StreamOperations.read(StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s. |
reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s. |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.