com.lightbend.akka.sbr

Class SplitBrainResolver.KeepMajority

java.lang.Object

com.lightbend.akka.sbr.SplitBrainResolver.Strategy

com.lightbend.akka.sbr.SplitBrainResolver.KeepMajority

All Implemented Interfaces:

akka.actor.NoSerializationVerificationNeeded

Enclosing class:

SplitBrainResolver

public static class SplitBrainResolver.KeepMajority
extends SplitBrainResolver.Strategy

Down the unreachable nodes if the current node is in the majority part based the last known membership information. Otherwise down the reachable nodes, i.e. the own part. If the the parts are of equal size the part containing the node with the lowest address is kept.

If the role is defined the decision is based only on members with that role.

Note that if there are more than two partitions and none is in majority each part will shutdown itself, terminating the whole cluster.

It is only counting members within the own data center.

Constructor Summary

Constructors

Constructor and Description
KeepMajority(java.lang.String selfDc, scala.Option<java.lang.String> role)

Method Summary

Modifier and Type	Method and Description
SplitBrainResolver.Decision	decide()
scala.Option<java.lang.String>	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

KeepMajority

public KeepMajority(java.lang.String selfDc,
                    scala.Option<java.lang.String> role)

Method Detail

decide

public SplitBrainResolver.Decision decide()

Specified by:

decide in class SplitBrainResolver.Strategy

role

public scala.Option<java.lang.String> role()

Specified by:

role in class SplitBrainResolver.Strategy