io.atomix.protocols.raft

Class RaftProtocol

java.lang.Object

io.atomix.protocols.raft.RaftProtocol

All Implemented Interfaces:

io.atomix.primitive.PrimitiveProtocol

public class RaftProtocol
extends Object
implements io.atomix.primitive.PrimitiveProtocol

Raft protocol.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RaftProtocol.Builder Raft protocol builder.

Nested classes/interfaces inherited from interface io.atomix.primitive.PrimitiveProtocol

io.atomix.primitive.PrimitiveProtocol.Type

Field Summary

Fields

Modifier and Type	Field and Description
static io.atomix.primitive.PrimitiveProtocol.Type	TYPE

Method Summary

Modifier and Type	Method and Description
static RaftProtocol.Builder	builder() Returns a new Raft protocol builder.
static RaftProtocol.Builder	builder(String group) Returns a new Raft protocol builder.
CommunicationStrategy	communicationStrategy() Returns the communication strategy.
Executor	executor() Returns the proxy executor.
String	group()
int	maxRetries() Returns the maximum number of allowed retries.
Duration	maxTimeout() Returns the maximum timeout.
Duration	minTimeout() Returns the minimum timeout.
ReadConsistency	readConsistency() Returns the read consistency.
io.atomix.primitive.Recovery	recoveryStrategy() Returns the recovery strategy.
Duration	retryDelay() Returns the retry delay.
io.atomix.primitive.PrimitiveProtocol.Type	type()

Methods inherited from class java.lang.Object

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

Field Detail

TYPE

public static final io.atomix.primitive.PrimitiveProtocol.Type TYPE

Method Detail

builder

public static RaftProtocol.Builder builder()

Returns a new Raft protocol builder.

Returns:

a new Raft protocol builder

builder

public static RaftProtocol.Builder builder(String group)

Returns a new Raft protocol builder.

Parameters:

group - the partition group

Returns:

the Raft protocol builder

type

public io.atomix.primitive.PrimitiveProtocol.Type type()

Specified by:

type in interface io.atomix.primitive.PrimitiveProtocol

group

public String group()

Specified by:

group in interface io.atomix.primitive.PrimitiveProtocol

minTimeout

public Duration minTimeout()

Returns the minimum timeout.

Returns:

the minimum timeout

maxTimeout

public Duration maxTimeout()

Returns the maximum timeout.

Returns:

the maximum timeout

readConsistency

public ReadConsistency readConsistency()

Returns the read consistency.

Returns:

the read consistency

communicationStrategy

public CommunicationStrategy communicationStrategy()

Returns the communication strategy.

Returns:

the communication strategy

recoveryStrategy

public io.atomix.primitive.Recovery recoveryStrategy()

Returns the recovery strategy.

Returns:

the recovery strategy

maxRetries

public int maxRetries()

Returns the maximum number of allowed retries.

Returns:

the maximum number of allowed retries

retryDelay

public Duration retryDelay()

Returns the retry delay.

Returns:

the retry delay

executor

public Executor executor()

Returns the proxy executor.

Returns:

the proxy executor