public abstract class AutoDownBase
extends java.lang.Object
implements akka.actor.Actor
The implementation is split into two classes AutoDown and AutoDownBase to be able to unit test the logic without running cluster.
Constructor and Description |
---|
AutoDownBase(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter) |
Modifier and Type | Method and Description |
---|---|
abstract void |
down(akka.actor.Address node) |
void |
downOrAddPending(UniqueAddress node) |
boolean |
leader() |
scala.collection.immutable.Set<UniqueAddress> |
pendingUnreachable() |
void |
postStop() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
void |
remove(UniqueAddress node) |
scala.collection.immutable.Map<UniqueAddress,akka.actor.Cancellable> |
scheduledUnreachable() |
abstract akka.actor.Scheduler |
scheduler() |
void |
scheduleUnreachable(UniqueAddress node) |
abstract akka.actor.Address |
selfAddress() |
scala.collection.immutable.Set<MemberStatus> |
skipMemberStatus() |
void |
unreachableMember(Member m) |
public AutoDownBase(scala.concurrent.duration.FiniteDuration autoDownUnreachableAfter)
public abstract akka.actor.Address selfAddress()
public abstract void down(akka.actor.Address node)
public abstract akka.actor.Scheduler scheduler()
public scala.collection.immutable.Set<MemberStatus> skipMemberStatus()
public scala.collection.immutable.Map<UniqueAddress,akka.actor.Cancellable> scheduledUnreachable()
public scala.collection.immutable.Set<UniqueAddress> pendingUnreachable()
public boolean leader()
public void postStop()
postStop
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public void unreachableMember(Member m)
public void scheduleUnreachable(UniqueAddress node)
public void downOrAddPending(UniqueAddress node)
public void remove(UniqueAddress node)