com.lightbend.akka.sbr

Class SplitBrainResolver.KeepReferee

java.lang.Object

com.lightbend.akka.sbr.SplitBrainResolver.Strategy

com.lightbend.akka.sbr.SplitBrainResolver.KeepReferee

All Implemented Interfaces:

akka.actor.NoSerializationVerificationNeeded

Enclosing class:

SplitBrainResolver

public static class SplitBrainResolver.KeepReferee
extends SplitBrainResolver.Strategy

Down the part that does not contain the given referee node. If the remaining number of nodes are less than the given downAllIfLessThanNodes all nodes will be downed. If the referee node itself is removed all nodes will be downed.

It is only using members within the own data center, i.e. the referee must be in the own data center.

Constructor Summary

Constructors

Constructor and Description
KeepReferee(java.lang.String selfDc, akka.actor.Address referee, int downAllIfLessThanNodes)

Method Summary

Modifier and Type	Method and Description
SplitBrainResolver.Decision	decide()
int	downAllIfLessThanNodes()
akka.actor.Address	referee()
scala.None$	role()

Methods inherited from class com.lightbend.akka.sbr.SplitBrainResolver.Strategy

add, addReachable, addUnreachable, allMembersInDC, hasIndirectlyConnected, indirectlyConnected, isAllUnreachableDownOrExiting, joining, lease, members, members, membersWithRole, membersWithRole, nodesToDown, nodesToDown$default$1, ordering, reachability, reachableMembers, reachableMembers, reachableMembersWithRole, reachableMembersWithRole, remove, reverseDecision, seenBy, selfDc, setReachability, setSeenBy, unreachable, unreachable, unreachableButNotIndirectlyConnected, unreachableMembers, unreachableMembers, unreachableMembersWithRole, unreachableMembersWithRole

Methods inherited from class java.lang.Object

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

Constructor Detail

KeepReferee

public KeepReferee(java.lang.String selfDc,
                   akka.actor.Address referee,
                   int downAllIfLessThanNodes)

Method Detail

decide

public SplitBrainResolver.Decision decide()

Specified by:

decide in class SplitBrainResolver.Strategy

downAllIfLessThanNodes

public int downAllIfLessThanNodes()

referee

public akka.actor.Address referee()

role

public scala.None$ role()