Packages

final case class PekkoCluster[F[_]](system: ActorSystem[_], dispatcher: Dispatcher[F], cluster: Cluster, sharding: ClusterSharding)(implicit evidence$1: Async[F]) extends Product with Serializable

Actor system and cluster sharding extension as well as dispatcher tied to its resource scope.

system

actor system

dispatcher

effects dispatcher tied to the cluster resource scope

cluster

cluster extension

sharding

cluster sharding extension

Linear Supertypes
Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PekkoCluster
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new PekkoCluster(system: ActorSystem[_], dispatcher: Dispatcher[F], cluster: Cluster, sharding: ClusterSharding)(implicit arg0: Async[F])

    system

    actor system

    dispatcher

    effects dispatcher tied to the cluster resource scope

    cluster

    cluster extension

    sharding

    cluster sharding extension

Value Members

  1. val cluster: Cluster
  2. val dispatcher: Dispatcher[F]
  3. def isMemberUp: F[Boolean]

    Returns true if the cluster member is up.

    Returns true if the cluster member is up. Can be used for readiness checks.

  4. def productElementNames: Iterator[String]
    Definition Classes
    Product
  5. val sharding: ClusterSharding
  6. val system: ActorSystem[_]