raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

=clu #13584 mark as experimental and some doc clarificiations

Browse source
This commit is contained in:
Patrik Nordwall 2015-09-04 12:38:49 +02:00
parent c08bc317e2
commit 22b8853314
18 changed files with 109 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-cluster-metrics/src/main/scala/akka/cluster/metrics/ClusterMetricsCollector.scala
View file

@ -179,8 +179,10 @@ private[metrics] class ClusterMetricsCollector extends Actor with ActorLogging {
case MemberRemoved(m, _) ⇒ removeMember(m)
case MemberExited(m) ⇒ removeMember(m)
case UnreachableMember(m) ⇒ removeMember(m)
case ReachableMember(m) ⇒ if (m.status == MemberStatus.Up) addMember(m)
case _: MemberEvent ⇒ // not interested in other types of MemberEvent
case ReachableMember(m) ⇒
if (m.status == MemberStatus.Up || m.status == MemberStatus.WeaklyUp)
addMember(m)
case _: MemberEvent ⇒ // not interested in other types of MemberEvent
}
@ -209,7 +211,9 @@ private[metrics] class ClusterMetricsCollector extends Actor with ActorLogging {
* Updates the initial node ring for those nodes that are [[akka.cluster.MemberStatus]] `Up`.
*/
def receiveState(state: CurrentClusterState): Unit =
nodes = (state.members -- state.unreachable) collect { case m if m.status == MemberStatus.Up ⇒ m.address }
nodes = (state.members -- state.unreachable) collect {
case m if m.status == MemberStatus.Up || m.status == MemberStatus.WeaklyUp ⇒ m.address
}
/**
* Samples the latest metrics for the node, updates metrics statistics in