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.xRange(String key,
Range<String> range)
Read records from a stream within a specific
Range . |
List<StringRecord> |
StringRedisConnection.xRange(String key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a Limit . |
List<StringRecord> |
DefaultStringRedisConnection.xRange(String key,
Range<String> range,
RedisZSetCommands.Limit 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> |
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<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. |
default List<StringRecord> |
StringRedisConnection.xRevRange(String key,
Range<String> range)
Read records from a stream within a specific
Range in reverse order. |
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. |
List<StringRecord> |
DefaultStringRedisConnection.xRevRange(String key,
Range<String> range,
RedisZSetCommands.Limit limit) |
Modifier and Type | Method and Description |
---|---|
RecordId |
StringRedisConnection.xAdd(StringRecord record) |
RecordId |
DefaultStringRedisConnection.xAdd(StringRecord record) |
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–2019 Pivotal Software, Inc.. All rights reserved.