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.
|
Modifier and Type | Method and Description |
---|---|
default List<StringRecord> |
StringRedisConnection.xClaim(String key,
String group,
String newOwner,
Duration minIdleTime,
RecordId... recordIds)
Change the ownership of a pending message to the given new consumer.
|
List<StringRecord> |
DefaultStringRedisConnection.xClaim(String key,
String group,
String consumer,
RedisStreamCommands.XClaimOptions options) |
List<StringRecord> |
StringRedisConnection.xClaim(String key,
String group,
String newOwner,
RedisStreamCommands.XClaimOptions options)
Change the ownership of a pending message to the given new consumer.
|
default List<StringRecord> |
StringRedisConnection.xRange(String key,
Range<String> range)
Read records from a stream within a specific
Range . |
List<StringRecord> |
DefaultStringRedisConnection.xRange(String key,
Range<String> range,
RedisZSetCommands.Limit limit) |
List<StringRecord> |
StringRedisConnection.xRange(String key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a Limit . |
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> |
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. |
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> |
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. |
default List<StringRecord> |
StringRedisConnection.xRevRange(String key,
Range<String> range)
Read records from a stream within a specific
Range in reverse order. |
List<StringRecord> |
DefaultStringRedisConnection.xRevRange(String key,
Range<String> range,
RedisZSetCommands.Limit limit) |
List<StringRecord> |
StringRedisConnection.xRevRange(String key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a Limit in reverse order. |
Modifier and Type | Method and Description |
---|---|
default RecordId |
StringRedisConnection.xAdd(StringRecord record)
Append the given
StringRecord to the stream stored at Record.getStream() . |
RecordId |
DefaultStringRedisConnection.xAdd(StringRecord record,
RedisStreamCommands.XAddOptions options) |
RecordId |
StringRedisConnection.xAdd(StringRecord record,
RedisStreamCommands.XAddOptions options)
Append the given
StringRecord to the stream stored at Record.getStream() . |
Modifier and Type | Method and Description |
---|---|
static StringRecord |
StringRecord.of(MapRecord<String,String,String> source)
|
StringRecord |
StreamRecords.RecordBuilder.ofStrings(Map<String,String> map)
Create a
StringRecord . |
static StringRecord |
StreamRecords.string(Map<String,String> raw)
Create a new
ByteBufferRecord for the given raw field/value pairs. |
StringRecord |
StringRecord.withId(RecordId id) |
StringRecord |
StringRecord.withStreamKey(String key)
Create a new
StringRecord with the associated stream key. |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.