io.atomix.protocols.raft

Class RaftProtocol.Builder

java.lang.Object

io.atomix.primitive.PrimitiveProtocol.Builder<RaftProtocol>

io.atomix.protocols.raft.RaftProtocol.Builder

All Implemented Interfaces:

io.atomix.utils.Builder<RaftProtocol>

Enclosing class:

RaftProtocol

public static class RaftProtocol.Builder
extends io.atomix.primitive.PrimitiveProtocol.Builder<RaftProtocol>

Raft protocol builder.

Method Summary

Modifier and Type	Method and Description
RaftProtocol	build()
RaftProtocol.Builder	withCommunicationStrategy(CommunicationStrategy communicationStrategy) Sets the communication strategy.
RaftProtocol.Builder	withExecutor(Executor executor) Sets the executor with which to complete proxy futures.
RaftProtocol.Builder	withMaxRetries(int maxRetries) Sets the maximum number of retries before an operation can be failed.
RaftProtocol.Builder	withMaxTimeout(Duration maxTimeout) Sets the maximum session timeout.
RaftProtocol.Builder	withMinTimeout(Duration minTimeout) Sets the minimum session timeout.
RaftProtocol.Builder	withReadConsistency(ReadConsistency readConsistency) Sets the read consistency level.
RaftProtocol.Builder	withRecoveryStrategy(io.atomix.primitive.Recovery recoveryStrategy) Sets the recovery strategy.
RaftProtocol.Builder	withRetryDelay(Duration retryDelay) Sets the operation retry delay.
RaftProtocol.Builder	withRetryDelay(long retryDelay, TimeUnit timeUnit) Sets the operation retry delay.
RaftProtocol.Builder	withRetryDelayMillis(long retryDelayMillis) Sets the operation retry delay.

Methods inherited from class java.lang.Object

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

Method Detail

withMinTimeout

public RaftProtocol.Builder withMinTimeout(Duration minTimeout)

Sets the minimum session timeout.

Parameters:

minTimeout - the minimum session timeout

Returns:

the Raft protocol builder

withMaxTimeout

public RaftProtocol.Builder withMaxTimeout(Duration maxTimeout)

Sets the maximum session timeout.

Parameters:

maxTimeout - the maximum session timeout

Returns:

the Raft protocol builder

withReadConsistency

public RaftProtocol.Builder withReadConsistency(ReadConsistency readConsistency)

Sets the read consistency level.

Parameters:

readConsistency - the read consistency level

Returns:

the Raft protocol builder

withCommunicationStrategy

public RaftProtocol.Builder withCommunicationStrategy(CommunicationStrategy communicationStrategy)

Sets the communication strategy.

Parameters:

communicationStrategy - the communication strategy

Returns:

the Raft protocol builder

withRecoveryStrategy

public RaftProtocol.Builder withRecoveryStrategy(io.atomix.primitive.Recovery recoveryStrategy)

Sets the recovery strategy.

Parameters:

recoveryStrategy - the recovery strategy

Returns:

the Raft protocol builder

withMaxRetries

public RaftProtocol.Builder withMaxRetries(int maxRetries)

Sets the maximum number of retries before an operation can be failed.

Parameters:

maxRetries - the maximum number of retries before an operation can be failed

Returns:

the proxy builder

withRetryDelayMillis

public RaftProtocol.Builder withRetryDelayMillis(long retryDelayMillis)

Sets the operation retry delay.

Parameters:

retryDelayMillis - the delay between operation retries in milliseconds

Returns:

the proxy builder

withRetryDelay

public RaftProtocol.Builder withRetryDelay(long retryDelay,
                                           TimeUnit timeUnit)

Sets the operation retry delay.

Parameters:

retryDelay - the delay between operation retries

timeUnit - the delay time unit

Returns:

the proxy builder

Throws:

NullPointerException - if the time unit is null

withRetryDelay

public RaftProtocol.Builder withRetryDelay(Duration retryDelay)

Sets the operation retry delay.

Parameters:

retryDelay - the delay between operation retries

Returns:

the proxy builder

Throws:

NullPointerException - if the delay is null

withExecutor

public RaftProtocol.Builder withExecutor(Executor executor)

Sets the executor with which to complete proxy futures.

Parameters:

executor - The executor with which to complete proxy futures.

Returns:

The proxy builder.

Throws:

NullPointerException - if the executor is null

build

public RaftProtocol build()