Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<Redis> |
__TYPE_ARG |
Constructor and Description |
---|
Redis(Object delegate) |
Redis(Redis delegate) |
Modifier and Type | Method and Description |
---|---|
Single<List<Response>> |
batch(List<Request> commands)
Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other
client users.
|
void |
close()
Closes the client and terminates any connection.
|
Single<RedisConnection> |
connect()
Connects to the redis server.
|
static Redis |
createClient(Vertx vertx)
Create a new redis client using the default client options.
|
static Redis |
createClient(Vertx vertx,
RedisOptions options)
Create a new redis client using the given client options.
|
static Redis |
createClient(Vertx vertx,
String connectionString)
Create a new redis client using the default client options.
|
boolean |
equals(Object o) |
Redis |
getDelegate() |
int |
hashCode() |
static Redis |
newInstance(Redis arg) |
Single<List<Response>> |
rxBatch(List<Request> commands)
Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other
client users.
|
Single<RedisConnection> |
rxConnect()
Connects to the redis server.
|
Maybe<Response> |
rxSend(Request command)
Send the given command to the redis server or cluster.
|
Maybe<Response> |
send(Request command)
Send the given command to the redis server or cluster.
|
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<Redis> __TYPE_ARG
public Redis getDelegate()
public static Redis createClient(Vertx vertx)
vertx
- the vertx instancepublic static Redis createClient(Vertx vertx, String connectionString)
vertx
- the vertx instanceconnectionString
- a string URI following the scheme: redis://[username:password@][host][:port][/database]public static Redis createClient(Vertx vertx, RedisOptions options)
vertx
- the vertx instanceoptions
- the user provided optionspublic Single<RedisConnection> connect()
public Single<RedisConnection> rxConnect()
public void close()
public Maybe<Response> send(Request command)
command
- the command to sendpublic Maybe<Response> rxSend(Request command)
command
- the command to sendpublic Single<List<Response>> batch(List<Request> commands)
commands
- list of command to sendpublic Single<List<Response>> rxBatch(List<Request> commands)
commands
- list of command to sendCopyright © 2021 Eclipse. All rights reserved.