com.lightbend.akka.sbr

Class SplitBrainResolver.LeaseMajority

java.lang.Object

com.lightbend.akka.sbr.SplitBrainResolver.Strategy

com.lightbend.akka.sbr.SplitBrainResolver.LeaseMajority

All Implemented Interfaces:

akka.actor.NoSerializationVerificationNeeded

Enclosing class:

SplitBrainResolver

public static class SplitBrainResolver.LeaseMajority
extends SplitBrainResolver.Strategy

Keep the part that can acquire the lease, and down the other part.

Best effort is to keep the side that has most nodes, i.e. the majority side. This is achieved by adding a delay before trying to acquire the lease on the minority side.

If the role is defined the majority/minority is based only on members with that role. It is only counting members within the own data center.

Constructor Summary

Constructors

Constructor and Description
LeaseMajority(java.lang.String selfDc, scala.Option<java.lang.String> role, akka.coordination.lease.scaladsl.Lease _lease, scala.concurrent.duration.FiniteDuration acquireLeaseDelayForMinority)

Method Summary

Modifier and Type	Method and Description
SplitBrainResolver.Decision	decide()
scala.Option<akka.coordination.lease.scaladsl.Lease>	lease()
scala.Option<java.lang.String>	role()

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

add, addReachable, addUnreachable, allMembersInDC, hasIndirectlyConnected, indirectlyConnected, isAllUnreachableDownOrExiting, joining, 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

LeaseMajority

public LeaseMajority(java.lang.String selfDc,
                     scala.Option<java.lang.String> role,
                     akka.coordination.lease.scaladsl.Lease _lease,
                     scala.concurrent.duration.FiniteDuration acquireLeaseDelayForMinority)

Method Detail

decide

public SplitBrainResolver.Decision decide()

Specified by:

decide in class SplitBrainResolver.Strategy

lease

public scala.Option<akka.coordination.lease.scaladsl.Lease> lease()

Overrides:

lease in class SplitBrainResolver.Strategy

role

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

Specified by:

role in class SplitBrainResolver.Strategy