Class SplitBrainResolverBase

    • Constructor Detail

      • SplitBrainResolverBase

        public SplitBrainResolverBase​(scala.concurrent.duration.FiniteDuration stableAfter,
                                      DowningStrategy _strategy)
    • Method Detail

      • addJoining

        public void addJoining​(Member m)
      • addUp

        public void addUp​(Member m)
      • addWeaklyUp

        public void addWeaklyUp​(Member m)
      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Specified by:
        context in interface StashSupport
      • 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​(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()
      • observeDecision

        public void observeDecision​(DowningStrategy.Decision decision,
                                    scala.collection.immutable.Set<UniqueAddress> nodesToDown,
                                    scala.collection.immutable.Set<java.lang.String> unreachableDataCenters)
      • postStop

        public void postStop()
        Description copied from interface: Actor
        User overridable callback.

        Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
        Specified by:
        postStop in interface Actor
        Specified by:
        postStop in interface UnrestrictedStash
      • reachabilityChanged

        public void reachabilityChanged​(Reachability r)
      • reachableDataCenter

        public void reachableDataCenter​(java.lang.String dc)
      • reachableMember

        public void reachableMember​(Member m)
      • receive

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Description copied from interface: Actor
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
        Specified by:
        receive in interface Actor
      • remove

        public void remove​(Member m)
      • resetStableDeadline

        public void resetStableDeadline()
      • seenChanged

        public void seenChanged​(scala.collection.immutable.Set<Address> seenBy)
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Specified by:
        self in interface StashSupport
      • selfDc

        public abstract java.lang.String selfDc()
      • selfMemberAdded

        public boolean selfMemberAdded()
      • selfMemberAdded_$eq

        public void selfMemberAdded_$eq​(boolean x$1)
      • selfUniqueAddress

        public abstract 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()
      • unreachableDataCenter

        public void unreachableDataCenter​(java.lang.String dc)
      • unreachableMember

        public void unreachableMember​(Member m)
      • waitingForLease

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