io.atomix.protocols.raft.utils

Class Quorum

java.lang.Object

io.atomix.protocols.raft.utils.Quorum

public class Quorum
extends Object

Quorum helper. Completes and invokes a callback when the number of succeed() or fail() calls equal the expected quorum count. Not threadsafe.

Constructor Summary

Constructors

Constructor and Description
Quorum(int quorum, Consumer<Boolean> callback)

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancels the quorum.
Quorum	fail() Indicates that a call in the quorum failed.
Quorum	succeed() Indicates that a call in the quorum succeeded.

Methods inherited from class java.lang.Object

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

Constructor Detail

Quorum

public Quorum(int quorum,
              Consumer<Boolean> callback)

Method Detail

succeed

public Quorum succeed()

Indicates that a call in the quorum succeeded.

fail

public Quorum fail()

Indicates that a call in the quorum failed.

cancel

public void cancel()

Cancels the quorum. Once this method has been called, the quorum will be marked complete and the handler will never be called.