Packages

final class LevelDBStandaloneSystem extends StandaloneSystem

Linear Supertypes
StandaloneSystem, Client, prelude.DirectLogging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. LevelDBStandaloneSystem
  2. StandaloneSystem
  3. Client
  4. DirectLogging
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new LevelDBStandaloneSystem(instance: Instance)

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
    Definition Classes
    StandaloneSystem
  5. var _isActive: Buffer[Boolean]
    Attributes
    protected
    Definition Classes
    StandaloneSystem
  6. def activeInstances: List[NodeInstance]

    All instances which are active.

    All instances which are active.

    Definition Classes
    StandaloneSystem
  7. def activeServers: Seq[LocalNodeClient]
    Definition Classes
    StandaloneSystem
  8. val actorMaterializer: ActorMaterializer

    The actor materializer to use.

    The actor materializer to use.

    Definition Classes
    StandaloneSystem → Client
  9. val addInstance: App[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.

    Definition Classes
    StandaloneSystem
  10. val addNode: App[Int]

    Add a new node to the cluster.

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

    Definition Classes
    StandaloneSystem
  11. def arbitraryActiveNodeAddress: prelude.Task[prelude.Address]
    Definition Classes
    StandaloneSystem
  12. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  13. def awaitTerm: App[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.

    Definition Classes
    StandaloneSystem
  14. val baseURL: URL
    Definition Classes
    StandaloneSystem
  15. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  16. def downNode(nodeIndex: Int): AppTask[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.

    Definition Classes
    StandaloneSystem
  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: App[Unit]

    Init cluster and assert healthy or fail.

    Init cluster and assert healthy or fail.

    Definition Classes
    StandaloneSystem
  24. def instances: Seq[NodeInstance]
    Definition Classes
    StandaloneSystem
  25. def isActive(index: Int): Boolean
    Definition Classes
    StandaloneSystem
  26. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  27. lazy val logger: prelude.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.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]
    Definition Classes
    StandaloneSystem
  34. val prelude: Prelude
    Definition Classes
    StandaloneSystem
  35. val proxy: StandaloneProxy
    Definition Classes
    StandaloneSystem
  36. def removeNode(nodeIndex: Int): App[node.TermReason]

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

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

    Definition Classes
    StandaloneSystem
  37. def replaceNode(nodeIndex: Int): App[Int]
    Definition Classes
    StandaloneSystem
  38. def requireHealthy: prelude.Task[Unit]
    Definition Classes
    Client
  39. def requireOkResponse(request: prelude.AkkaHttp.HttpRequest): prelude.Task[prelude.AkkaHttp.ResponseEntity]
    Definition Classes
    Client
  40. def requireResponseCode(request: prelude.AkkaHttp.HttpRequest, expected: prelude.AkkaHttp.StatusCode): prelude.Task[prelude.AkkaHttp.ResponseEntity]
    Definition Classes
    Client
  41. def requireUnhealthy: prelude.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.Task[(prelude.AkkaHttp.StatusCode, Strict)]
    Definition Classes
    Client
  44. def responseEntity(request: prelude.AkkaHttp.HttpRequest): prelude.Task[Strict]
    Definition Classes
    Client
  45. def responseJson(request: prelude.AkkaHttp.HttpRequest): prelude.Task[(prelude.AkkaHttp.StatusCode, JsValue)]
    Definition Classes
    Client
  46. def responseTxt(request0: prelude.AkkaHttp.HttpRequest): prelude.Task[(prelude.AkkaHttp.StatusCode, String)]
    Definition Classes
    Client
  47. def responseTxtAcceptAll(request: prelude.AkkaHttp.HttpRequest): prelude.Task[(prelude.AkkaHttp.StatusCode, String)]
    Definition Classes
    Client
  48. def servers: Seq[LocalNodeClient]
    Definition Classes
    StandaloneSystem
  49. val setup: Setup
    Definition Classes
    StandaloneSystem
  50. def shutdown: AppUIO[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

    Definition Classes
    StandaloneSystem
  51. def singleRequest(request: prelude.AkkaHttp.HttpRequest): prelude.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()

Inherited from StandaloneSystem

Inherited from Client

Inherited from prelude.DirectLogging

Inherited from AnyRef

Inherited from Any

Ungrouped