Akka.Cluster by Akka.NET Team

<PackageReference Include="Akka.Cluster" Version="1.4.41" />

.NET API 282,624 bytes

 MembershipState

sealed class MembershipState : IEquatable<MembershipState>
INTERNAL API
public static readonly ImmutableHashSet<MemberStatus> ConvergenceSkipUnreachableWithMemberStatus

If there are unreachable members in the cluster with any of these statuses, they will be skipped during convergence checks.

public static readonly ImmutableHashSet<MemberStatus> RemoveUnreachableWithMemberStatus

If there are unreachable members in the cluster with any of these statuses, they will be pruned from the local gossip

public Reachability DcReachability { get; }

TODO: this will eventually need to be made DC-aware and tailored specifically to the current DC

public Reachability DcReachabilityExcludingDownedObservers { get; }

public Gossip LatestGossip { get; }

public UniqueAddress Leader { get; }

public ImmutableSortedSet<Member> Members { get; }

public GossipOverview Overview { get; }

public Member SelfMember { get; }

public UniqueAddress SelfUniqueAddress { get; }

public MembershipState(Gossip latestGossip, UniqueAddress selfUniqueAddress)

public bool Convergence(IImmutableSet<UniqueAddress> exitingConfirmed)

First check that: 1. we don't have any members that are unreachable, or 2. all unreachable members in the set have status DOWN or EXITING Else we can't continue to check for convergence. When that is done we check that all members with a convergence status is in the seen table and has the latest vector clock version.

public MembershipState Copy(Gossip gossip = null, UniqueAddress selfUniqueAddress = null)

public bool Equals(MembershipState other)

public bool IsLeader(UniqueAddress node)

public bool IsReachableExcludingDownedObservers(UniqueAddress toAddress)

public UniqueAddress LeaderOf(IImmutableSet<Member> mbrs)

public UniqueAddress RoleLeader(string role)

public MembershipState Seen()

Copies the current MembershipState and marks the LatestGossip as Seen by the SelfUniqueAddress.

public bool ValidNodeForGossip(UniqueAddress node)

Never gossip to self and not to node marked as unreachable by self (heartbeat messages are not getting through so no point in trying to gossip). Nodes marked as unreachable by others are still valid targets for gossip.