Packages

final class CurrentClusterState extends Product5[SortedSet[Member], Set[Member], Set[Address], Option[Address], Map[String, Option[Address]]] with Serializable

Current snapshot state of the cluster. Sent to new subscriber.

Annotations
@SerialVersionUID() @nowarn()
Source
ClusterEvent.scala
Linear Supertypes
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CurrentClusterState
  2. Serializable
  3. Product5
  4. Product
  5. Equals
  6. AnyRef
  7. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new CurrentClusterState(members: SortedSet[Member], unreachable: Set[Member], seenBy: Set[Address], leader: Option[Address], roleLeaderMap: Map[String, Option[Address]], unreachableDataCenters: Set[DataCenter], memberTombstones: Set[UniqueAddress])

    leader

    leader of the data center of this node

    memberTombstones

    INTERNAL API

  2. new CurrentClusterState(members: SortedSet[Member] = immutable.SortedSet.empty, unreachable: Set[Member] = Set.empty, seenBy: Set[Address] = Set.empty, leader: Option[Address] = None, roleLeaderMap: Map[String, Option[Address]] = Map.empty)
    Annotations
    @deprecated
    Deprecated

    (Since version 2.6.10) use main constructor

  3. new CurrentClusterState(members: SortedSet[Member], unreachable: Set[Member], seenBy: Set[Address], leader: Option[Address], roleLeaderMap: Map[String, Option[Address]], unreachableDataCenters: Set[DataCenter])
    Annotations
    @deprecated
    Deprecated

    (Since version 2.6.10) use main constructor

Value Members

  1. def _1: SortedSet[Member]
    Definition Classes
    CurrentClusterState → Product5
  2. def _2: Set[Member]
    Definition Classes
    CurrentClusterState → Product5
  3. def _3: Set[Address]
    Definition Classes
    CurrentClusterState → Product5
  4. def _4: Option[Address]
    Definition Classes
    CurrentClusterState → Product5
  5. def _5: Map[String, Option[Address]]
    Definition Classes
    CurrentClusterState → Product5
  6. def allRoles: Set[String]

    All node roles in the cluster

  7. def canEqual(that: Any): Boolean
    Definition Classes
    CurrentClusterState → Equals
  8. def copy(members: SortedSet[Member] = this.members, unreachable: Set[Member] = this.unreachable, seenBy: Set[Address] = this.seenBy, leader: Option[Address] = this.leader, roleLeaderMap: Map[String, Option[Address]] = this.roleLeaderMap): CurrentClusterState
  9. def equals(other: Any): Boolean
    Definition Classes
    CurrentClusterState → Equals → AnyRef → Any
  10. def getAllDataCenters: Set[String]

    Java API: All data centers in the cluster

  11. def getAllRoles: Set[String]

    Java API: All node roles in the cluster

  12. def getLeader: Address

    Java API: get address of current data center leader, or null if none

  13. def getMembers: Iterable[Member]

    Java API: get current member list.

  14. def getRoleLeader(role: String): Address

    Java API: get address of current leader, if any, within the data center that has the given role or null if no such node exists

  15. def getSeenBy: Set[Address]

    Java API: get current “seen-by” set.

  16. def getUnreachable: Set[Member]

    Java API: get current unreachable set.

  17. def getUnreachableDataCenters: Set[String]

    Java API: All data centers in the cluster

  18. def hashCode(): Int
    Definition Classes
    CurrentClusterState → AnyRef → Any
  19. val leader: Option[Address]
  20. val members: SortedSet[Member]
  21. def productArity: Int
    Definition Classes
    Product5 → Product
  22. def productElement(n: Int): Any
    Definition Classes
    Product5 → Product
    Annotations
    @throws(classOf[java.lang.IndexOutOfBoundsException])
  23. def productElementName(n: Int): String
    Definition Classes
    Product
  24. def productElementNames: Iterator[String]
    Definition Classes
    Product
  25. def productIterator: Iterator[Any]
    Definition Classes
    Product
  26. def productPrefix: String
    Definition Classes
    CurrentClusterState → Product
  27. def roleLeader(role: String): Option[Address]

    get address of current leader, if any, within the data center that has the given role

  28. val roleLeaderMap: Map[String, Option[Address]]
  29. val seenBy: Set[Address]
  30. def toString(): String
    Definition Classes
    CurrentClusterState → AnyRef → Any
  31. val unreachable: Set[Member]
  32. val unreachableDataCenters: Set[DataCenter]
  33. def withMemberTombstones(memberTombstones: Set[UniqueAddress]): CurrentClusterState
  34. def withUnreachableDataCenters(unreachableDataCenters: Set[DataCenter]): CurrentClusterState

    Replace the set of unreachable datacenters with the given set

Deprecated Value Members

  1. def allDataCenters: Set[String]

    All data centers in the cluster

    All data centers in the cluster

    Annotations
    @deprecated
    Deprecated

    (Since version 2.10.0) Use Akka Distributed Cluster instead