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.
|
org.springframework.data.redis.stream |
Modifier and Type | Method and Description |
---|---|
List<StreamOffset<ByteBuffer>> |
ReactiveStreamCommands.ReadCommand.getStreamOffsets() |
Modifier and Type | Method and Description |
---|---|
static ReactiveStreamCommands.ReadCommand |
ReactiveStreamCommands.ReadCommand.from(StreamOffset<ByteBuffer>... streamOffsets)
Creates a new
ReactiveStreamCommands.ReadCommand given a StreamOffset s. |
static ReactiveStreamCommands.ReadCommand |
ReactiveStreamCommands.ReadCommand.from(StreamOffset<ByteBuffer> streamOffset)
Creates a new
ReactiveStreamCommands.ReadCommand given a StreamOffset . |
default List<ByteRecord> |
RedisStreamCommands.xRead(StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s. |
default List<ByteRecord> |
DefaultedRedisConnection.xRead(StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xRead(StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s. |
List<ByteRecord> |
RedisStreamCommands.xRead(StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s. |
default List<ByteRecord> |
DefaultedRedisConnection.xRead(StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<ByteRecord> |
DefaultStringRedisConnection.xRead(StreamReadOptions readOptions,
StreamOffset<byte[]>... streams) |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xRead(StreamReadOptions readOptions,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s. |
default List<StringRecord> |
StringRedisConnection.xReadAsString(StreamOffset<String>... streams)
Read records from one or more
StreamOffset s. |
default List<StringRecord> |
StringRedisConnection.xReadAsString(StreamOffset<String> stream)
Read records from one or more
StreamOffset s. |
List<StringRecord> |
StringRedisConnection.xReadAsString(StreamReadOptions readOptions,
StreamOffset<String>... streams)
Read records from one or more
StreamOffset s. |
List<StringRecord> |
DefaultStringRedisConnection.xReadAsString(StreamReadOptions readOptions,
StreamOffset<String>... streams) |
default List<StringRecord> |
StringRedisConnection.xReadAsString(StreamReadOptions readOptions,
StreamOffset<String> stream)
Read records from one or more
StreamOffset s. |
default List<ByteRecord> |
RedisStreamCommands.xReadGroup(Consumer consumer,
StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<ByteRecord> |
DefaultedRedisConnection.xReadGroup(Consumer consumer,
StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xReadGroup(Consumer consumer,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
List<ByteRecord> |
RedisStreamCommands.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<ByteRecord> |
DefaultedRedisConnection.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<ByteRecord> |
DefaultStringRedisConnection.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams) |
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. |
default List<StringRecord> |
StringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamOffset<String>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<StringRecord> |
StringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamOffset<String> stream)
Read records from one or more
StreamOffset s using a consumer group. |
List<StringRecord> |
StringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<String>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
List<StringRecord> |
DefaultStringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<String>... streams) |
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 |
---|---|
static <K> StreamOffset<K> |
StreamOffset.create(K stream,
ReadOffset readOffset)
|
static <K> StreamOffset<K> |
StreamOffset.from(Record<K,?> reference)
|
static <K> StreamOffset<K> |
StreamOffset.fromStart(K stream)
|
static <K> StreamOffset<K> |
StreamOffset.latest(K stream)
|
Modifier and Type | Method and Description |
---|---|
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> |
ReactiveStreamOperations.read(Class<V> targetType,
Consumer consumer,
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,
Consumer consumer,
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,
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,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s as ObjectRecord . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.read(Class<V> targetType,
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,
StreamOffset<K> stream)
Read records from a
StreamOffset 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 . |
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 reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(Consumer consumer,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<MapRecord<K,HK,HV>> |
StreamOperations.read(Consumer consumer,
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>> |
StreamOperations.read(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(StreamOffset<K>... streams)
Read records from one or more
StreamOffset s. |
default List<MapRecord<K,HK,HV>> |
StreamOperations.read(StreamOffset<K>... streams)
Read records from one or more
StreamOffset s. |
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(StreamOffset<K> stream)
Read records from a
StreamOffset as ObjectRecord . |
reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s. |
List<MapRecord<K,HK,HV>> |
StreamOperations.read(StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s. |
Modifier and Type | Method and Description |
---|---|
StreamOffset<K> |
StreamMessageListenerContainer.StreamReadRequest.getStreamOffset() |
Modifier and Type | Method and Description |
---|---|
static <K> StreamMessageListenerContainer.StreamReadRequestBuilder<K> |
StreamMessageListenerContainer.StreamReadRequest.builder(StreamOffset<K> offset) |
reactor.core.publisher.Flux<V> |
StreamReceiver.receive(Consumer consumer,
StreamOffset<K> streamOffset)
|
default Subscription |
StreamMessageListenerContainer.receive(Consumer consumer,
StreamOffset<K> streamOffset,
StreamListener<K,V> listener)
Register a new subscription for a Redis Stream.
|
reactor.core.publisher.Flux<V> |
StreamReceiver.receive(StreamOffset<K> streamOffset)
|
default Subscription |
StreamMessageListenerContainer.receive(StreamOffset<K> streamOffset,
StreamListener<K,V> listener)
Register a new subscription for a Redis Stream.
|
reactor.core.publisher.Flux<V> |
StreamReceiver.receiveAutoAck(Consumer consumer,
StreamOffset<K> streamOffset)
|
default Subscription |
StreamMessageListenerContainer.receiveAutoAck(Consumer consumer,
StreamOffset<K> streamOffset,
StreamListener<K,V> listener)
Register a new subscription for a Redis Stream.
|
Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.