Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  var _instances: Buffer[NodeInstance]

   Attributes

   protected

5.  var _isActive: Buffer[Boolean]

   Attributes

   protected

6.  def activeInstances: List[NodeInstance]

   All instances which are active.

7.  def activeServers: Seq[LocalNodeClient]
8.  val actorMaterializer: ActorMaterializer

   The actor materializer to use.

   The actor materializer to use.

   Definition Classes

   StandaloneSystem → Client

9.  val addInstance: Host[Int]

   Add a new server instance.

   Add a new server instance. Value returned is index of instance. A new instance is not inherintly joined to the cluster.

10.  val addNode: Host[Int]

    Add a new node to the cluster.

    Add a new node to the cluster. Value returned is index of node's instance.

11.  def arbitraryActiveNodeAddress: prelude.external.Task[prelude.external.Address]
12.  final def asInstanceOf[T0]: T0

    Definition Classes

    Any

13.  def awaitTerm: Host[Unit]

    Await termination of the entire system.

    Await termination of the entire system. this is where standalone waits for SIGINT/SIGKILL.

    TODO: Nothing internally will succeed this promise. A SIGINT/SIGKILL result in either a failure or interruption error. 1. there should be a standalone UI to this. 2. SIGINT verified to always result in interrupt error. 2. SIGKILL verified to always result in failure.

14.  val baseURL: URL
15.  def clone(): AnyRef

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()

16.  def downNode(nodeIndex: Int): HostTask[node.TermReason]

    Down the node in the cluster.

    Down the node in the cluster. This will not immediately shut down the node's server.

    #112 verify the actor system will initiate shutdown once the down gossip reaches itself.

17.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

18.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

19.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

20.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

21.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

22.  val http: HttpExt

    HTTP interface to use.

    HTTP interface to use.

    Definition Classes

    StandaloneSystem → Client

23.  def initClusterToHealthy: Host[Unit]

    Init cluster and assert healthy or fail.

24.  def instances: Seq[NodeInstance]
25.  def isActive(index: Int): Boolean
26.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

27.  lazy val logger: prelude.external.Logger
    Attributes

    protected

    Definition Classes

    DirectLogging

28.  val maxOperationDuration: Finite

    Definition Classes

    StandaloneSystem → Client

29.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

30.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

31.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

32.  def operationTimeout: prelude.external.Timeout

    Operation timeout defaults to the max operation duration plus a bit.

    Operation timeout defaults to the max operation duration plus a bit.

    Definition Classes

    Client

33.  def ops: Seq[LocalNodeClient]
34.  val prelude: Prelude
35.  val proxy: StandaloneProxy
36.  def removeNode(nodeIndex: Int): Host[node.TermReason]

    Request the given node terminate and wait for the node's termination.

37.  def replaceNode(nodeIndex: Int): Host[Int]
38.  def requireHealthy: prelude.external.Task[Unit]

    Definition Classes

    Client

39.  def requireOkResponse(request: prelude.AkkaHttp.HttpRequest): prelude.external.Task[prelude.AkkaHttp.ResponseEntity]

    Definition Classes

    Client

40.  def requireResponseCode(request: prelude.AkkaHttp.HttpRequest, expected: prelude.AkkaHttp.StatusCode): prelude.external.Task[prelude.AkkaHttp.ResponseEntity]

    Definition Classes

    Client

41.  def requireUnhealthy: prelude.external.Task[Unit]

    Definition Classes

    Client

42.  def resolveRelativeUri(uri: prelude.AkkaHttp.Uri): prelude.AkkaHttp.Uri

    Standalone aggregrate client targets the proxy HTTP port.

    Standalone aggregrate client targets the proxy HTTP port. Which then proxies the request to an active node.

    Definition Classes

    StandaloneSystem → Client

43.  def responseCodeAndEntity(request: prelude.AkkaHttp.HttpRequest): prelude.external.Task[(prelude.AkkaHttp.StatusCode, Strict)]

    Definition Classes

    Client

44.  def responseEntity(request: prelude.AkkaHttp.HttpRequest): prelude.external.Task[Strict]

    Definition Classes

    Client

45.  def responseJson(request: prelude.AkkaHttp.HttpRequest): prelude.external.Task[(prelude.AkkaHttp.StatusCode, JsValue)]

    Definition Classes

    Client

46.  def responseTxt(request0: prelude.AkkaHttp.HttpRequest): prelude.external.Task[(prelude.AkkaHttp.StatusCode, String)]

    Definition Classes

    Client

47.  def responseTxtAcceptAll(request: prelude.AkkaHttp.HttpRequest): prelude.external.Task[(prelude.AkkaHttp.StatusCode, String)]

    Definition Classes

    Client

48.  def servers: Seq[LocalNodeClient]
49.  val setup: Setup
50.  def shutdown: HostUIO[Unit]

    Request all of the given servers instances to stop and wait until they have stopped.

    Request all of the given servers instances to stop and wait until they have stopped.

    Shutdown is not done concurrently for consistency with gradual node replacement in distributed clusters.

    TODO: lift shutdown results to Set[TermReason] \/ app.Error

51.  def singleRequest(request: prelude.AkkaHttp.HttpRequest): prelude.external.Task[prelude.AkkaHttp.HttpResponse]

    Definition Classes

    Client

52.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

53.  def toString(): String

    Definition Classes

    AnyRef → Any

54.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

56.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()