Uses of Interface
org.springframework.data.redis.connection.stream.StringRecord
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Data structures and interfaces to interact with Redis Streams.
-
Uses of StringRecord in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionDefaultStringRedisConnection.xClaim
(String key, String group, String consumer, RedisStreamCommands.XClaimOptions options) 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.StringRedisConnection.xClaim
(String key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer.DefaultStringRedisConnection.xRange
(String key, org.springframework.data.domain.Range<String> range, Limit limit) default List<StringRecord>
Read records from a stream within a specificRedisZSetCommands.Range
.StringRedisConnection.xRange
(String key, org.springframework.data.domain.Range<String> range, Limit limit) Read records from a stream within a specificRedisZSetCommands.Range
applying aLimit
.DefaultStringRedisConnection.xReadAsString
(StreamReadOptions readOptions, StreamOffset<String>... streams) default List<StringRecord>
StringRedisConnection.xReadAsString
(StreamOffset<String> stream) Read records from one or moreStreamOffset
s.default List<StringRecord>
StringRedisConnection.xReadAsString
(StreamOffset<String>... streams) Read records from one or moreStreamOffset
s.default List<StringRecord>
StringRedisConnection.xReadAsString
(StreamReadOptions readOptions, StreamOffset<String> stream) Read records from one or moreStreamOffset
s.StringRedisConnection.xReadAsString
(StreamReadOptions readOptions, StreamOffset<String>... streams) Read records from one or moreStreamOffset
s.DefaultStringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams) default List<StringRecord>
StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamOffset<String> stream) Read records from one or moreStreamOffset
s using a consumer group.default List<StringRecord>
StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamOffset<String>... streams) Read records from one or moreStreamOffset
s using a consumer group.default List<StringRecord>
StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String> stream) Read records from one or moreStreamOffset
s using a consumer group.StringRedisConnection.xReadGroupAsString
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<String>... streams) Read records from one or moreStreamOffset
s using a consumer group.DefaultStringRedisConnection.xRevRange
(String key, org.springframework.data.domain.Range<String> range, Limit limit) default List<StringRecord>
Read records from a stream within a specificRedisZSetCommands.Range
in reverse order.StringRedisConnection.xRevRange
(String key, org.springframework.data.domain.Range<String> range, Limit limit) Read records from a stream within a specificRedisZSetCommands.Range
applying aLimit
in reverse order.Modifier and TypeMethodDescriptionDefaultStringRedisConnection.xAdd
(StringRecord record, RedisStreamCommands.XAddOptions options) default RecordId
StringRedisConnection.xAdd
(StringRecord record) Append the givenStringRecord
to the stream stored atRecord.getStream()
.StringRedisConnection.xAdd
(StringRecord record, RedisStreamCommands.XAddOptions options) Append the givenStringRecord
to the stream stored atRecord.getStream()
. -
Uses of StringRecord in org.springframework.data.redis.connection.stream
Modifier and TypeMethodDescriptionstatic StringRecord
static StringRecord
Create aStringRecord
.static StringRecord
Create a newByteBufferRecord
for the given raw field/value pairs.StringRecord.withStreamKey
(String key) Create a newStringRecord
with the associated stream key.