akka.cluster

ClusterEvent

object ClusterEvent

Domain events published to the event bus. Subscribe with:

Cluster(system).subscribe(actorRef, classOf[ClusterDomainEvent])
Linear Supertypes
AnyRef, Any
Content Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ClusterEvent
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. sealed trait ClusterDomainEvent extends AnyRef

    Marker interface for cluster domain events.

  2. case class ClusterMetricsChanged(nodeMetrics: Set[NodeMetrics]) extends ClusterDomainEvent with Product with Serializable

    Current snapshot of cluster node metrics.

  3. case class CurrentClusterState(members: SortedSet[Member] = ..., unreachable: Set[Member] = ..., seenBy: Set[Address] = ..., leader: Option[Address] = scala.None, roleLeaderMap: Map[String, Option[Address]] = ...) extends ClusterDomainEvent with Product with Serializable

    Current snapshot state of the cluster.

  4. case class LeaderChanged(leader: Option[Address]) extends ClusterDomainEvent with Product with Serializable

    Leader of the cluster members changed.

  5. sealed trait MemberEvent extends ClusterDomainEvent

    Marker interface for membership events.

  6. case class MemberExited(member: Member) extends MemberEvent with Product with Serializable

    Member status changed to Exiting.

  7. case class MemberRemoved(member: Member, previousStatus: MemberStatus) extends MemberEvent with Product with Serializable

    Member completely removed from the cluster.

  8. case class MemberUp(member: Member) extends MemberEvent with Product with Serializable

    Member status changed to Up.

  9. case class RoleLeaderChanged(role: String, leader: Option[Address]) extends ClusterDomainEvent with Product with Serializable

    First member (leader) of the members within a role set changed.

  10. case class UnreachableMember(member: Member) extends ClusterDomainEvent with Product with Serializable

    A member is considered as unreachable by the failure detector.

Value Members

  1. final def !=(arg0: AnyRef): Boolean

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

    Definition Classes
    Any
  3. final def ##(): Int

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

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

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  8. final def eq(arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  10. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  11. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  12. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  13. final def isInstanceOf[T0]: Boolean

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

    Definition Classes
    AnyRef
  15. final def notify(): Unit

    Definition Classes
    AnyRef
  16. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  17. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  18. def toString(): String

    Definition Classes
    AnyRef → Any
  19. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  20. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  21. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped