io.atomix.protocols.backup

Class MultiPrimaryProtocol.Builder

java.lang.Object

io.atomix.primitive.PrimitiveProtocol.Builder

io.atomix.protocols.backup.MultiPrimaryProtocol.Builder

All Implemented Interfaces:

io.atomix.utils.Builder

Enclosing class:

MultiPrimaryProtocol

public static class MultiPrimaryProtocol.Builder
extends io.atomix.primitive.PrimitiveProtocol.Builder

Multi-primary protocol builder.

Method Summary

Modifier and Type	Method and Description
MultiPrimaryProtocol	build()
MultiPrimaryProtocol.Builder	withBackups(int numBackups) Sets the number of backups.
MultiPrimaryProtocol.Builder	withConsistency(io.atomix.primitive.Consistency consistency) Sets the protocol consistency model.
MultiPrimaryProtocol.Builder	withExecutor(Executor executor) Sets the executor with which to complete proxy futures.
MultiPrimaryProtocol.Builder	withMaxRetries(int maxRetries) Sets the maximum number of retries before an operation can be failed.
MultiPrimaryProtocol.Builder	withRecovery(io.atomix.primitive.Recovery recovery) Sets the protocol recovery strategy.
MultiPrimaryProtocol.Builder	withReplication(io.atomix.primitive.Replication replication) Sets the protocol replication strategy.
MultiPrimaryProtocol.Builder	withRetryDelay(Duration retryDelay) Sets the operation retry delay.
MultiPrimaryProtocol.Builder	withRetryDelay(long retryDelay, TimeUnit timeUnit) Sets the operation retry delay.
MultiPrimaryProtocol.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

withConsistency

public MultiPrimaryProtocol.Builder withConsistency(io.atomix.primitive.Consistency consistency)

Sets the protocol consistency model.

Parameters:

consistency - the protocol consistency model

Returns:

the protocol builder

withReplication

public MultiPrimaryProtocol.Builder withReplication(io.atomix.primitive.Replication replication)

Sets the protocol replication strategy.

Parameters:

replication - the protocol replication strategy

Returns:

the protocol builder

withRecovery

public MultiPrimaryProtocol.Builder withRecovery(io.atomix.primitive.Recovery recovery)

Sets the protocol recovery strategy.

Parameters:

recovery - the protocol recovery strategy

Returns:

the protocol builder

withBackups

public MultiPrimaryProtocol.Builder withBackups(int numBackups)

Sets the number of backups.

Parameters:

numBackups - the number of backups

Returns:

the protocol builder

withMaxRetries

public MultiPrimaryProtocol.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 MultiPrimaryProtocol.Builder withRetryDelayMillis(long retryDelayMillis)

Sets the operation retry delay.

Parameters:

retryDelayMillis - the delay between operation retries in milliseconds

Returns:

the proxy builder

withRetryDelay

public MultiPrimaryProtocol.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 MultiPrimaryProtocol.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 MultiPrimaryProtocol.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 MultiPrimaryProtocol build()