code.data.cluster.Client

Aliases

Parameters

subClasses

superClasses

Any
java.lang.Object

Js Constructors

ApplyMethods

Methods

$bang$eq(x$1:Any):boolean
$eq$eq(x$1:Any):boolean
$hash$hash():int
$init$():Unit
asInstanceOf():scala.Any.T0
dirtyEntity(entity:java.lang.String):Unit
eq(x$1:java.lang.Object):boolean
equals(x$1:Any):boolean
getClass():java.lang.Class[Any]
getClientHealth():code.data.cluster.HealthResponse
getRunningFlows(query:code.data.cluster.RunningFlowsQuery):scala.collection.immutable.List[code.data.RemoteFlowStatus]
getServers():scala.collection.immutable.List[code.data.cluster.RemoteServer]
hashCode():int
isInstanceOf():boolean
killAllFlows(query:code.data.cluster.RunningFlowsQuery):Unit
killFlow(orchId:code.data.OrchestrationIdentity):Unit
killServer(serverId:java.lang.String):Unit
myName():java.lang.String
myUrl():java.lang.String
ne(x$1:java.lang.Object):boolean
notify():Unit
notifyAll():Unit
notifyFlowStatus(rm:code.data.RemoteFlowStatus):Unit
onServerMessage(msg:code.data.cluster.ClusterMessage):Unit
pauseFlow(orchId:code.data.OrchestrationIdentity):Unit
resumeFlow(orchId:code.data.OrchestrationIdentity):Unit
sendMessageToServer(msg:code.data.cluster.ClusterMessage):Unit
start():Unit
stop():Unit
subscribe(name:java.lang.String, pf:scala.Function1[Unitcode.data.cluster.ClusterMessage]):Unit
subscribeToFlows(name:java.lang.String, query:code.data.cluster.RunningFlowsQuery, onFlowStatus:scala.Function1[Unitscala.util.Either[code.data.RemoteFlowStatuscode.data.cluster.ForgetFlow]]):Unit
subscribeToServers(subsId:java.lang.String, pf:scala.Function1[Unitcode.data.cluster.ServerClusterMessage]):Unit
synchronized(x$1:java.lang.Object.T0):java.lang.Object.T0
toString():java.lang.String
unsubscribe(name:java.lang.String):Unit
unsubscribeFromFlows(name:java.lang.String):Unit
unsubscribeFromServers(subsId:java.lang.String):Unit
wait():Unit
wait(x$1:long):Unit
wait(x$1:long, x$2:int):Unit