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 |
---|---|
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.
|
List<ByteRecord> |
DefaultStringRedisConnection.xClaim(byte[] key,
String group,
String newOwner,
RedisStreamCommands.XClaimOptions options) |
default List<ByteRecord> |
DefaultedRedisConnection.xClaim(byte[] key,
String group,
String newOwner,
RedisStreamCommands.XClaimOptions options)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<ByteRecord> |
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> |
DefaultedRedisConnection.xRange(byte[] key,
Range<String> range)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
default List<ByteRecord> |
RedisStreamCommands.xRange(byte[] key,
Range<String> range)
|
List<ByteRecord> |
DefaultStringRedisConnection.xRange(byte[] key,
Range<String> range,
RedisZSetCommands.Limit limit) |
default List<ByteRecord> |
DefaultedRedisConnection.xRange(byte[] key,
Range<String> range,
RedisZSetCommands.Limit limit)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<ByteRecord> |
RedisStreamCommands.xRange(byte[] key,
Range<String> range,
RedisZSetCommands.Limit limit)
|
default List<ByteRecord> |
DefaultedRedisConnection.xRead(StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
default List<ByteRecord> |
RedisStreamCommands.xRead(StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s. |
List<ByteRecord> |
DefaultStringRedisConnection.xRead(StreamReadOptions readOptions,
StreamOffset<byte[]>... streams) |
default List<ByteRecord> |
DefaultedRedisConnection.xRead(StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<ByteRecord> |
RedisStreamCommands.xRead(StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s. |
default List<ByteRecord> |
DefaultedRedisConnection.xReadGroup(Consumer consumer,
StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
default List<ByteRecord> |
RedisStreamCommands.xReadGroup(Consumer consumer,
StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
List<ByteRecord> |
DefaultStringRedisConnection.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams) |
default List<ByteRecord> |
DefaultedRedisConnection.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<ByteRecord> |
RedisStreamCommands.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<ByteRecord> |
DefaultedRedisConnection.xRevRange(byte[] key,
Range<String> range)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
default List<ByteRecord> |
RedisStreamCommands.xRevRange(byte[] key,
Range<String> range)
Read records from a stream within a specific
Range in reverse order. |
List<ByteRecord> |
DefaultStringRedisConnection.xRevRange(byte[] key,
Range<String> range,
RedisZSetCommands.Limit limit) |
default List<ByteRecord> |
DefaultedRedisConnection.xRevRange(byte[] key,
Range<String> range,
RedisZSetCommands.Limit limit)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<ByteRecord> |
RedisStreamCommands.xRevRange(byte[] key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit in reverse order. |
Modifier and Type | Method and Description |
---|---|
static ByteRecord |
ByteRecord.of(MapRecord<byte[],byte[],byte[]> source)
Convert a binary
MapRecord into a ByteRecord . |
ByteRecord |
StreamRecords.RecordBuilder.ofBytes(Map<byte[],byte[]> value) |
static ByteRecord |
StreamRecords.rawBytes(Map<byte[],byte[]> raw)
Create a new
ByteRecord 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)
Serialize
key with the streamSerializer, field names with the
fieldSerializer and values with the valueSerializer. |
ByteRecord |
ByteRecord.withId(RecordId id) |
ByteRecord |
ByteRecord.withStreamKey(byte[] key)
Create a new
ByteRecord with the associated stream key. |
Modifier and Type | Method and Description |
---|---|
MapRecord<K,HK,HV> |
StreamOperations.deserializeRecord(ByteRecord record)
Deserialize a
ByteRecord using the configured serializers into a MapRecord . |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.