Package | Description |
---|---|
io.vertx.reactivex.redis.client | |
io.vertx.redis.client | |
io.vertx.rxjava.redis.client | |
io.vertx.rxjava3.redis.client |
Modifier and Type | Method and Description |
---|---|
RedisConnection |
RedisConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static RedisConnection |
RedisConnection.newInstance(RedisConnection arg) |
Constructor and Description |
---|
RedisConnection(RedisConnection delegate) |
Modifier and Type | Method and Description |
---|---|
default 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.
|
default RedisConnection |
RedisConnection.close(Handler<AsyncResult<Void>> onClose)
Closes the connection or returns to the pool.
|
RedisConnection |
RedisConnection.endHandler(Handler<Void> endHandler)
Set an end handler.
|
RedisConnection |
RedisConnection.exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
RedisConnection |
RedisConnection.fetch(long amount)
Fetch the specified
amount of elements. |
RedisConnection |
RedisConnection.handler(Handler<Response> handler)
Set a data handler.
|
RedisConnection |
RedisConnection.pause()
Pause the
ReadStream , it sets the buffer in fetch mode and clears the actual demand. |
RedisConnection |
RedisConnection.resume()
Resume reading, and sets the buffer in
flowing mode. |
default 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 |
---|---|
Future<RedisConnection> |
Redis.connect()
Connects to the redis server.
|
Modifier and Type | Method and Description |
---|---|
static RedisAPI |
RedisAPI.api(RedisConnection connection) |
static RedisCluster |
RedisCluster.create(RedisConnection connection) |
Modifier and Type | Method and Description |
---|---|
default Redis |
Redis.connect(Handler<AsyncResult<RedisConnection>> handler)
Connects to the redis server.
|
Modifier and Type | Method and Description |
---|---|
RedisConnection |
RedisConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static RedisConnection |
RedisConnection.newInstance(RedisConnection arg) |
Constructor and Description |
---|
RedisConnection(RedisConnection delegate) |
Modifier and Type | Method and Description |
---|---|
RedisConnection |
RedisConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static RedisConnection |
RedisConnection.newInstance(RedisConnection arg) |
Constructor and Description |
---|
RedisConnection(RedisConnection delegate) |
Copyright © 2024 Eclipse. All rights reserved.