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 |
---|---|
void |
close() |
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.
|
ReactiveScriptingCommands |
scriptingCommands()
|
ReactiveServerCommands |
serverCommands()
|
ReactiveSetCommands |
setCommands()
Get
ReactiveSetCommands . |
ReactiveStringCommands |
stringCommands()
|
ReactiveZSetCommands |
zSetCommands()
Get
ReactiveZSetCommands . |
void close()
close
in interface AutoCloseable
close
in interface Closeable
ReactiveKeyCommands keyCommands()
ReactiveKeyCommands
.ReactiveStringCommands stringCommands()
ReactiveNumberCommands numberCommands()
ReactiveListCommands listCommands()
ReactiveListCommands
.ReactiveSetCommands setCommands()
ReactiveSetCommands
.ReactiveZSetCommands zSetCommands()
ReactiveZSetCommands
.ReactiveHashCommands hashCommands()
ReactiveHashCommands
.ReactiveGeoCommands geoCommands()
ReactiveHyperLogLogCommands hyperLogLogCommands()
ReactiveScriptingCommands scriptingCommands()
ReactiveServerCommands serverCommands()
reactor.core.publisher.Mono<String> ping()
Mono
wrapping server response message - usually PONG.Copyright © 2011–2018 Pivotal Software, Inc.. All rights reserved.