Package | Description |
---|---|
io.vertx.reactivex.redis.client |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<Request> |
Request.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
Request |
Request.arg(boolean arg)
Adds a boolean encoded to string
|
Request |
Request.arg(Buffer arg)
Adds a String key argument
|
Request |
Request.arg(byte arg)
Adds a byte encoded to string
|
Request |
Request.arg(byte[] arg)
Adds a byte array
|
Request |
Request.arg(double arg)
Adds a double encoded to string
|
Request |
Request.arg(float arg)
Adds a float encoded to string
|
Request |
Request.arg(int arg)
Adds a int encoded to string
|
Request |
Request.arg(JsonArray arg)
Adds a JsonArray argument, the encoding will serialize the json as value0, value1, ...
|
Request |
Request.arg(JsonObject arg)
Adds a JsonObject argument, the encoding will serialize the json as key0, value0, key1, value1, ...
|
Request |
Request.arg(long arg)
Adds a long encoded to string
|
Request |
Request.arg(short arg)
Adds a short encoded to string
|
Request |
Request.arg(String arg)
Adds a String argument using UTF8 character encoding
|
Request |
Request.arg(String arg,
String enc)
Adds a String using a specific character encoding argument
|
static Request |
Request.cmd(Command command)
Creates a new request command.
|
static Request |
Request.cmd(Command command,
Object[] args)
|
static Request |
Request.newInstance(Request arg) |
Request |
Request.nullArg()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Maybe<Response> |
Redis.rxSend(Request command)
Send the given command to the redis server or cluster.
|
Maybe<Response> |
RedisConnection.rxSend(Request command)
Send the given command to the redis server or cluster.
|
Redis |
Redis.send(Request command)
Send the given command to the redis server or cluster.
|
RedisConnection |
RedisConnection.send(Request command)
Send the given command to the redis server or cluster.
|
Redis |
Redis.send(Request command,
Handler<AsyncResult<Response>> onSend)
Send the given command to the redis server or cluster.
|
RedisConnection |
RedisConnection.send(Request command,
Handler<AsyncResult<Response>> onSend)
Send the given command to the redis server or cluster.
|
Modifier and Type | Method and Description |
---|---|
Redis |
Redis.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.
|
RedisConnection |
RedisConnection.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.
|
Redis |
Redis.batch(List<Request> commands,
Handler<AsyncResult<List<Response>>> onSend)
Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other
client users.
|
RedisConnection |
RedisConnection.batch(List<Request> commands,
Handler<AsyncResult<List<Response>>> onSend)
Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other
client users.
|
Single<List<Response>> |
Redis.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<List<Response>> |
RedisConnection.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.
|
Copyright © 2024 Eclipse. All rights reserved.