ConnectionManager

Instance Constructors

new ConnectionManager(dest: String, label: Option[String], canBeRo: Boolean, timeForPreventive: Option[Duration], timeForRoMode: Option[Duration])

Type Members

type SearchMethod = (String) ⇒ Future[ServiceFactory[ReqPacket, RepPacket]]

Value Members

final def !=(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def !=(arg0: Any): Boolean

Definition Classes
Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def ==(arg0: Any): Boolean

Definition Classes
Any
def addHosts(hostList: String): Unit

Should add new hosts to the server list
Should add new hosts to the server list
hostList
the hosts to add
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def close(deadline: Time): Future[Unit]

To close connection manager, the current connexion, stop preventive search and stop rw server search.
To close connection manager, the current connexion, stop preventive search and stop rw server search.
returns
a Future.Done or Exception
def close(): Future[Unit]

To close connection manager, the current connexion, stop preventive search and stop rw server search.
To close connection manager, the current connexion, stop preventive search and stop rw server search.
returns
a Future.Done or Exception
var connection: Option[Connection]
def currentHost: Option[String]

Return the currently connected host
Return the currently connected host
returns
Some(host) or None if not connected
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def findAndConnect(): Future[Unit]

Find a server, and connect to it, priority to RW server, then RO server and finally not RO server.
Find a server, and connect to it, priority to RW server, then RO server and finally not RO server.
returns
a Future.Done or Exception
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
def initConnectionManager(): Future[Unit]

Initiates connection Manager on client creation.
Initiates connection Manager on client creation.
returns
Future.Done or Exception
val isInitiated: AtomicBoolean
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def newServiceFactory(server: String): ServiceFactory[ReqPacket, RepPacket]

Creates a new service factory.
Creates a new service factory.
server
the server to connect to
returns
a brand new service factory
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def removeAndFind(hostList: String): Future[String]

Should remove the given hosts from the host list, if the client is connected to one of these hosts, it will find a new host and return it.
Should remove the given hosts from the host list, if the client is connected to one of these hosts, it will find a new host and return it.
hostList
the hosts to remove from the current host list.
returns
address of an available server not included in the given host list or an Exception
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def testAndConnect(host: String): Future[Unit]

Test a server with isro request and connect request, then connect to it if testing is successful.
Test a server with isro request and connect request, then connect to it if testing is successful.
host
a host to test
returns
Future.Done or Exception
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
@throws( ... )

class ConnectionManager extends AnyRef

Instance Constructors

new ConnectionManager(dest: String, label: Option[String], canBeRo: Boolean, timeForPreventive: Option[Duration], timeForRoMode: Option[Duration])

Type Members

type SearchMethod = (String) ⇒ Future[ServiceFactory[ReqPacket, RepPacket]]

Value Members

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

def addHosts(hostList: String): Unit

final def asInstanceOf[T0]: T0

def clone(): AnyRef

def close(deadline: Time): Future[Unit]

def close(): Future[Unit]

var connection: Option[Connection]

def currentHost: Option[String]

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

def findAndConnect(): Future[Unit]

final def getClass(): Class[_]

def hashCode(): Int

def initConnectionManager(): Future[Unit]

val isInitiated: AtomicBoolean

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

def newServiceFactory(server: String): ServiceFactory[ReqPacket, RepPacket]

final def notify(): Unit

final def notifyAll(): Unit

def removeAndFind(hostList: String): Future[String]

final def synchronized[T0](arg0: ⇒ T0): T0

def testAndConnect(host: String): Future[Unit]

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from AnyRef

Inherited from Any

Ungrouped