public interface ReactiveRedisConnection extends Closeable
ReactiveRedisConnection
is typically implemented by a stateful object that requires to be closed
once it is no longer required.
Commands can be either executed by passing plain arguments like key
, value
or wrapped inside a
command stream. Streaming command execution accepts Publisher
of a particular
ReactiveRedisConnection.Command
. Commands are executed at the time their emission.
Arguments are binary-safe by using ByteBuffer
arguments. Expect ByteBuffer
to be consumed by
ReactiveRedisConnection
invocation or during execution. Any ByteBuffer
used as method parameter
should not be altered after invocation.
ReactiveRedisConnection.Command
,
ReactiveRedisConnection.CommandResponse
,
ReactiveRedisConnection.KeyCommand
Modifier and Type | Method and Description |
---|---|
default void |
close() |
reactor.core.publisher.Mono<Void> |
closeLater()
Asynchronously close the connection and release associated resources.
|
ReactiveGeoCommands |
geoCommands()
|
ReactiveHashCommands |
hashCommands()
Get
ReactiveHashCommands . |
ReactiveHyperLogLogCommands |
hyperLogLogCommands()
|
ReactiveKeyCommands |
keyCommands()
Get
ReactiveKeyCommands . |
ReactiveListCommands |
listCommands()
Get
ReactiveListCommands . |
ReactiveNumberCommands |
numberCommands()
|
reactor.core.publisher.Mono<String> |
ping()
Test connection.
|
ReactivePubSubCommands |
pubSubCommands()
|
ReactiveScriptingCommands |
scriptingCommands()
|
ReactiveServerCommands |
serverCommands()
|
ReactiveSetCommands |
setCommands()
Get
ReactiveSetCommands . |
ReactiveStreamCommands |
streamCommands()
|
ReactiveStringCommands |
stringCommands()
|
ReactiveZSetCommands |
zSetCommands()
Get
ReactiveZSetCommands . |
default void close()
close
in interface AutoCloseable
close
in interface Closeable
reactor.core.publisher.Mono<Void> closeLater()
Mono
signaling when done.ReactiveKeyCommands keyCommands()
ReactiveKeyCommands
.ReactiveStringCommands stringCommands()
ReactiveNumberCommands numberCommands()
ReactiveListCommands listCommands()
ReactiveListCommands
.ReactiveSetCommands setCommands()
ReactiveSetCommands
.ReactiveZSetCommands zSetCommands()
ReactiveZSetCommands
.ReactiveHashCommands hashCommands()
ReactiveHashCommands
.ReactiveGeoCommands geoCommands()
ReactiveHyperLogLogCommands hyperLogLogCommands()
ReactivePubSubCommands pubSubCommands()
ReactiveScriptingCommands scriptingCommands()
ReactiveServerCommands serverCommands()
ReactiveStreamCommands streamCommands()
reactor.core.publisher.Mono<String> ping()
Mono
wrapping server response message - usually PONG.Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.