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 |
---|---|
ReadOffset |
ReactiveStreamCommands.GroupCommand.getReadOffset() |
Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.GroupCommand |
ReactiveStreamCommands.GroupCommand.at(ReadOffset offset) |
String |
DefaultStringRedisConnection.xGroupCreate(byte[] key,
String groupName,
ReadOffset readOffset) |
default String |
DefaultedRedisConnection.xGroupCreate(byte[] key,
String groupName,
ReadOffset readOffset)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
String |
RedisStreamCommands.xGroupCreate(byte[] key,
String groupName,
ReadOffset readOffset)
Create a consumer group.
|
String |
DefaultStringRedisConnection.xGroupCreate(byte[] key,
String groupName,
ReadOffset readOffset,
boolean mkStream) |
default String |
DefaultedRedisConnection.xGroupCreate(byte[] key,
String groupName,
ReadOffset readOffset,
boolean mkStream)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
String |
RedisStreamCommands.xGroupCreate(byte[] key,
String groupName,
ReadOffset readOffset,
boolean mkStream)
Create a consumer group.
|
default reactor.core.publisher.Mono<String> |
ReactiveStreamCommands.xGroupCreate(ByteBuffer key,
String groupName,
ReadOffset readOffset)
Create a consumer group.
|
default reactor.core.publisher.Mono<String> |
ReactiveStreamCommands.xGroupCreate(ByteBuffer key,
String groupName,
ReadOffset readOffset,
boolean mkStream)
Create a consumer group.
|
String |
DefaultStringRedisConnection.xGroupCreate(String key,
ReadOffset readOffset,
String group) |
String |
StringRedisConnection.xGroupCreate(String key,
ReadOffset readOffset,
String group)
Create a consumer group.
|
String |
DefaultStringRedisConnection.xGroupCreate(String key,
ReadOffset readOffset,
String group,
boolean mkStream) |
String |
StringRedisConnection.xGroupCreate(String key,
ReadOffset readOffset,
String group,
boolean mkStream)
Create a consumer group.
|
Constructor and Description |
---|
GroupCommand(ByteBuffer key,
ReactiveStreamCommands.GroupCommand.GroupCommandAction action,
String groupName,
String consumerName,
ReadOffset offset) |
GroupCommand(ByteBuffer key,
ReactiveStreamCommands.GroupCommand.GroupCommandAction action,
String groupName,
String consumerName,
ReadOffset offset,
boolean mkStream) |
Modifier and Type | Method and Description |
---|---|
static ReadOffset |
ReadOffset.from(RecordId offset)
Read all arriving elements from the stream starting at
RecordId . |
static ReadOffset |
ReadOffset.from(String offset)
Read all arriving elements from the stream starting at
offset . |
ReadOffset |
StreamOffset.getOffset() |
static ReadOffset |
ReadOffset.lastConsumed()
Read all new arriving elements with ids greater than the last one consumed by the consumer group.
|
static ReadOffset |
ReadOffset.latest()
Read from the latest offset.
|
Modifier and Type | Method and Description |
---|---|
static <K> StreamOffset<K> |
StreamOffset.create(K stream,
ReadOffset readOffset)
|
Modifier and Type | Method and Description |
---|---|
String |
StreamOperations.createGroup(K key,
ReadOffset readOffset,
String group)
Create a consumer group.
|
reactor.core.publisher.Mono<String> |
ReactiveStreamOperations.createGroup(K key,
ReadOffset readOffset,
String group)
Create a consumer group.
|
String |
BoundStreamOperations.createGroup(ReadOffset readOffset,
String group)
Create a consumer group.
|
default List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(Consumer consumer,
ReadOffset readOffset)
Read records starting from
ReadOffset . using a consumer group. |
List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(Consumer consumer,
StreamReadOptions readOptions,
ReadOffset readOffset)
Read records starting from
ReadOffset . using a consumer group. |
default List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(ReadOffset readOffset)
Read records from
ReadOffset . |
List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(StreamReadOptions readOptions,
ReadOffset readOffset)
Read records starting from
ReadOffset . |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.