class RedisSentinel extends AnyRef
Interface for sentinel commands
- Alphabetic
- By Inheritance
- RedisSentinel
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new RedisSentinel(_asJava: AnyRef)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asJava: AnyRef
-
def
ckquorum(name: String, handler: Handler[AsyncResult[String]]): RedisSentinel
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.
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. This command should be used in monitoring systems to check if a Sentinel deployment is ok. * @param name master name
- handler
Handler for the result of this call
-
def
ckquorumFuture(name: String): Future[String]
Like ckquorum but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
close(handler: Handler[AsyncResult[Unit]]): Unit
Close the client - when it is fully closed the handler will be called.
-
def
closeFuture(): Future[Unit]
Like close but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
failover(name: String, handler: Handler[AsyncResult[String]]): RedisSentinel
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) * @param name master 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) * @param name master name
- handler
Handler for the result of this call
-
def
failoverFuture(name: String): Future[String]
Like failover but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
flushConfig(handler: Handler[AsyncResult[Unit]]): RedisSentinel
Force Sentinel to rewrite its configuration on disk, including the current Sentinel state.
Force Sentinel to rewrite its configuration on disk, including the current Sentinel state. Normally Sentinel rewrites the configuration every time something changes in its state (in the context of the subset of the state which is persisted on disk across restart). However sometimes it is possible that the configuration file is lost because of operation errors, disk failures, package upgrade scripts or configuration managers. In those cases a way to to force Sentinel to rewrite the configuration file is handy. This command works even if the previous configuration file is completely missing. * @param handler Handler for the result of this call
-
def
flushConfigFuture(): Future[Unit]
Like flushConfig but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getMasterAddrByName(name: String, handler: Handler[AsyncResult[JsonArray]]): RedisSentinel
Return the ip and port number of the master with that name.
Return the ip and port number of the master with that name. If a failover is in progress or terminated successfully for this master it returns the address and port of the promoted slave * @param name master name
- handler
Handler for the result of this call
-
def
getMasterAddrByNameFuture(name: String): Future[JsonArray]
Like getMasterAddrByName but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
master(name: String, handler: Handler[AsyncResult[JsonArray]]): RedisSentinel
Show the state and info of the specified master * @param name master name
Show the state and info of the specified master * @param name master name
- handler
Handler for the result of this call
-
def
masterFuture(name: String): Future[JsonArray]
Like master but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
masters(handler: Handler[AsyncResult[JsonArray]]): RedisSentinel
Show a list of monitored masters and their state * @param handler Handler for the result of this call
-
def
mastersFuture(): Future[JsonArray]
Like masters but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
reset(pattern: String, handler: Handler[AsyncResult[Unit]]): RedisSentinel
Reset all the masters with matching name.
Reset all the masters with matching name. The pattern argument is a glob-style pattern. The reset process clears any previous state in a master (including a failover in pro * @param pattern pattern String
- handler
Handler for the result of this call
-
def
resetFuture(pattern: String): Future[Unit]
Like reset but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
sentinels(name: String, handler: Handler[AsyncResult[JsonArray]]): RedisSentinel
Show a list of sentinel instances for this master, and their state * @param name master name
Show a list of sentinel instances for this master, and their state * @param name master name
- handler
Handler for the result of this call
-
def
sentinelsFuture(name: String): Future[JsonArray]
Like sentinels but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
slaves(name: String, handler: Handler[AsyncResult[JsonArray]]): RedisSentinel
Show a list of slaves for this master, and their state * @param name master name
Show a list of slaves for this master, and their state * @param name master name
- handler
Handler for the result of this call
-
def
slavesFuture(name: String): Future[JsonArray]
Like slaves but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )