| Package | Description |
|---|---|
| io.atomix.protocols.raft |
Core interfaces for operating on replicated state machines in the Raft cluster.
|
| Modifier and Type | Method and Description |
|---|---|
RaftServer.Builder |
RaftServer.Builder.addPrimitiveType(io.atomix.primitive.PrimitiveType primitiveType)
Adds a primitive type to the registry.
|
static RaftServer.Builder |
RaftServer.builder()
Returns a new Raft server builder using the default host:port.
|
static RaftServer.Builder |
RaftServer.builder(io.atomix.cluster.NodeId localNodeId)
Returns a new Raft server builder.
|
RaftServer.Builder |
RaftServer.Builder.withClusterService(io.atomix.cluster.ClusterService clusterService)
Sets the cluster service.
|
RaftServer.Builder |
RaftServer.Builder.withElectionTimeout(Duration electionTimeout)
Sets the Raft election timeout, returning the Raft configuration for method chaining.
|
RaftServer.Builder |
RaftServer.Builder.withHeartbeatInterval(Duration heartbeatInterval)
Sets the Raft heartbeat interval, returning the Raft configuration for method chaining.
|
RaftServer.Builder |
RaftServer.Builder.withName(String name)
Sets the server name.
|
RaftServer.Builder |
RaftServer.Builder.withPrimitiveTypes(io.atomix.primitive.PrimitiveTypeRegistry primitiveTypes)
Sets the primitive types.
|
RaftServer.Builder |
RaftServer.Builder.withProtocol(RaftServerProtocol protocol)
Sets the server protocol.
|
RaftServer.Builder |
RaftServer.Builder.withSessionTimeout(Duration sessionTimeout)
Sets the Raft session timeout, returning the Raft configuration for method chaining.
|
RaftServer.Builder |
RaftServer.Builder.withStorage(RaftStorage storage)
Sets the storage module.
|
RaftServer.Builder |
RaftServer.Builder.withThreadModel(io.atomix.utils.concurrent.ThreadModel threadModel)
Sets the server thread model.
|
RaftServer.Builder |
RaftServer.Builder.withThreadPoolSize(int threadPoolSize)
Sets the server thread pool size.
|
RaftServer.Builder |
RaftServer.Builder.withType(RaftMember.Type type)
Deprecated.
|
Copyright © 2013–2018. All rights reserved.