public class RedisSentinel extends Object
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<RedisSentinel> |
__TYPE_ARG |
Constructor and Description |
---|
RedisSentinel(Object delegate) |
RedisSentinel(RedisSentinel delegate) |
Modifier and Type | Method and Description |
---|---|
RedisSentinel |
ckquorum(String name,
Handler<AsyncResult<String>> handler)
Check if the current Sentinel configuration is able to reach the quorum needed to failover a master,
and the majority needed to authorize the failover.
|
Observable<String> |
ckquorumObservable(String name)
Deprecated.
use
rxCkquorum(java.lang.String) instead |
void |
close(Handler<AsyncResult<Void>> handler)
Close the client - when it is fully closed the handler will be called.
|
Observable<Void> |
closeObservable()
Deprecated.
use
rxClose() instead |
static RedisSentinel |
create(Vertx vertx) |
static RedisSentinel |
create(Vertx vertx,
JsonObject config) |
boolean |
equals(Object o) |
RedisSentinel |
failover(String name,
Handler<AsyncResult<String>> handler)
Force a failover as if the master was not reachable, and without asking for agreement to other Sentinels
(however a new version of the configuration will be published so that the other Sentinels
will update their configurations)
|
Observable<String> |
failoverObservable(String name)
Deprecated.
use
rxFailover(java.lang.String) instead |
RedisSentinel |
flushConfig(Handler<AsyncResult<Void>> handler)
Force Sentinel to rewrite its configuration on disk, including the current Sentinel state.
|
Observable<Void> |
flushConfigObservable()
Deprecated.
use
rxFlushConfig() instead |
RedisSentinel |
getDelegate() |
RedisSentinel |
getMasterAddrByName(String name,
Handler<AsyncResult<JsonArray>> handler)
Return the ip and port number of the master with that name.
|
Observable<JsonArray> |
getMasterAddrByNameObservable(String name)
Deprecated.
use
rxGetMasterAddrByName(java.lang.String) instead |
int |
hashCode() |
RedisSentinel |
master(String name,
Handler<AsyncResult<JsonArray>> handler)
Show the state and info of the specified master
|
Observable<JsonArray> |
masterObservable(String name)
Deprecated.
use
rxMaster(java.lang.String) instead |
RedisSentinel |
masters(Handler<AsyncResult<JsonArray>> handler)
Show a list of monitored masters and their state
|
Observable<JsonArray> |
mastersObservable()
Deprecated.
use
rxMasters() instead |
static RedisSentinel |
newInstance(RedisSentinel arg) |
RedisSentinel |
reset(String pattern,
Handler<AsyncResult<Void>> handler)
Reset all the masters with matching name.
|
Observable<Void> |
resetObservable(String pattern)
Deprecated.
use
rxReset(java.lang.String) instead |
Single<String> |
rxCkquorum(String name)
Check if the current Sentinel configuration is able to reach the quorum needed to failover a master,
and the majority needed to authorize the failover.
|
Single<Void> |
rxClose()
Close the client - when it is fully closed the handler will be called.
|
Single<String> |
rxFailover(String name)
Force a failover as if the master was not reachable, and without asking for agreement to other Sentinels
(however a new version of the configuration will be published so that the other Sentinels
will update their configurations)
|
Single<Void> |
rxFlushConfig()
Force Sentinel to rewrite its configuration on disk, including the current Sentinel state.
|
Single<JsonArray> |
rxGetMasterAddrByName(String name)
Return the ip and port number of the master with that name.
|
Single<JsonArray> |
rxMaster(String name)
Show the state and info of the specified master
|
Single<JsonArray> |
rxMasters()
Show a list of monitored masters and their state
|
Single<Void> |
rxReset(String pattern)
Reset all the masters with matching name.
|
Single<JsonArray> |
rxSentinels(String name)
Show a list of sentinel instances for this master, and their state
|
Single<JsonArray> |
rxSlaves(String name)
Show a list of slaves for this master, and their state
|
RedisSentinel |
sentinels(String name,
Handler<AsyncResult<JsonArray>> handler)
Show a list of sentinel instances for this master, and their state
|
Observable<JsonArray> |
sentinelsObservable(String name)
Deprecated.
use
rxSentinels(java.lang.String) instead |
RedisSentinel |
slaves(String name,
Handler<AsyncResult<JsonArray>> handler)
Show a list of slaves for this master, and their state
|
Observable<JsonArray> |
slavesObservable(String name)
Deprecated.
use
rxSlaves(java.lang.String) instead |
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<RedisSentinel> __TYPE_ARG
public RedisSentinel(RedisSentinel delegate)
public RedisSentinel(Object delegate)
public RedisSentinel getDelegate()
public static RedisSentinel create(Vertx vertx)
public static RedisSentinel create(Vertx vertx, JsonObject config)
public void close(Handler<AsyncResult<Void>> handler)
handler
- @Deprecated public Observable<Void> closeObservable()
rxClose()
insteadpublic Single<Void> rxClose()
public RedisSentinel masters(Handler<AsyncResult<JsonArray>> handler)
handler
- Handler for the result of this call@Deprecated public Observable<JsonArray> mastersObservable()
rxMasters()
insteadpublic Single<JsonArray> rxMasters()
public RedisSentinel master(String name, Handler<AsyncResult<JsonArray>> handler)
name
- master namehandler
- Handler for the result of this call@Deprecated public Observable<JsonArray> masterObservable(String name)
rxMaster(java.lang.String)
insteadname
- master namepublic Single<JsonArray> rxMaster(String name)
name
- master namepublic RedisSentinel slaves(String name, Handler<AsyncResult<JsonArray>> handler)
name
- master namehandler
- Handler for the result of this call@Deprecated public Observable<JsonArray> slavesObservable(String name)
rxSlaves(java.lang.String)
insteadname
- master namepublic Single<JsonArray> rxSlaves(String name)
name
- master namepublic RedisSentinel sentinels(String name, Handler<AsyncResult<JsonArray>> handler)
name
- master namehandler
- Handler for the result of this call@Deprecated public Observable<JsonArray> sentinelsObservable(String name)
rxSentinels(java.lang.String)
insteadname
- master namepublic Single<JsonArray> rxSentinels(String name)
name
- master namepublic RedisSentinel getMasterAddrByName(String name, Handler<AsyncResult<JsonArray>> handler)
name
- master namehandler
- Handler for the result of this call@Deprecated public Observable<JsonArray> getMasterAddrByNameObservable(String name)
rxGetMasterAddrByName(java.lang.String)
insteadname
- master namepublic Single<JsonArray> rxGetMasterAddrByName(String name)
name
- master namepublic RedisSentinel reset(String pattern, Handler<AsyncResult<Void>> handler)
pattern
- pattern Stringhandler
- Handler for the result of this call@Deprecated public Observable<Void> resetObservable(String pattern)
rxReset(java.lang.String)
insteadpattern
- pattern Stringpublic Single<Void> rxReset(String pattern)
pattern
- pattern Stringpublic RedisSentinel failover(String name, Handler<AsyncResult<String>> handler)
name
- master namehandler
- Handler for the result of this call@Deprecated public Observable<String> failoverObservable(String name)
rxFailover(java.lang.String)
insteadname
- master namepublic Single<String> rxFailover(String name)
name
- master namepublic RedisSentinel ckquorum(String name, Handler<AsyncResult<String>> handler)
name
- master namehandler
- Handler for the result of this call@Deprecated public Observable<String> ckquorumObservable(String name)
rxCkquorum(java.lang.String)
insteadname
- master namepublic Single<String> rxCkquorum(String name)
name
- master namepublic RedisSentinel flushConfig(Handler<AsyncResult<Void>> handler)
handler
- Handler for the result of this call@Deprecated public Observable<Void> flushConfigObservable()
rxFlushConfig()
insteadpublic Single<Void> rxFlushConfig()
public static RedisSentinel newInstance(RedisSentinel arg)
Copyright © 2023 Eclipse. All rights reserved.