Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
|
Modifier and Type | Method and Description |
---|---|
static ReactiveStreamCommands.AddStreamRecord |
ReactiveStreamCommands.AddStreamRecord.body(Map<ByteBuffer,ByteBuffer> body)
Creates a new
ReactiveStreamCommands.AddStreamRecord given body . |
ReactiveStreamCommands.AddStreamRecord |
ReactiveStreamCommands.AddStreamRecord.maxlen(long maxlen)
Limit the size of the stream to the given maximum number of elements.
|
static ReactiveStreamCommands.AddStreamRecord |
ReactiveStreamCommands.AddStreamRecord.of(ByteBufferRecord record)
Creates a new
ReactiveStreamCommands.AddStreamRecord given body . |
ReactiveStreamCommands.AddStreamRecord |
ReactiveStreamCommands.AddStreamRecord.to(ByteBuffer key)
Applies the Geo set key.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.