com.lightbend.akka.sbr

Class SplitBrainResolverBase

java.lang.Object

com.lightbend.akka.sbr.SplitBrainResolverBase

All Implemented Interfaces:

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

Direct Known Subclasses:

SplitBrainResolver

public abstract class SplitBrainResolverBase
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging, akka.actor.Stash

INTERNAL API

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/interfaces inherited from interface akka.actor.Actor

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
scala.collection.immutable.Set<akka.cluster.UniqueAddress>	actOnDecision(SplitBrainResolver.Decision decision)
void	addJoining(akka.cluster.Member m)
void	addUp(akka.cluster.Member m)
void	addWeaklyUp(akka.cluster.Member m)
abstract void	down(akka.actor.Address node)
scala.concurrent.duration.FiniteDuration	downAllWhenUnstable()
boolean	isResponsible()
void	leader_$eq(boolean x$1)
boolean	leader()
void	leaving(akka.cluster.Member m)
void	mutateMemberInfo(boolean resetStable, scala.Function0<scala.runtime.BoxedUnit> f) Helper to wrap updates to strategy info with, so that stable-after timer is reset and information is logged about state change
void	mutateResponsibilityInfo(scala.Function0<scala.runtime.BoxedUnit> f) Helper to wrap updates to `leader` and `selfMemberAdded` to log changes in responsibility status
protected scala.concurrent.duration.Deadline	newStableDeadline()
void	postStop()
void	reachabilityChanged(akka.cluster.Reachability r)
void	reachableDataCenter(java.lang.String dc)
void	reachableMember(akka.cluster.Member m)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive()
void	remove(akka.cluster.Member m)
void	resetStableDeadline()
void	seenChanged(scala.collection.immutable.Set<akka.actor.Address> seenBy)
abstract java.lang.String	selfDc()
void	selfMemberAdded_$eq(boolean x$1)
boolean	selfMemberAdded()
abstract akka.cluster.UniqueAddress	selfUniqueAddress()
void	stableDeadline_$eq(scala.concurrent.duration.Deadline x$1)
scala.concurrent.duration.Deadline	stableDeadline()
scala.concurrent.duration.FiniteDuration	tickInterval()
akka.actor.Cancellable	tickTask()
void	unreachableDataCenter(java.lang.String dc)
void	unreachableMember(akka.cluster.Member m)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	waitingForLease(SplitBrainResolver.Decision decision)

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, preStart, 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

SplitBrainResolverBase

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

Method Detail

actOnDecision

public scala.collection.immutable.Set<akka.cluster.UniqueAddress> actOnDecision(SplitBrainResolver.Decision decision)

Parameters:

decision - (undocumented)

Returns:

the nodes that were downed

addJoining

public void addJoining(akka.cluster.Member m)

addUp

public void addUp(akka.cluster.Member m)

addWeaklyUp

public void addWeaklyUp(akka.cluster.Member m)

down

public abstract void down(akka.actor.Address node)

downAllWhenUnstable

public scala.concurrent.duration.FiniteDuration downAllWhenUnstable()

isResponsible

public boolean isResponsible()

leader

public boolean leader()

leader_$eq

public void leader_$eq(boolean x$1)

leaving

public void leaving(akka.cluster.Member m)

mutateMemberInfo

public void mutateMemberInfo(boolean resetStable,
                             scala.Function0<scala.runtime.BoxedUnit> f)

Helper to wrap updates to strategy info with, so that stable-after timer is reset and information is logged about state change

mutateResponsibilityInfo

public void mutateResponsibilityInfo(scala.Function0<scala.runtime.BoxedUnit> f)

Helper to wrap updates to `leader` and `selfMemberAdded` to log changes in responsibility status

newStableDeadline

protected scala.concurrent.duration.Deadline newStableDeadline()

postStop

public void postStop()

Specified by:

postStop in interface akka.actor.Actor

Specified by:

postStop in interface akka.actor.UnrestrictedStash

reachabilityChanged

public void reachabilityChanged(akka.cluster.Reachability r)

reachableDataCenter

public void reachableDataCenter(java.lang.String dc)

reachableMember

public void reachableMember(akka.cluster.Member m)

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()

Specified by:

receive in interface akka.actor.Actor

remove

public void remove(akka.cluster.Member m)

resetStableDeadline

public void resetStableDeadline()

seenChanged

public void seenChanged(scala.collection.immutable.Set<akka.actor.Address> seenBy)

selfDc

public abstract java.lang.String selfDc()

selfMemberAdded

public boolean selfMemberAdded()

selfMemberAdded_$eq

public void selfMemberAdded_$eq(boolean x$1)

selfUniqueAddress

public abstract akka.cluster.UniqueAddress selfUniqueAddress()

stableDeadline

public scala.concurrent.duration.Deadline stableDeadline()

stableDeadline_$eq

public void stableDeadline_$eq(scala.concurrent.duration.Deadline x$1)

tickInterval

public scala.concurrent.duration.FiniteDuration tickInterval()

tickTask

public akka.actor.Cancellable tickTask()

unreachableDataCenter

public void unreachableDataCenter(java.lang.String dc)

unreachableMember

public void unreachableMember(akka.cluster.Member m)

waitingForLease

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForLease(SplitBrainResolver.Decision decision)