Instance Constructors
-
new
SentinelClient(host: String = "localhost", port: Int = 26379, onMasterChange: (String, String, Int) ⇒ Unit = ..., onNewSentinel: (String, String, Int) ⇒ Unit = ..., onSentinelDown: (String, String, Int) ⇒ Unit = ..., name: String = "SentinelClient")(implicit _system: ActorSystem)
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
val
channels: Seq[String]
-
def
clone(): AnyRef
-
-
-
-
def
failover(master: String): Future[Boolean]
-
def
finalize(): Unit
-
final
def
getClass(): Class[_]
-
def
getConnectOperations: () ⇒ Seq[Operation[_, _]]
-
def
getMasterAddr(master: String): Future[Option[(String, Int)]]
-
var
host: String
-
final
def
isInstanceOf[T0]: Boolean
-
-
val
log: LoggingAdapter
-
def
masters(): Future[Seq[Map[String, String]]]
-
val
name: String
-
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
-
def
onConnectStatus(): (Boolean) ⇒ Unit
-
val
onMasterChange: (String, String, Int) ⇒ Unit
-
-
val
onNewSentinel: (String, String, Int) ⇒ Unit
-
val
onSentinelDown: (String, String, Int) ⇒ Unit
-
val
password: Option[String]
-
var
port: Int
-
def
reconnect(host: String = host, port: Int = port): Unit
-
val
redisConnection: ActorRef
-
val
redisPubSubConnection: ActorRef
-
def
resetMaster(pattern: String): Future[Boolean]
-
-
def
slaves(master: String): Future[Seq[Map[String, String]]]
-
def
stop(): Unit
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
val
system: ActorSystem
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from Serializable