Class Gossip$
- java.lang.Object
-
- akka.cluster.Gossip$
-
- All Implemented Interfaces:
java.io.Serializable
public class Gossip$ extends java.lang.Object implements java.io.Serializable
INTERNAL 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.Gossip
apply(scala.collection.immutable.SortedSet<Member> members)
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 APIakka.cluster.GossipOverview
apply$default$2()
INTERNAL APIVectorClock
apply$default$3()
scala.collection.immutable.Map<UniqueAddress,java.lang.Object>
apply$default$4()
akka.cluster.Gossip
empty()
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.String
vclockName(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
members
fromJoining
toUp
.When failure detector consider a node as unavailable it will be moved from
members
tooverview.unreachable
.When a node is downed, either manually or automatically, its status is changed to
Down
. It is also removed fromoverview.seen
table. The node will reside asDown
in theoverview.unreachable
set until joining again and it will then go through the normal joining procedure.When a
Gossip
is received the version (vector clock) is used to determine if the receivedGossip
is newer or older than the current localGossip
. The receivedGossip
and localGossip
is 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
Leaving
and 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 theExiting
state and once a convergence is complete move the node toRemoved
by removing it from themembers
set and sending aRemoved
command 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
members
fromJoining
toUp
.When failure detector consider a node as unavailable it will be moved from
members
tooverview.unreachable
.When a node is downed, either manually or automatically, its status is changed to
Down
. It is also removed fromoverview.seen
table. The node will reside asDown
in theoverview.unreachable
set until joining again and it will then go through the normal joining procedure.When a
Gossip
is received the version (vector clock) is used to determine if the receivedGossip
is newer or older than the current localGossip
. The receivedGossip
and localGossip
is 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
Leaving
and 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 theExiting
state and once a convergence is complete move the node toRemoved
by removing it from themembers
set and sending aRemoved
command 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
members
fromJoining
toUp
.When failure detector consider a node as unavailable it will be moved from
members
tooverview.unreachable
.When a node is downed, either manually or automatically, its status is changed to
Down
. It is also removed fromoverview.seen
table. The node will reside asDown
in theoverview.unreachable
set until joining again and it will then go through the normal joining procedure.When a
Gossip
is received the version (vector clock) is used to determine if the receivedGossip
is newer or older than the current localGossip
. The receivedGossip
and localGossip
is 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
Leaving
and 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 theExiting
state and once a convergence is complete move the node toRemoved
by removing it from themembers
set and sending aRemoved
command 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)
-
-