Uses of Interface
org.springframework.data.redis.connection.stream.ByteRecord
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.
Core package for integrating Redis with Spring concepts.
-
Uses of ByteRecord in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptiondefault List<ByteRecord>
DefaultedRedisConnection.xClaim
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Deprecated.DefaultStringRedisConnection.xClaim
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) default List<ByteRecord>
RedisStreamCommands.xClaim
(byte[] key, String group, String newOwner, Duration minIdleTime, RecordId... recordIds) Change the ownership of a pending message to the given new consumer.RedisStreamCommands.xClaim
(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer.default List<ByteRecord>
Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.default List<ByteRecord>
Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.default List<ByteRecord>
default List<ByteRecord>
DefaultedRedisConnection.xRead
(StreamOffset<byte[]>... streams) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.default List<ByteRecord>
DefaultedRedisConnection.xRead
(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.DefaultStringRedisConnection.xRead
(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) default List<ByteRecord>
RedisStreamCommands.xRead
(StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s.RedisStreamCommands.xRead
(StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s.default List<ByteRecord>
DefaultedRedisConnection.xReadGroup
(Consumer consumer, StreamOffset<byte[]>... streams) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.default List<ByteRecord>
DefaultedRedisConnection.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.DefaultStringRedisConnection.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) default List<ByteRecord>
RedisStreamCommands.xReadGroup
(Consumer consumer, StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s using a consumer group.RedisStreamCommands.xReadGroup
(Consumer consumer, StreamReadOptions readOptions, StreamOffset<byte[]>... streams) Read records from one or moreStreamOffset
s using a consumer group.default List<ByteRecord>
Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.default List<ByteRecord>
Deprecated.in favor ofRedisCommandsProvider.streamCommands()
}.default List<ByteRecord>
Read records from a stream within a specificRange
in reverse order. -
Uses of ByteRecord in org.springframework.data.redis.connection.stream
Modifier and TypeMethodDescriptionstatic ByteRecord
Convert a binaryMapRecord
into aByteRecord
.static ByteRecord
Create a newByteRecord
for the given raw field/value pairs.default ByteRecord
MapRecord.serialize
(RedisSerializer<?> serializer) default ByteRecord
MapRecord.serialize
(RedisSerializer<? super S> streamSerializer, RedisSerializer<? super K> fieldSerializer, RedisSerializer<? super V> valueSerializer) Serializekey
with the streamSerializer, field names with the fieldSerializer and values with the valueSerializer.ByteRecord.withStreamKey
(byte[] key) Create a newByteRecord
with the associated stream key. -
Uses of ByteRecord in org.springframework.data.redis.core
Modifier and TypeMethodDescriptionStreamOperations.deserializeRecord
(ByteRecord record) Deserialize aByteRecord
using the configured serializers into aMapRecord
.
RedisCommandsProvider.streamCommands()
}.