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 |
---|---|
ByteBufferRecord |
ReactiveStreamCommands.AddStreamRecord.getRecord() |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> |
ReactiveStreamCommands.read(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands)
Read records from one or more
StreamOffset s. |
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 reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xClaim(ByteBuffer key,
String group,
String newOwner,
RedisStreamCommands.XClaimOptions options)
Change the ownership of a pending message to the given new consumer.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> |
ReactiveStreamCommands.xClaim(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)
Change the ownership of a pending message to the given new consumer.
|
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xRange(ByteBuffer key,
Range<String> range)
Read records from a stream within a specific
Range . |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xRange(ByteBuffer key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit . |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> |
ReactiveStreamCommands.xRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit . |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xRead(StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xRead(StreamReadOptions readOptions,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xReadGroup(Consumer consumer,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xRevRange(ByteBuffer key,
Range<String> range)
Read records from a stream within a specific
Range in reverse order. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xRevRange(ByteBuffer key,
Range<String> range,
RedisZSetCommands.Limit limit)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit in reverse order. |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> |
ReactiveStreamCommands.xRevRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)
Read records from a stream within a specific
Range applying a RedisZSetCommands.Limit in reverse order. |
Modifier and Type | Method and Description |
---|---|
static ReactiveStreamCommands.AddStreamRecord |
ReactiveStreamCommands.AddStreamRecord.of(ByteBufferRecord record)
Creates a new
ReactiveStreamCommands.AddStreamRecord given body . |
default reactor.core.publisher.Mono<RecordId> |
ReactiveStreamCommands.xAdd(ByteBufferRecord record)
Add stream record with given body to key.
|
Modifier and Type | Method and Description |
---|---|
static ByteBufferRecord |
ByteBufferRecord.of(MapRecord<ByteBuffer,ByteBuffer,ByteBuffer> source)
Convert a binary
MapRecord into a ByteRecord . |
ByteBufferRecord |
StreamRecords.RecordBuilder.ofBuffer(Map<ByteBuffer,ByteBuffer> value) |
static ByteBufferRecord |
StreamRecords.rawBuffer(Map<ByteBuffer,ByteBuffer> raw)
Create a new
ByteBufferRecord for the given raw field/value pairs. |
ByteBufferRecord |
ByteBufferRecord.withId(RecordId id) |
ByteBufferRecord |
ByteBufferRecord.withStreamKey(ByteBuffer key)
Create a new
ByteBufferRecord with the associated stream key. |
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.