Class Gossip$
- java.lang.Object
-
- akka.cluster.Gossip$
-
- All Implemented Interfaces:
java.io.Serializable
public class Gossip$ extends java.lang.Object implements java.io.SerializableINTERNAL API- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description Gossip$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description akka.cluster.GossipOverview$lessinit$greater$default$2()INTERNAL APIVectorClock$lessinit$greater$default$3()scala.collection.immutable.Map<UniqueAddress,java.lang.Object>$lessinit$greater$default$4()akka.cluster.Gossipapply(scala.collection.immutable.SortedSet<Member> members)akka.cluster.Gossipapply(scala.collection.immutable.SortedSet<Member> members, akka.cluster.GossipOverview overview, VectorClock version, scala.collection.immutable.Map<UniqueAddress,java.lang.Object> tombstones)INTERNAL APIakka.cluster.GossipOverviewapply$default$2()INTERNAL APIVectorClockapply$default$3()scala.collection.immutable.Map<UniqueAddress,java.lang.Object>apply$default$4()akka.cluster.Gossipempty()scala.collection.immutable.SortedSet<Member>emptyMembers()scala.Option<scala.Tuple4<scala.collection.immutable.SortedSet<Member>,akka.cluster.GossipOverview,VectorClock,scala.collection.immutable.Map<UniqueAddress,java.lang.Object>>>unapply(akka.cluster.Gossip x$0)java.lang.StringvclockName(UniqueAddress node)
-
-
-
Field Detail
-
MODULE$
public static final Gossip$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
$lessinit$greater$default$2
public akka.cluster.GossipOverview $lessinit$greater$default$2()
INTERNAL APIRepresents the state of the cluster; cluster ring membership, ring convergence - all versioned by a vector clock.
When a node is joining the
Member, with statusJoining, is added tomembers. If the joining node was downed it is moved fromoverview.unreachable(statusDown) tomembers(statusJoining). It cannot rejoin if not first downed.When convergence is reached the leader change status of
membersfromJoiningtoUp.When failure detector consider a node as unavailable it will be moved from
memberstooverview.unreachable.When a node is downed, either manually or automatically, its status is changed to
Down. It is also removed fromoverview.seentable. The node will reside asDownin theoverview.unreachableset until joining again and it will then go through the normal joining procedure.When a
Gossipis received the version (vector clock) is used to determine if the receivedGossipis newer or older than the current localGossip. The receivedGossipand localGossipis merged in case of conflicting version, i.e. vector clocks without same history.When a node is told by the user to leave the cluster the leader will move it to
Leavingand then rebalance and repartition the cluster and start hand-off by migrating the actors from the leaving node to the new partitions. Once this process is complete the leader will move the node to theExitingstate and once a convergence is complete move the node toRemovedby removing it from themembersset and sending aRemovedcommand to the removed node telling it to shut itself down.
-
$lessinit$greater$default$3
public VectorClock $lessinit$greater$default$3()
-
$lessinit$greater$default$4
public scala.collection.immutable.Map<UniqueAddress,java.lang.Object> $lessinit$greater$default$4()
-
emptyMembers
public scala.collection.immutable.SortedSet<Member> emptyMembers()
-
empty
public akka.cluster.Gossip empty()
-
apply
public akka.cluster.Gossip apply(scala.collection.immutable.SortedSet<Member> members)
-
apply$default$2
public akka.cluster.GossipOverview apply$default$2()
INTERNAL APIRepresents the state of the cluster; cluster ring membership, ring convergence - all versioned by a vector clock.
When a node is joining the
Member, with statusJoining, is added tomembers. If the joining node was downed it is moved fromoverview.unreachable(statusDown) tomembers(statusJoining). It cannot rejoin if not first downed.When convergence is reached the leader change status of
membersfromJoiningtoUp.When failure detector consider a node as unavailable it will be moved from
memberstooverview.unreachable.When a node is downed, either manually or automatically, its status is changed to
Down. It is also removed fromoverview.seentable. The node will reside asDownin theoverview.unreachableset until joining again and it will then go through the normal joining procedure.When a
Gossipis received the version (vector clock) is used to determine if the receivedGossipis newer or older than the current localGossip. The receivedGossipand localGossipis merged in case of conflicting version, i.e. vector clocks without same history.When a node is told by the user to leave the cluster the leader will move it to
Leavingand then rebalance and repartition the cluster and start hand-off by migrating the actors from the leaving node to the new partitions. Once this process is complete the leader will move the node to theExitingstate and once a convergence is complete move the node toRemovedby removing it from themembersset and sending aRemovedcommand to the removed node telling it to shut itself down.
-
apply$default$3
public VectorClock apply$default$3()
-
apply$default$4
public scala.collection.immutable.Map<UniqueAddress,java.lang.Object> apply$default$4()
-
vclockName
public java.lang.String vclockName(UniqueAddress node)
-
apply
public akka.cluster.Gossip apply(scala.collection.immutable.SortedSet<Member> members, akka.cluster.GossipOverview overview, VectorClock version, scala.collection.immutable.Map<UniqueAddress,java.lang.Object> tombstones)
INTERNAL APIRepresents the state of the cluster; cluster ring membership, ring convergence - all versioned by a vector clock.
When a node is joining the
Member, with statusJoining, is added tomembers. If the joining node was downed it is moved fromoverview.unreachable(statusDown) tomembers(statusJoining). It cannot rejoin if not first downed.When convergence is reached the leader change status of
membersfromJoiningtoUp.When failure detector consider a node as unavailable it will be moved from
memberstooverview.unreachable.When a node is downed, either manually or automatically, its status is changed to
Down. It is also removed fromoverview.seentable. The node will reside asDownin theoverview.unreachableset until joining again and it will then go through the normal joining procedure.When a
Gossipis received the version (vector clock) is used to determine if the receivedGossipis newer or older than the current localGossip. The receivedGossipand localGossipis merged in case of conflicting version, i.e. vector clocks without same history.When a node is told by the user to leave the cluster the leader will move it to
Leavingand then rebalance and repartition the cluster and start hand-off by migrating the actors from the leaving node to the new partitions. Once this process is complete the leader will move the node to theExitingstate and once a convergence is complete move the node toRemovedby removing it from themembersset and sending aRemovedcommand to the removed node telling it to shut itself down.
-
unapply
public scala.Option<scala.Tuple4<scala.collection.immutable.SortedSet<Member>,akka.cluster.GossipOverview,VectorClock,scala.collection.immutable.Map<UniqueAddress,java.lang.Object>>> unapply(akka.cluster.Gossip x$0)
-
-