com.lightbend.akka.sbr

Class SplitBrainResolver

java.lang.Object

com.lightbend.akka.sbr.SplitBrainResolverBase

com.lightbend.akka.sbr.SplitBrainResolver

All Implemented Interfaces:

akka.actor.Actor, akka.actor.ActorLogging, akka.actor.Stash, akka.actor.StashSupport, akka.actor.UnrestrictedStash, akka.dispatch.RequiresMessageQueue<akka.dispatch.DequeBasedMessageQueueSemantics>

public class SplitBrainResolver
extends SplitBrainResolverBase

INTERNAL API

Unreachable members will be downed by this actor according to the given strategy. It is active on the leader node in the cluster.

The implementation is split into two classes SplitBrainResolver and SplitBrainResolverBase to be able to unit test the logic without running cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SplitBrainResolver.AcquireLease$ For delayed acquire of the lease.
static class	SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected
static class	SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected$
static class	SplitBrainResolver.AcquireLeaseAndDownUnreachable
static class	SplitBrainResolver.AcquireLeaseAndDownUnreachable$
static interface	SplitBrainResolver.AcquireLeaseDecision
static class	SplitBrainResolver.AcquireLeaseResult Response (result) of the acquire lease request.
static class	SplitBrainResolver.AcquireLeaseResult$
static interface	SplitBrainResolver.Decision
static class	SplitBrainResolver.DownAll$
static class	SplitBrainResolver.DownAllNodes Down all nodes unconditionally.
static class	SplitBrainResolver.DownIndirectlyConnected$
static class	SplitBrainResolver.DownReachable$
static class	SplitBrainResolver.DownUnreachable$
static class	SplitBrainResolver.KeepMajority Down the unreachable nodes if the current node is in the majority part based the last known membership information.
static class	SplitBrainResolver.KeepOldest Down the part that does not contain the oldest member (current singleton).
static class	SplitBrainResolver.KeepReferee Down the part that does not contain the given referee node.
static class	SplitBrainResolver.LeaseMajority Keep the part that can acquire the lease, and down the other part.
static class	SplitBrainResolver.ReachabilityChangedStats
static class	SplitBrainResolver.ReachabilityChangedStats$
static interface	SplitBrainResolver.ReleaseLeaseCondition
static class	SplitBrainResolver.ReleaseLeaseCondition$
static class	SplitBrainResolver.ReleaseLeaseResult Response (result) of the release lease request.
static class	SplitBrainResolver.ReleaseLeaseResult$
static class	SplitBrainResolver.ReverseDownIndirectlyConnected$
static class	SplitBrainResolver.StaticQuorum Down the unreachable nodes if the number of remaining nodes are greater than or equal to the given quorumSize.
static class	SplitBrainResolver.Strategy
static class	SplitBrainResolver.Tick$

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
SplitBrainResolver(scala.concurrent.duration.FiniteDuration stableAfter, SplitBrainResolver.Strategy strategy)

Method Summary

Modifier and Type	Method and Description
akka.cluster.Cluster	cluster()
void	down(akka.actor.Address node)
void	postStop()
void	preStart()
static akka.actor.Props	props(scala.concurrent.duration.FiniteDuration stableAfter, SplitBrainResolver.Strategy strategy)
java.lang.String	selfDc()
akka.cluster.UniqueAddress	selfUniqueAddress()

Methods inherited from class com.lightbend.akka.sbr.SplitBrainResolverBase

actOnDecision, addJoining, addUp, addWeaklyUp, downAllWhenUnstable, isResponsible, leader_$eq, leader, leaving, mutateMemberInfo, mutateResponsibilityInfo, newStableDeadline, reachabilityChanged, reachableDataCenter, reachableMember, receive, remove, resetStableDeadline, seenChanged, selfMemberAdded_$eq, selfMemberAdded, stableDeadline_$eq, stableDeadline, tickInterval, tickTask, unreachableDataCenter, unreachableMember, waitingForLease

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.ActorLogging

akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log, log

Methods inherited from interface akka.actor.Actor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.StashSupport

akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, clearStash, context, mailbox, prepend, self, stash, unstash, unstashAll, unstashAll

Constructor Detail

SplitBrainResolver

public SplitBrainResolver(scala.concurrent.duration.FiniteDuration stableAfter,
                          SplitBrainResolver.Strategy strategy)

Method Detail

props

public static akka.actor.Props props(scala.concurrent.duration.FiniteDuration stableAfter,
                                     SplitBrainResolver.Strategy strategy)

cluster

public akka.cluster.Cluster cluster()

selfUniqueAddress

public akka.cluster.UniqueAddress selfUniqueAddress()

Specified by:

selfUniqueAddress in class SplitBrainResolverBase

selfDc

public java.lang.String selfDc()

Specified by:

selfDc in class SplitBrainResolverBase

preStart

public void preStart()

postStop

public void postStop()

Specified by:

postStop in interface akka.actor.Actor

Specified by:

postStop in interface akka.actor.UnrestrictedStash

Overrides:

postStop in class SplitBrainResolverBase

down

public void down(akka.actor.Address node)

Specified by:

down in class SplitBrainResolverBase