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 |
---|---|
static RecordId[] |
StringRedisConnection.entryIds(String... entryIds) |
default RecordId |
RedisStreamCommands.xAdd(byte[] key,
Map<byte[],byte[]> content)
Append a new record with the given
field/value pairs as content to the stream stored at key . |
default RecordId |
RedisStreamCommands.xAdd(MapRecord<byte[],byte[],byte[]> record)
Append the given
record to the stream stored at Record.getStream() . |
RecordId |
DefaultStringRedisConnection.xAdd(MapRecord<byte[],byte[],byte[]> record,
RedisStreamCommands.XAddOptions options) |
default RecordId |
DefaultedRedisConnection.xAdd(MapRecord<byte[],byte[],byte[]> record,
RedisStreamCommands.XAddOptions options)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
RecordId |
RedisStreamCommands.xAdd(MapRecord<byte[],byte[],byte[]> record,
RedisStreamCommands.XAddOptions options)
Append the given
record to the stream stored at Record.getStream() . |
default RecordId |
StringRedisConnection.xAdd(String key,
Map<String,String> body)
Append a record to the stream
key . |
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 |
---|---|
List<RecordId> |
RedisStreamCommands.XClaimOptions.getIds()
Get the
List of ID. |
List<RecordId> |
ReactiveStreamCommands.AcknowledgeCommand.getRecordIds() |
List<RecordId> |
ReactiveStreamCommands.DeleteCommand.getRecordIds() |
default reactor.core.publisher.Mono<RecordId> |
ReactiveStreamCommands.xAdd(ByteBuffer key,
Map<ByteBuffer,ByteBuffer> body)
Add stream record with given body to key.
|
default reactor.core.publisher.Mono<RecordId> |
ReactiveStreamCommands.xAdd(ByteBufferRecord record)
Add stream record with given body to key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,RecordId>> |
ReactiveStreamCommands.xAdd(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands)
Add stream record with given body to key.
|
List<RecordId> |
DefaultStringRedisConnection.xClaimJustId(byte[] key,
String group,
String newOwner,
RedisStreamCommands.XClaimOptions options) |
default List<RecordId> |
DefaultedRedisConnection.xClaimJustId(byte[] key,
String group,
String newOwner,
RedisStreamCommands.XClaimOptions options)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<RecordId> |
RedisStreamCommands.xClaimJustId(byte[] key,
String group,
String newOwner,
RedisStreamCommands.XClaimOptions options)
Change the ownership of a pending message to the given new consumer without increasing the delivered
count.
|
default reactor.core.publisher.Flux<RecordId> |
ReactiveStreamCommands.xClaimJustId(ByteBuffer key,
String group,
String newOwner,
RedisStreamCommands.XClaimOptions options)
Change the ownership of a pending message to the given new consumer without increasing the delivered
count.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<RecordId>>> |
ReactiveStreamCommands.xClaimJustId(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)
Change the ownership of a pending message to the given new consumer without increasing the delivered
count.
|
List<RecordId> |
DefaultStringRedisConnection.xClaimJustId(String key,
String group,
String consumer,
RedisStreamCommands.XClaimOptions options) |
List<RecordId> |
StringRedisConnection.xClaimJustId(String key,
String group,
String newOwner,
RedisStreamCommands.XClaimOptions options)
Change the ownership of a pending message to the given new consumer without increasing the delivered
count.
|
Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.AcknowledgeCommand |
ReactiveStreamCommands.AcknowledgeCommand.forRecords(RecordId... recordIds)
Applies the recordIds.
|
RedisStreamCommands.XClaimOptions |
RedisStreamCommands.XClaimOptions.XClaimOptionsBuilder.ids(RecordId... ids)
Set the IDs to claim.
|
ReactiveStreamCommands.DeleteCommand |
ReactiveStreamCommands.DeleteCommand.records(RecordId... recordIds)
Applies the recordIds.
|
Long |
DefaultStringRedisConnection.xAck(byte[] key,
String group,
RecordId... recordIds) |
default Long |
DefaultedRedisConnection.xAck(byte[] key,
String group,
RecordId... messageIds)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
Long |
RedisStreamCommands.xAck(byte[] key,
String group,
RecordId... recordIds)
Acknowledge one or more records, identified via their id, as processed.
|
default reactor.core.publisher.Mono<Long> |
ReactiveStreamCommands.xAck(ByteBuffer key,
String group,
RecordId... recordIds)
Acknowledge one or more records as processed.
|
Long |
DefaultStringRedisConnection.xAck(String key,
String group,
RecordId... recordIds) |
Long |
StringRedisConnection.xAck(String key,
String group,
RecordId... recordIds) |
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.
|
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xClaim(ByteBuffer key,
String group,
String newOwner,
Duration minIdleTime,
RecordId... recordIds)
Change the ownership of a pending message to the given new consumer.
|
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.
|
Long |
DefaultStringRedisConnection.xDel(byte[] key,
RecordId... recordIds) |
default Long |
DefaultedRedisConnection.xDel(byte[] key,
RecordId... recordIds)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
Long |
RedisStreamCommands.xDel(byte[] key,
RecordId... recordIds)
Removes the records with the given id's from the stream.
|
default reactor.core.publisher.Mono<Long> |
ReactiveStreamCommands.xDel(ByteBuffer key,
RecordId... recordIds)
Removes the specified entries from the stream.
|
Long |
DefaultStringRedisConnection.xDel(String key,
RecordId... recordIds) |
Long |
StringRedisConnection.xDel(String key,
RecordId... recordIds) |
Modifier and Type | Method and Description |
---|---|
static RecordId |
RecordId.autoGenerate()
Obtain the
RecordId signalling the server to auto generate an entry-id on insert (XADD ). |
RecordId |
Record.getId()
The id of the entry inside the stream.
|
RecordId |
PendingMessage.getId() |
RecordId |
PendingMessagesSummary.maxRecordId()
Get the greatest ID among the pending messages.
|
RecordId |
PendingMessagesSummary.minRecordId()
Get the smallest ID among the pending messages.
|
static RecordId |
RecordId.of(long millisecondsTime,
long sequenceNumber)
Create a new instance of
RecordId using the provided String formatted as
<millisecondsTime>-<sequenceNumber>. |
static RecordId |
RecordId.of(String value)
Obtain an instance of
RecordId using the provided String formatted as
<millisecondsTime>-<sequenceNumber>. |
Modifier and Type | Method and Description |
---|---|
static ReadOffset |
ReadOffset.from(RecordId offset)
Read all arriving elements from the stream starting at
RecordId . |
Record<S,V> |
Record.withId(RecordId id)
|
ByteRecord |
ByteRecord.withId(RecordId id) |
ObjectRecord<S,V> |
ObjectRecord.withId(RecordId id) |
ByteBufferRecord |
ByteBufferRecord.withId(RecordId id) |
StreamRecords.RecordBuilder<S> |
StreamRecords.RecordBuilder.withId(RecordId id)
Configure a
RecordId . |
StringRecord |
StringRecord.withId(RecordId id) |
MapRecord<S,K,V> |
MapRecord.withId(RecordId id) |
Constructor and Description |
---|
PendingMessage(RecordId id,
Consumer consumer,
Duration elapsedTimeSinceLastDelivery,
long totalDeliveryCount) |
Modifier and Type | Method and Description |
---|---|
default RecordId |
StreamOperations.add(K key,
Map<? extends HK,? extends HV> content)
Append a record to the stream
key . |
RecordId |
BoundStreamOperations.add(Map<HK,HV> body)
Append a record to the stream
key . |
default RecordId |
StreamOperations.add(MapRecord<K,? extends HK,? extends HV> record)
Append a record, backed by a
Map holding the field/value pairs, to the stream. |
RecordId |
StreamOperations.add(Record<K,?> record)
Append the record, backed by the given value, to the stream.
|
Modifier and Type | Method and Description |
---|---|
default reactor.core.publisher.Mono<RecordId> |
ReactiveStreamOperations.add(K key,
Map<? extends HK,? extends HV> content)
Append a record to the stream
key . |
default reactor.core.publisher.Flux<RecordId> |
ReactiveStreamOperations.add(K key,
org.reactivestreams.Publisher<? extends Map<? extends HK,? extends HV>> bodyPublisher)
Append one or more records to the stream
key . |
default reactor.core.publisher.Mono<RecordId> |
ReactiveStreamOperations.add(MapRecord<K,? extends HK,? extends HV> record)
Append a record, backed by a
Map holding the field/value pairs, to the stream. |
reactor.core.publisher.Mono<RecordId> |
ReactiveStreamOperations.add(Record<K,?> record)
Append the record, backed by the given value, to the stream.
|
Modifier and Type | Method and Description |
---|---|
default Long |
StreamOperations.acknowledge(K key,
String group,
RecordId... recordIds)
Acknowledge one or more records as processed.
|
reactor.core.publisher.Mono<Long> |
ReactiveStreamOperations.acknowledge(K key,
String group,
RecordId... recordIds)
Acknowledge one or more records as processed.
|
Long |
StreamOperations.delete(K key,
RecordId... recordIds)
Removes the specified records from the stream.
|
reactor.core.publisher.Mono<Long> |
ReactiveStreamOperations.delete(K key,
RecordId... recordIds)
Removes the specified records from the stream.
|
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.