A B C D E F G H I J K L M N O P Q R S T U V W

A

AbstractRaftRequest - Class in io.atomix.protocols.raft.protocol

Base request for all client requests.

AbstractRaftRequest() - Constructor for class io.atomix.protocols.raft.protocol.AbstractRaftRequest

AbstractRaftResponse - Class in io.atomix.protocols.raft.protocol

Base response for all client responses.

AbstractRole - Class in io.atomix.protocols.raft.roles

Abstract state.

accepted() - Method in class io.atomix.protocols.raft.protocol.PollResponse

Returns a boolean indicating whether the poll was accepted.

active() - Method in enum io.atomix.protocols.raft.RaftServer.Role

Returns whether the role is a voting Raft member role.

ActiveRole - Class in io.atomix.protocols.raft.roles

Abstract active state.

addEntry(RaftLogEntry) - Method in class io.atomix.protocols.raft.protocol.AppendRequest.Builder

Adds an entry to the request.

addLeaderElectionListener(Consumer<RaftMember>) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Adds a listener to be called when a leader is elected.

addListener(RaftClusterEventListener) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Registers a callback to be called when a member leaves the cluster.

addListener(SessionEventListener) - Method in class io.atomix.protocols.raft.session.RaftSession

addPrimitiveType(PrimitiveType) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Adds a primitive type to the registry.

addRoleChangeListener(Consumer<RaftServer.Role>) - Method in interface io.atomix.protocols.raft.RaftServer

Adds a role change listener.

addSession(RaftSession) - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry

Adds a session.

addTypeChangeListener(Consumer<RaftMember.Type>) - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Adds a listener to be called when the member's type changes.

append(NodeId, AppendRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends an append request to the given node.

AppendRequest - Class in io.atomix.protocols.raft.protocol

Append entries request.

AppendRequest(long, String, long, long, List<RaftLogEntry>, long) - Constructor for class io.atomix.protocols.raft.protocol.AppendRequest

AppendRequest.Builder - Class in io.atomix.protocols.raft.protocol

Append request builder.

AppendResponse - Class in io.atomix.protocols.raft.protocol

Server append entries response.

AppendResponse(RaftResponse.Status, RaftError, long, boolean, long) - Constructor for class io.atomix.protocols.raft.protocol.AppendResponse

AppendResponse.Builder - Class in io.atomix.protocols.raft.protocol

Append response builder.

ApplicationException(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.ApplicationException

ApplicationException(Throwable) - Constructor for exception io.atomix.protocols.raft.RaftException.ApplicationException

B

backups() - Method in class io.atomix.protocols.raft.partition.RaftPartition

bootstrap(NodeId...) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Bootstraps the cluster.

bootstrap(Collection<NodeId>) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Bootstraps the cluster.

bootstrap() - Method in interface io.atomix.protocols.raft.RaftServer

Bootstraps a single-node cluster.

bootstrap(NodeId...) - Method in interface io.atomix.protocols.raft.RaftServer

Bootstraps the cluster using the provided cluster configuration.

bootstrap(Collection<NodeId>) - Method in interface io.atomix.protocols.raft.RaftServer

Bootstraps the cluster using the provided cluster configuration.

build() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup.Builder

build() - Method in class io.atomix.protocols.raft.protocol.AppendRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.AppendResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.CloseSessionRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.CloseSessionResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.CommandRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.CommandResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.ConfigureResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.HeartbeatRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.HeartbeatResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.InstallRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.InstallResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.JoinRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.JoinResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.KeepAliveRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.KeepAliveResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.LeaveRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.LeaveResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.MetadataRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.MetadataResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.OpenSessionResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.PollRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.PollResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.PublishRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.QueryRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.QueryResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.ReconfigureRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.ReconfigureResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.ResetRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.TransferRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.TransferResponse.Builder

build() - Method in class io.atomix.protocols.raft.protocol.VoteRequest.Builder

build() - Method in class io.atomix.protocols.raft.protocol.VoteResponse.Builder

build() - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

build() - Method in class io.atomix.protocols.raft.storage.log.RaftLog.Builder

build() - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Builds the RaftStorage object.

build() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor.Builder

Builds the snapshot descriptor.

builder(String) - Static method in class io.atomix.protocols.raft.partition.RaftPartitionGroup

Returns a new Raft partition group builder.

builder() - Static method in class io.atomix.protocols.raft.protocol.AppendRequest

Returns a new append request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.AppendRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.AppendResponse

Returns a new append response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.AppendResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.CloseSessionRequest

Returns a new unregister request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.CloseSessionRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.CloseSessionResponse

Returns a new keep alive response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.CloseSessionResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.CommandRequest

Returns a new submit request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.CommandRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.CommandResponse

Returns a new submit response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.CommandResponse.Builder

Builder() - Constructor for class io.atomix.protocols.raft.protocol.ConfigurationRequest.Builder

Builder() - Constructor for class io.atomix.protocols.raft.protocol.ConfigurationResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.ConfigureRequest

Returns a new configuration request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.ConfigureRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.ConfigureResponse

Returns a new configure response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.ConfigureResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.HeartbeatRequest

Returns a new heartbeat request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.HeartbeatRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.HeartbeatResponse

Returns a new heartbeat response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.HeartbeatResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.InstallRequest

Returns a new install request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.InstallRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.InstallResponse

Returns a new install response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.InstallResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.JoinRequest

Returns a new join request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.JoinRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.JoinResponse

Returns a new join response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.JoinResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.KeepAliveRequest

Returns a new keep alive request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.KeepAliveRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.KeepAliveResponse

Returns a new keep alive response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.KeepAliveResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.LeaveRequest

Returns a new leave request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.LeaveRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.LeaveResponse

Returns a new leave response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.LeaveResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.MetadataRequest

Returns a new metadata request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.MetadataRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.MetadataResponse

Returns a new metadata response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.MetadataResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.OpenSessionRequest

Returns a new open session request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.OpenSessionRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.OpenSessionResponse

Returns a new register client response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.OpenSessionResponse.Builder

Builder() - Constructor for class io.atomix.protocols.raft.protocol.OperationRequest.Builder

Builder() - Constructor for class io.atomix.protocols.raft.protocol.OperationResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.PollRequest

Returns a new poll request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.PollRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.PollResponse

Returns a new poll response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.PollResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.PublishRequest

Returns a new publish request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.PublishRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.QueryRequest

Returns a new query request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.QueryRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.QueryResponse

Returns a new query response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.QueryResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.ReconfigureRequest

Returns a new reconfigure request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.ReconfigureRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.ReconfigureResponse

Returns a new reconfigure response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.ReconfigureResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.ResetRequest

Returns a new publish response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.ResetRequest.Builder

Builder() - Constructor for class io.atomix.protocols.raft.protocol.SessionRequest.Builder

Builder() - Constructor for class io.atomix.protocols.raft.protocol.SessionResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.TransferRequest

Returns a new transfer request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.TransferRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.TransferResponse

Returns a new transfer response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.TransferResponse.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.VoteRequest

Returns a new vote request builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.VoteRequest.Builder

builder() - Static method in class io.atomix.protocols.raft.protocol.VoteResponse

Returns a new vote response builder.

Builder() - Constructor for class io.atomix.protocols.raft.protocol.VoteResponse.Builder

builder() - Static method in interface io.atomix.protocols.raft.RaftClient

Returns a new Raft client builder.

builder(NodeId...) - Static method in interface io.atomix.protocols.raft.RaftClient

Returns a new Raft client builder.

builder(Collection<NodeId>) - Static method in interface io.atomix.protocols.raft.RaftClient

Returns a new Raft client builder.

builder() - Static method in class io.atomix.protocols.raft.RaftProtocol

Returns a new Raft protocol builder.

builder(String) - Static method in class io.atomix.protocols.raft.RaftProtocol

Returns a new Raft protocol builder.

builder() - Static method in interface io.atomix.protocols.raft.RaftServer

Returns a new Raft server builder using the default host:port.

builder(NodeId) - Static method in interface io.atomix.protocols.raft.RaftServer

Returns a new Raft server builder.

builder() - Static method in class io.atomix.protocols.raft.storage.log.RaftLog

Returns a new Raft log builder.

builder() - Static method in class io.atomix.protocols.raft.storage.RaftStorage

Returns a new storage builder.

builder() - Static method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

Returns a descriptor builder.

builder(Buffer) - Static method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

Returns a descriptor builder for the given descriptor buffer.

BYTES - Static variable in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

C

cancel() - Method in class io.atomix.protocols.raft.utils.Quorum

Cancels the quorum.

candidate() - Method in class io.atomix.protocols.raft.protocol.PollRequest

Returns the candidate's address.

candidate() - Method in class io.atomix.protocols.raft.protocol.VoteRequest

Returns the candidate's address.

CandidateRole - Class in io.atomix.protocols.raft.roles

Candidate state.

CandidateRole(RaftContext) - Constructor for class io.atomix.protocols.raft.roles.CandidateRole

chunkOffset() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

Returns the offset of the snapshot chunk.

clearResults(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Clears command results up to the given sequence number.

clientId() - Method in interface io.atomix.protocols.raft.RaftClient

Returns the globally unique client identifier.

close() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup

close() - Method in interface io.atomix.protocols.raft.RaftClient

Closes the client.

close() - Method in class io.atomix.protocols.raft.session.RaftSession

Closes the session.

close() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Closes the snapshot.

close() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

close() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

close() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotStore

close() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

close() - Method in class io.atomix.protocols.raft.storage.system.MetaStore

ClosedSession(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.ClosedSession

closeSession(NodeId, CloseSessionRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Sends a close session request to the given node.

closeSession(NodeId, CloseSessionRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a close session request to the given node.

closeSession(long, long, RaftSession, boolean) - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Unregister the given session.

CloseSessionEntry - Class in io.atomix.protocols.raft.storage.log.entry

Close session entry.

CloseSessionEntry(long, long, long, boolean) - Constructor for class io.atomix.protocols.raft.storage.log.entry.CloseSessionEntry

CloseSessionRequest - Class in io.atomix.protocols.raft.protocol

Close session request.

CloseSessionRequest(long) - Constructor for class io.atomix.protocols.raft.protocol.CloseSessionRequest

CloseSessionRequest.Builder - Class in io.atomix.protocols.raft.protocol

Unregister request builder.

CloseSessionResponse - Class in io.atomix.protocols.raft.protocol

Close session response.

CloseSessionResponse(RaftResponse.Status, RaftError) - Constructor for class io.atomix.protocols.raft.protocol.CloseSessionResponse

CloseSessionResponse.Builder - Class in io.atomix.protocols.raft.protocol

Status response builder.

cluster() - Method in interface io.atomix.protocols.raft.RaftServer

Returns the server's cluster configuration.

command(NodeId, CommandRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Sends a command request to the given node.

command(NodeId, CommandRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a command request to the given node.

CommandEntry - Class in io.atomix.protocols.raft.storage.log.entry

Stores a state machine command.

CommandEntry(long, long, long, long, PrimitiveOperation) - Constructor for class io.atomix.protocols.raft.storage.log.entry.CommandEntry

CommandFailure(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.CommandFailure

CommandRequest - Class in io.atomix.protocols.raft.protocol

Client command request.

CommandRequest(long, long, PrimitiveOperation) - Constructor for class io.atomix.protocols.raft.protocol.CommandRequest

CommandRequest.Builder - Class in io.atomix.protocols.raft.protocol

Command request builder.

CommandResponse - Class in io.atomix.protocols.raft.protocol

Client command response.

CommandResponse(RaftResponse.Status, RaftError, long, long, byte[], long) - Constructor for class io.atomix.protocols.raft.protocol.CommandResponse

CommandResponse.Builder - Class in io.atomix.protocols.raft.protocol

Command response builder.

commandSequenceNumbers() - Method in class io.atomix.protocols.raft.protocol.KeepAliveRequest

Returns the command sequence numbers.

commandSequenceNumbers() - Method in class io.atomix.protocols.raft.storage.log.entry.KeepAliveEntry

Returns the command sequence numbers.

commit(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Commits events for the given index.

commit(long) - Method in class io.atomix.protocols.raft.storage.log.RaftLogWriter

Commits entries up to the given index.

commitIndex() - Method in class io.atomix.protocols.raft.protocol.AppendRequest

Returns the leader's commit index.

CommunicationStrategy - Enum in io.atomix.protocols.raft.proxy

Strategy for selecting nodes to which to connect and submit operations.

communicationStrategy() - Method in class io.atomix.protocols.raft.RaftProtocol

Returns the communication strategy.

compact() - Method in class io.atomix.protocols.raft.storage.compactor.RaftLogCompactor

Compacts Raft logs.

compact(long) - Method in class io.atomix.protocols.raft.storage.log.RaftLog

Compacts the journal up to the given index.

complete() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

Returns a boolean value indicating whether this is the last chunk of the snapshot.

complete() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Completes writing the snapshot to persist it and make it available for reads.

completeKeepAlive(long, long) - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Completes a keep-alive.

completeSnapshot(long) - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Completes a snapshot of the service state.

Configuration - Class in io.atomix.protocols.raft.storage.system

Represents a persisted server configuration.

Configuration(long, long, long, Collection<RaftMember>) - Constructor for class io.atomix.protocols.raft.storage.system.Configuration

ConfigurationEntry - Class in io.atomix.protocols.raft.storage.log.entry

Stores a cluster configuration.

ConfigurationEntry(long, long, Collection<RaftMember>) - Constructor for class io.atomix.protocols.raft.storage.log.entry.ConfigurationEntry

ConfigurationException(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.ConfigurationException

ConfigurationRequest - Class in io.atomix.protocols.raft.protocol

Configuration change request.

ConfigurationRequest.Builder<T extends ConfigurationRequest.Builder<T,U>,U extends ConfigurationRequest> - Class in io.atomix.protocols.raft.protocol

Configuration request builder.

ConfigurationResponse - Class in io.atomix.protocols.raft.protocol

Server configuration response.

ConfigurationResponse(RaftResponse.Status, RaftError, long, long, long, Collection<RaftMember>) - Constructor for class io.atomix.protocols.raft.protocol.ConfigurationResponse

ConfigurationResponse.Builder<T extends ConfigurationResponse.Builder<T,U>,U extends ConfigurationResponse> - Class in io.atomix.protocols.raft.protocol

Configuration response builder.

configure(NodeId, ConfigureRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a configure request to the given node.

ConfigureRequest - Class in io.atomix.protocols.raft.protocol

Configuration installation request.

ConfigureRequest(long, String, long, long, Collection<RaftMember>) - Constructor for class io.atomix.protocols.raft.protocol.ConfigureRequest

ConfigureRequest.Builder - Class in io.atomix.protocols.raft.protocol

Heartbeat request builder.

ConfigureResponse - Class in io.atomix.protocols.raft.protocol

Configuration installation response.

ConfigureResponse(RaftResponse.Status, RaftError) - Constructor for class io.atomix.protocols.raft.protocol.ConfigureResponse

ConfigureResponse.Builder - Class in io.atomix.protocols.raft.protocol

Heartbeat response builder.

connect() - Method in interface io.atomix.protocols.raft.RaftClient

Connects the client to Raft cluster via the default server address.

connect(NodeId...) - Method in interface io.atomix.protocols.raft.RaftClient

Connects the client to Raft cluster via the provided server addresses.

connect(Collection<NodeId>) - Method in interface io.atomix.protocols.raft.RaftClient

Connects the client to Raft cluster via the provided server addresses.

createException() - Method in class io.atomix.protocols.raft.RaftError

Creates a new exception for the error.

currentIndex() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

currentOperation() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

currentSession() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

D

data() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

Returns the snapshot data.

dataDirectory() - Method in class io.atomix.protocols.raft.partition.RaftPartition

Returns the partition data directory.

delete() - Method in class io.atomix.protocols.raft.partition.RaftPartition

Deletes the partition.

delete() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Deletes the snapshot.

delete() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

Deletes the descriptor.

deleteLog() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Deletes a RaftLog from disk.

deleteMetaStore() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Deletes a MetaStore from disk.

deleteSnapshotStore() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Deletes a SnapshotStore from disk.

demote() - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Demotes the member to the next lowest type.

demote(RaftMember.Type) - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Demotes the member to the given type.

directory() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns the storage directory.

dynamicCompaction() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns whether dynamic log compaction is enabled.

E

entries() - Method in class io.atomix.protocols.raft.protocol.AppendRequest

Returns the log entries to append.

equals(Object) - Method in class io.atomix.protocols.raft.protocol.AbstractRaftResponse

equals(Object) - Method in class io.atomix.protocols.raft.protocol.AppendRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.AppendResponse

equals(Object) - Method in class io.atomix.protocols.raft.protocol.CloseSessionResponse

equals(Object) - Method in class io.atomix.protocols.raft.protocol.CommandRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.ConfigurationRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse

equals(Object) - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.HeartbeatRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.InstallRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.KeepAliveRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.KeepAliveResponse

equals(Object) - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.OpenSessionResponse

equals(Object) - Method in class io.atomix.protocols.raft.protocol.OperationResponse

equals(Object) - Method in class io.atomix.protocols.raft.protocol.PollRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.PollResponse

equals(Object) - Method in class io.atomix.protocols.raft.protocol.PublishRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.QueryRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.ReconfigureRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.ResetRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.SessionRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.TransferRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.VoteRequest

equals(Object) - Method in class io.atomix.protocols.raft.protocol.VoteResponse

equals(Object) - Method in class io.atomix.protocols.raft.session.RaftSession

equals(Object) - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

error() - Method in class io.atomix.protocols.raft.protocol.AbstractRaftResponse

error() - Method in interface io.atomix.protocols.raft.protocol.RaftResponse

Returns the response error if the response status is Status.ERROR

eventIndex() - Method in class io.atomix.protocols.raft.protocol.OperationResponse

Returns the event index.

eventIndex() - Method in class io.atomix.protocols.raft.protocol.PublishRequest

Returns the event index.

eventIndexes() - Method in class io.atomix.protocols.raft.protocol.KeepAliveRequest

Returns the event indexes.

eventIndexes() - Method in class io.atomix.protocols.raft.storage.log.entry.KeepAliveEntry

Returns the event indexes.

events() - Method in class io.atomix.protocols.raft.protocol.PublishRequest

Returns the request events.

executeCommand(long, long, long, RaftSession, PrimitiveOperation) - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Executes the given command on the state machine.

executeQuery(long, long, long, RaftSession, PrimitiveOperation) - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Executes the given query on the state machine.

executor() - Method in class io.atomix.protocols.raft.RaftProtocol

Returns the proxy executor.

executor() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Returns the state machine executor.

expire() - Method in class io.atomix.protocols.raft.session.RaftSession

Expires the session.

expired() - Method in class io.atomix.protocols.raft.storage.log.entry.CloseSessionEntry

Returns whether the session is expired.

F

fail() - Method in class io.atomix.protocols.raft.utils.Quorum

Indicates that a call in the quorum failed.

file() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotFile

Returns the snapshot file.

flush() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

FollowerRole - Class in io.atomix.protocols.raft.roles

Follower state.

FollowerRole(RaftContext) - Constructor for class io.atomix.protocols.raft.roles.FollowerRole

forId(int) - Static method in enum io.atomix.protocols.raft.protocol.RaftResponse.Status

Returns the status for the given identifier.

freeDiskBuffer() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns the percentage of disk space that must be available before log compaction is forced.

G

getCommandSequence() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the session operation sequence number.

getCompactableIndex(long) - Method in class io.atomix.protocols.raft.storage.log.RaftLog

Returns the index of the last segment in the log.

getEventIndex() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the session event index.

getFirstIndex() - Method in class io.atomix.protocols.raft.storage.log.RaftLogReader

Returns the first index in the journal.

getLastApplied() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the session index.

getLastCompleted() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the index of the highest event acked for the session.

getLastUpdated() - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Returns the time at which the member was updated.

getLastUpdated() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the session update timestamp.

getLeader() - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Returns the current cluster leader.

getLeader() - Method in interface io.atomix.protocols.raft.RaftMetadataClient

Returns the current cluster leader.

getMember() - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Returns the local cluster member.

getMember(NodeId) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Returns a member by ID.

getMembers() - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Returns a collection of all cluster members.

getMembers() - Method in interface io.atomix.protocols.raft.RaftMetadataClient

Returns the set of known members in the cluster.

getPartition(PartitionId) - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup

getPartitionIds() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup

getPartitions() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup

getPrimitiveClient() - Method in class io.atomix.protocols.raft.partition.RaftPartition

getRequestSequence() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the session request number.

getResult(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the session response for the given sequence number.

getRole() - Method in interface io.atomix.protocols.raft.RaftServer

Returns the server role.

getServers() - Method in interface io.atomix.protocols.raft.RaftMetadataClient

Returns the set of known members in the cluster.

getService() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the state machine context associated with the session.

getSession(SessionId) - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry

Gets a session by session ID.

getSession(long) - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry

Gets a session by session ID.

getSessions() - Method in interface io.atomix.protocols.raft.RaftMetadataClient

Returns a list of open sessions.

getSessions(PrimitiveType) - Method in interface io.atomix.protocols.raft.RaftMetadataClient

Returns a list of open sessions of the given type.

getSessions(PrimitiveType, String) - Method in interface io.atomix.protocols.raft.RaftMetadataClient

Returns a list of open sessions for the given service.

getSessions() - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry

Returns the collection of registered sessions.

getSessions(PrimitiveId) - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry

Returns a set of sessions associated with the given service.

getSnapshot(PrimitiveId, long) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotStore

Returns the snapshot for the given primitive at the given index.

getSnapshotById(PrimitiveId) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotStore

Returns the last snapshot for the given state machine identifier.

getSnapshotsByIndex(long) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotStore

Returns the snapshot at the given index.

getState() - Method in class io.atomix.protocols.raft.session.RaftSession

getTerm() - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Returns the current cluster term.

getType() - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Returns the member type.

getType() - Method in exception io.atomix.protocols.raft.RaftException

Returns the exception type.

group() - Method in class io.atomix.protocols.raft.RaftProtocol

H

hash() - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Returns the member hash.

hashCode() - Method in class io.atomix.protocols.raft.protocol.AbstractRaftResponse

hashCode() - Method in class io.atomix.protocols.raft.protocol.AppendRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.AppendResponse

hashCode() - Method in class io.atomix.protocols.raft.protocol.CommandRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.ConfigurationRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse

hashCode() - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.HeartbeatRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.KeepAliveRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.KeepAliveResponse

hashCode() - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.OpenSessionResponse

hashCode() - Method in class io.atomix.protocols.raft.protocol.OperationResponse

hashCode() - Method in class io.atomix.protocols.raft.protocol.PollRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.PollResponse

hashCode() - Method in class io.atomix.protocols.raft.protocol.PublishRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.QueryRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.ReconfigureRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.ResetRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.SessionRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.TransferRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.VoteRequest

hashCode() - Method in class io.atomix.protocols.raft.protocol.VoteResponse

hashCode() - Method in class io.atomix.protocols.raft.session.RaftSession

hashCode() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

hasNext() - Method in class io.atomix.protocols.raft.storage.log.RaftLogReader

hasRemaining() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

heartbeat(NodeId, HeartbeatRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a heartbeat request to the given node.

HeartbeatRequest - Class in io.atomix.protocols.raft.protocol

Client heartbeat request.

HeartbeatRequest(NodeId, Collection<NodeId>) - Constructor for class io.atomix.protocols.raft.protocol.HeartbeatRequest

HeartbeatRequest.Builder - Class in io.atomix.protocols.raft.protocol

Heartbeat request builder.

HeartbeatResponse - Class in io.atomix.protocols.raft.protocol

Client heartbeat response.

HeartbeatResponse(RaftResponse.Status, RaftError) - Constructor for class io.atomix.protocols.raft.protocol.HeartbeatResponse

HeartbeatResponse.Builder - Class in io.atomix.protocols.raft.protocol

Heartbeat response builder.

I

id() - Method in class io.atomix.protocols.raft.partition.RaftPartition

id() - Method in enum io.atomix.protocols.raft.protocol.RaftResponse.Status

Returns the status identifier.

IllegalMemberState(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.IllegalMemberState

InactiveRole - Class in io.atomix.protocols.raft.roles

Inactive state.

InactiveRole(RaftContext) - Constructor for class io.atomix.protocols.raft.roles.InactiveRole

index() - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse

Returns the response index.

index() - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest

Returns the configuration index.

index() - Method in class io.atomix.protocols.raft.protocol.OperationResponse

Returns the operation index.

index() - Method in class io.atomix.protocols.raft.protocol.QueryRequest

Returns the query index.

index() - Method in class io.atomix.protocols.raft.protocol.ReconfigureRequest

Returns the configuration index.

index() - Method in class io.atomix.protocols.raft.protocol.ResetRequest

Returns the event index.

index() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Returns the snapshot index.

index() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

Returns the snapshot index.

index() - Method in class io.atomix.protocols.raft.storage.system.Configuration

Returns the configuration index.

InitializeEntry - Class in io.atomix.protocols.raft.storage.log.entry

Indicates a leader change has occurred.

InitializeEntry(long, long) - Constructor for class io.atomix.protocols.raft.storage.log.entry.InitializeEntry

install(NodeId, InstallRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends an install request to the given node.

install(SnapshotReader) - Method in interface io.atomix.protocols.raft.storage.snapshot.Snapshottable

Installs a snapshot of the state machine state.

InstallRequest - Class in io.atomix.protocols.raft.protocol

Server snapshot installation request.

InstallRequest(long, NodeId, long, String, long, long, int, byte[], boolean) - Constructor for class io.atomix.protocols.raft.protocol.InstallRequest

InstallRequest.Builder - Class in io.atomix.protocols.raft.protocol

Snapshot request builder.

InstallResponse - Class in io.atomix.protocols.raft.protocol

Snapshot installation response.

InstallResponse(RaftResponse.Status, RaftError) - Constructor for class io.atomix.protocols.raft.protocol.InstallResponse

InstallResponse.Builder - Class in io.atomix.protocols.raft.protocol

Install response builder.

io.atomix.protocols.raft - package io.atomix.protocols.raft

Core interfaces for operating on replicated state machines in the Raft cluster.

io.atomix.protocols.raft.cluster - package io.atomix.protocols.raft.cluster

Interfaces for managing and interacting with the Raft cluster.

io.atomix.protocols.raft.partition - package io.atomix.protocols.raft.partition

io.atomix.protocols.raft.protocol - package io.atomix.protocols.raft.protocol

RaftRequest and RaftResponse implementations for all client-server communication.

io.atomix.protocols.raft.proxy - package io.atomix.protocols.raft.proxy

Facilitates modification of a Raft state machine via proxy.

io.atomix.protocols.raft.roles - package io.atomix.protocols.raft.roles

Internal classes that manage Raft server state.

io.atomix.protocols.raft.service - package io.atomix.protocols.raft.service

io.atomix.protocols.raft.session - package io.atomix.protocols.raft.session

io.atomix.protocols.raft.storage - package io.atomix.protocols.raft.storage

Standalone segmented log for Raft's Raft implementation.

io.atomix.protocols.raft.storage.compactor - package io.atomix.protocols.raft.storage.compactor

io.atomix.protocols.raft.storage.log - package io.atomix.protocols.raft.storage.log

io.atomix.protocols.raft.storage.log.entry - package io.atomix.protocols.raft.storage.log.entry

RaftLogEntry implementations used internally to replicate state changes, sessions, and configuration changes in the cluster.

io.atomix.protocols.raft.storage.snapshot - package io.atomix.protocols.raft.storage.snapshot

Classes and interfaces that aid in storing, loading, and installing on-disk state machine snapshots.

io.atomix.protocols.raft.storage.system - package io.atomix.protocols.raft.storage.system

Classes and interfaces that aid in storing and loading persistent cluster and server configurations.

io.atomix.protocols.raft.utils - package io.atomix.protocols.raft.utils

isCompactable(long) - Method in class io.atomix.protocols.raft.storage.log.RaftLog

Returns a boolean indicating whether a segment can be removed from the journal prior to the given index.

isFlushOnCommit() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns whether to flush buffers to disk when entries are committed.

isFollower() - Method in interface io.atomix.protocols.raft.RaftServer

Returns whether the server is a follower.

isLeader() - Method in interface io.atomix.protocols.raft.RaftServer

Returns whether the server is the leader.

isLocked() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

Returns whether the snapshot has been locked by commitment.

isPersisted() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Returns whether the snapshot is persisted.

isRetainStaleSnapshots() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns a boolean value indicating whether to retain stale snapshots on disk.

isRunning() - Method in interface io.atomix.protocols.raft.RaftServer

Returns a boolean indicating whether the server is running.

isRunning() - Method in class io.atomix.protocols.raft.roles.AbstractRole

isSnapshotFile(File) - Static method in class io.atomix.protocols.raft.storage.snapshot.SnapshotFile

Returns a boolean value indicating whether the given file appears to be a parsable snapshot file.

isTimedOut(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Returns a boolean indicating whether the session is timed out.

isUnderHighLoad() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Returns a boolean indicating whether the service is under high load.

isUnderHighLoad() - Method in class io.atomix.protocols.raft.utils.LoadMonitor

Returns a boolean indicating whether the server is under high load.

J

join(NodeId...) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Joins the cluster.

join(Collection<NodeId>) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Joins the cluster.

join(NodeId, JoinRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a join request to the given node.

join(NodeId...) - Method in interface io.atomix.protocols.raft.RaftServer

Joins the cluster.

join(Collection<NodeId>) - Method in interface io.atomix.protocols.raft.RaftServer

Joins the cluster.

JoinRequest - Class in io.atomix.protocols.raft.protocol

Server join configuration change request.

JoinRequest(RaftMember) - Constructor for class io.atomix.protocols.raft.protocol.JoinRequest

JoinRequest.Builder - Class in io.atomix.protocols.raft.protocol

Join request builder.

JoinResponse - Class in io.atomix.protocols.raft.protocol

Server join configuration change response.

JoinResponse(RaftResponse.Status, RaftError, long, long, long, Collection<RaftMember>) - Constructor for class io.atomix.protocols.raft.protocol.JoinResponse

JoinResponse.Builder - Class in io.atomix.protocols.raft.protocol

Join response builder.

K

keepAlive(NodeId, KeepAliveRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Sends a keep alive request to the given node.

keepAlive(NodeId, KeepAliveRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a keep alive request to the given node.

keepAlive(long, long, RaftSession, long, long) - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Keeps the given session alive.

KeepAliveEntry - Class in io.atomix.protocols.raft.storage.log.entry

Stores a client keep-alive request.

KeepAliveEntry(long, long, long[], long[], long[]) - Constructor for class io.atomix.protocols.raft.storage.log.entry.KeepAliveEntry

KeepAliveRequest - Class in io.atomix.protocols.raft.protocol

Session keep alive request.

KeepAliveRequest(long[], long[], long[]) - Constructor for class io.atomix.protocols.raft.protocol.KeepAliveRequest

KeepAliveRequest.Builder - Class in io.atomix.protocols.raft.protocol

Keep alive request builder.

KeepAliveResponse - Class in io.atomix.protocols.raft.protocol

Session keep alive response.

KeepAliveResponse(RaftResponse.Status, RaftError, NodeId, Collection<NodeId>, long[]) - Constructor for class io.atomix.protocols.raft.protocol.KeepAliveResponse

KeepAliveResponse.Builder - Class in io.atomix.protocols.raft.protocol

Status response builder.

keepAliveSessions(long, long) - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Keeps all sessions alive using the given timestamp.

L

lastLogIndex() - Method in class io.atomix.protocols.raft.protocol.AppendResponse

Returns the last index of the replica's log.

lastLogIndex() - Method in class io.atomix.protocols.raft.protocol.PollRequest

Returns the candidate's last log index.

lastLogIndex() - Method in class io.atomix.protocols.raft.protocol.VoteRequest

Returns the candidate's last log index.

lastLogTerm() - Method in class io.atomix.protocols.raft.protocol.PollRequest

Returns the candidate's last log term.

lastLogTerm() - Method in class io.atomix.protocols.raft.protocol.VoteRequest

Returns the candidate's last log term.

lastSequenceNumber() - Method in class io.atomix.protocols.raft.protocol.OperationResponse

Returns the last in sequence command.

leader() - Method in class io.atomix.protocols.raft.protocol.AppendRequest

Returns the requesting leader address.

leader() - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest

Returns the requesting leader address.

leader() - Method in class io.atomix.protocols.raft.protocol.HeartbeatRequest

Returns the cluster leader.

leader() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

Returns the requesting leader address.

leader() - Method in class io.atomix.protocols.raft.protocol.KeepAliveResponse

Returns the cluster leader.

leader() - Method in interface io.atomix.protocols.raft.RaftClient

Returns the current leader.

LeaderRole - Class in io.atomix.protocols.raft.roles

Leader state.

LeaderRole(RaftContext) - Constructor for class io.atomix.protocols.raft.roles.LeaderRole

leave() - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Leaves the cluster.

leave(NodeId, LeaveRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a leave request to the given node.

leave() - Method in interface io.atomix.protocols.raft.RaftServer

Leaves the Raft cluster.

LeaveRequest - Class in io.atomix.protocols.raft.protocol

Server leave configuration request.

LeaveRequest(RaftMember) - Constructor for class io.atomix.protocols.raft.protocol.LeaveRequest

LeaveRequest.Builder - Class in io.atomix.protocols.raft.protocol

Leave request builder.

LeaveResponse - Class in io.atomix.protocols.raft.protocol

Server leave configuration change response.

LeaveResponse(RaftResponse.Status, RaftError, long, long, long, Collection<RaftMember>) - Constructor for class io.atomix.protocols.raft.protocol.LeaveResponse

LeaveResponse.Builder - Class in io.atomix.protocols.raft.protocol

Leave response builder.

listen(NodeId...) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Joins the cluster as a listener.

listen(Collection<NodeId>) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Joins the cluster as a listener.

listen(NodeId...) - Method in interface io.atomix.protocols.raft.RaftServer

Joins the cluster as a passive listener.

listen(Collection<NodeId>) - Method in interface io.atomix.protocols.raft.RaftServer

Joins the cluster as a passive listener.

loadConfiguration() - Method in class io.atomix.protocols.raft.storage.system.MetaStore

Loads the current cluster configuration.

LoadMonitor - Class in io.atomix.protocols.raft.utils

Server load monitor.

LoadMonitor(int, int, ThreadContext) - Constructor for class io.atomix.protocols.raft.utils.LoadMonitor

loadTerm() - Method in class io.atomix.protocols.raft.storage.system.MetaStore

Loads the stored server term.

loadVote() - Method in class io.atomix.protocols.raft.storage.system.MetaStore

Loads the last vote for the server.

lock() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

Locks the segment.

logicalClock() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

M

maxLogEntriesPerSegment() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns the maximum number of entries per segment.

maxLogSegmentSize() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns the maximum log segment size.

maxRetries() - Method in class io.atomix.protocols.raft.RaftProtocol

Returns the maximum number of allowed retries.

maxTimeout() - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest

Returns the maximum session timeout.

maxTimeout() - Method in class io.atomix.protocols.raft.RaftProtocol

Returns the maximum timeout.

maxTimeout() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the maximum session timeout.

maxTimeout() - Method in class io.atomix.protocols.raft.storage.log.entry.OpenSessionEntry

Returns the maximum session timeout.

member() - Method in class io.atomix.protocols.raft.protocol.ConfigurationRequest

Returns the member to configure.

member() - Method in class io.atomix.protocols.raft.protocol.TransferRequest

Returns the member to which to transfer.

memberId() - Method in class io.atomix.protocols.raft.storage.log.entry.OpenSessionEntry

Returns the client node identifier.

members() - Method in class io.atomix.protocols.raft.partition.RaftPartition

Returns the identifiers of partition members.

members() - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse

Returns the configuration members list.

members() - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest

Returns the configuration members.

members() - Method in class io.atomix.protocols.raft.protocol.HeartbeatRequest

Returns the cluster members.

members() - Method in class io.atomix.protocols.raft.protocol.KeepAliveResponse

Returns the cluster members.

members() - Method in class io.atomix.protocols.raft.storage.log.entry.ConfigurationEntry

Returns the members.

members() - Method in class io.atomix.protocols.raft.storage.system.Configuration

Returns the cluster membership for this configuration.

message() - Method in class io.atomix.protocols.raft.RaftError

Returns the error message.

metadata(NodeId, MetadataRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Sends a metadata request to the given node.

metadata(NodeId, MetadataRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a metadata request to the given node.

metadata() - Method in interface io.atomix.protocols.raft.RaftClient

Returns the Raft metadata.

MetadataEntry - Class in io.atomix.protocols.raft.storage.log.entry

Metadata entry.

MetadataEntry(long, long, long) - Constructor for class io.atomix.protocols.raft.storage.log.entry.MetadataEntry

MetadataRequest - Class in io.atomix.protocols.raft.protocol

Cluster metadata request.

MetadataRequest(long) - Constructor for class io.atomix.protocols.raft.protocol.MetadataRequest

MetadataRequest.Builder - Class in io.atomix.protocols.raft.protocol

Metadata request builder.

MetadataResponse - Class in io.atomix.protocols.raft.protocol

Cluster metadata response.

MetadataResponse(RaftResponse.Status, RaftError, Set<SessionMetadata>) - Constructor for class io.atomix.protocols.raft.protocol.MetadataResponse

MetadataResponse.Builder - Class in io.atomix.protocols.raft.protocol

Metadata response builder.

MetaStore - Class in io.atomix.protocols.raft.storage.system

Manages persistence of server configurations.

MetaStore(RaftStorage, Serializer) - Constructor for class io.atomix.protocols.raft.storage.system.MetaStore

minTimeout() - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest

Returns the minimum session timeout.

minTimeout() - Method in class io.atomix.protocols.raft.RaftProtocol

Returns the minimum timeout.

minTimeout() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the minimum session timeout.

minTimeout() - Method in class io.atomix.protocols.raft.storage.log.entry.OpenSessionEntry

Returns the minimum session timeout.

N

name() - Method in class io.atomix.protocols.raft.partition.RaftPartition

Returns the partition name.

name() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup

name() - Method in interface io.atomix.protocols.raft.RaftServer

Returns the server name.

name() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotFile

Returns the snapshot name.

newBuilder() - Static method in interface io.atomix.protocols.raft.RaftClient

Deprecated.

since 2.1

newBuilder(NodeId...) - Static method in interface io.atomix.protocols.raft.RaftClient

Deprecated.

since 2.1

newBuilder(Collection<NodeId>) - Static method in interface io.atomix.protocols.raft.RaftClient

Deprecated.

since 2.1

newBuilder() - Static method in class io.atomix.protocols.raft.storage.log.RaftLog

Deprecated.

newBuilder() - Static method in class io.atomix.protocols.raft.storage.RaftStorage

Deprecated.

since 2.1

newSnapshot(PrimitiveId, String, long, WallClockTimestamp) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotStore

Creates a new snapshot.

newTemporarySnapshot(PrimitiveId, String, long, WallClockTimestamp) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotStore

Creates a temporary in-memory snapshot.

nextCommandSequence() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the next operation sequence number.

nextRequestSequence() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the next request sequence number.

node() - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest

Returns the client node identifier.

nodeId() - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Returns the member node ID.

nodeId() - Method in class io.atomix.protocols.raft.session.RaftSession

NoLeader(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.NoLeader

O

onAppend(AppendRequest) - Method in class io.atomix.protocols.raft.roles.ActiveRole

onAppend(AppendRequest) - Method in class io.atomix.protocols.raft.roles.CandidateRole

onAppend(AppendRequest) - Method in class io.atomix.protocols.raft.roles.FollowerRole

onAppend(AppendRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onAppend(AppendRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onAppend(AppendRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onAppend(AppendRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles an append request.

onCloseSession(CloseSessionRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onCloseSession(CloseSessionRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onCloseSession(CloseSessionRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onCloseSession(CloseSessionRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a close session request.

onCommand(CommandRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onCommand(CommandRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onCommand(CommandRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onCommand(CommandRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a command request.

onConfigure(ConfigureRequest) - Method in class io.atomix.protocols.raft.roles.FollowerRole

onConfigure(ConfigureRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onConfigure(ConfigureRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a configure request.

onInstall(InstallRequest) - Method in class io.atomix.protocols.raft.roles.FollowerRole

onInstall(InstallRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onInstall(InstallRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onInstall(InstallRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles an install request.

onJoin(JoinRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onJoin(JoinRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onJoin(JoinRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onJoin(JoinRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a join request.

onKeepAlive(KeepAliveRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onKeepAlive(KeepAliveRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onKeepAlive(KeepAliveRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onKeepAlive(KeepAliveRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a keep alive request.

onLeave(LeaveRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onLeave(LeaveRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onLeave(LeaveRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onLeave(LeaveRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a leave request.

onMetadata(MetadataRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onMetadata(MetadataRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onMetadata(MetadataRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onMetadata(MetadataRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a metadata request.

onOpenSession(OpenSessionRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onOpenSession(OpenSessionRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onOpenSession(OpenSessionRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onOpenSession(OpenSessionRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles an open session request.

onPoll(PollRequest) - Method in class io.atomix.protocols.raft.roles.ActiveRole

onPoll(PollRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onPoll(PollRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onPoll(PollRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onPoll(PollRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a poll request.

onQuery(QueryRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onQuery(QueryRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onQuery(QueryRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onQuery(QueryRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a query request.

onReconfigure(ReconfigureRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onReconfigure(ReconfigureRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onReconfigure(ReconfigureRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onReconfigure(ReconfigureRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a configure request.

onTransfer(TransferRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onTransfer(TransferRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onTransfer(TransferRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a transfer request.

onVote(VoteRequest) - Method in class io.atomix.protocols.raft.roles.ActiveRole

onVote(VoteRequest) - Method in class io.atomix.protocols.raft.roles.CandidateRole

onVote(VoteRequest) - Method in class io.atomix.protocols.raft.roles.InactiveRole

onVote(VoteRequest) - Method in class io.atomix.protocols.raft.roles.LeaderRole

onVote(VoteRequest) - Method in class io.atomix.protocols.raft.roles.PassiveRole

onVote(VoteRequest) - Method in interface io.atomix.protocols.raft.roles.RaftRole

Handles a vote request.

open(PartitionManagementService) - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup

open() - Method in class io.atomix.protocols.raft.session.RaftSession

Opens the session.

openLog() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Opens a new RaftLog, recovering the log from disk if it exists.

openMetaStore() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Opens a new MetaStore, recovering metadata from disk if it exists.

openReader(long) - Method in class io.atomix.protocols.raft.storage.log.RaftLog

openReader(long, RaftLogReader.Mode) - Method in class io.atomix.protocols.raft.storage.log.RaftLog

Opens a new Raft log reader with the given reader mode.

openReader() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Opens a new snapshot reader.

openSession(NodeId, OpenSessionRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Sends an open session request to the given node.

openSession(NodeId, OpenSessionRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends an open session request to the given node.

openSession(long, long, RaftSession) - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Registers the given session.

OpenSessionEntry - Class in io.atomix.protocols.raft.storage.log.entry

Open session entry.

OpenSessionEntry(long, long, String, String, String, ReadConsistency, long, long) - Constructor for class io.atomix.protocols.raft.storage.log.entry.OpenSessionEntry

OpenSessionRequest - Class in io.atomix.protocols.raft.protocol

Open session request.

OpenSessionRequest(String, String, String, ReadConsistency, long, long) - Constructor for class io.atomix.protocols.raft.protocol.OpenSessionRequest

OpenSessionRequest.Builder - Class in io.atomix.protocols.raft.protocol

Open session request builder.

OpenSessionResponse - Class in io.atomix.protocols.raft.protocol

Open session response.

OpenSessionResponse(RaftResponse.Status, RaftError, long, long) - Constructor for class io.atomix.protocols.raft.protocol.OpenSessionResponse

OpenSessionResponse.Builder - Class in io.atomix.protocols.raft.protocol

Register response builder.

openSnapshotStore() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Opens a new SnapshotStore, recovering snapshots from disk if they exist.

openWriter() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Opens a new snapshot writer.

operation() - Method in class io.atomix.protocols.raft.protocol.OperationRequest

Returns the operation.

operation() - Method in class io.atomix.protocols.raft.storage.log.entry.OperationEntry

Returns the entry operation.

OperationEntry - Class in io.atomix.protocols.raft.storage.log.entry

Stores a state machine operation.

OperationEntry(long, long, long, long, PrimitiveOperation) - Constructor for class io.atomix.protocols.raft.storage.log.entry.OperationEntry

OperationFailure(RaftError.Type, String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.OperationFailure

OperationRequest - Class in io.atomix.protocols.raft.protocol

Client operation request.

OperationRequest.Builder<T extends OperationRequest.Builder<T,U>,U extends OperationRequest> - Class in io.atomix.protocols.raft.protocol

Operation request builder.

OperationResponse - Class in io.atomix.protocols.raft.protocol

Base client operation response.

OperationResponse(RaftResponse.Status, RaftError, long, long, byte[], long) - Constructor for class io.atomix.protocols.raft.protocol.OperationResponse

OperationResponse.Builder<T extends OperationResponse.Builder<T,U>,U extends OperationResponse> - Class in io.atomix.protocols.raft.protocol

Operation response builder.

P

PassiveRole - Class in io.atomix.protocols.raft.roles

Passive state.

PassiveRole(RaftContext) - Constructor for class io.atomix.protocols.raft.roles.PassiveRole

persist() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Persists the snapshot to disk if necessary.

poll(NodeId, PollRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a poll request to the given node.

PollRequest - Class in io.atomix.protocols.raft.protocol

Server poll request.

PollRequest(long, String, long, long) - Constructor for class io.atomix.protocols.raft.protocol.PollRequest

PollRequest.Builder - Class in io.atomix.protocols.raft.protocol

Poll request builder.

PollResponse - Class in io.atomix.protocols.raft.protocol

Server poll response.

PollResponse(RaftResponse.Status, RaftError, long, boolean) - Constructor for class io.atomix.protocols.raft.protocol.PollResponse

PollResponse.Builder - Class in io.atomix.protocols.raft.protocol

Poll response builder.

position() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

prefix() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns the storage filename prefix.

previousIndex() - Method in class io.atomix.protocols.raft.protocol.PublishRequest

Returns the previous event index.

prevLogIndex() - Method in class io.atomix.protocols.raft.protocol.AppendRequest

Returns the index of the log entry preceding the new entry.

prevLogTerm() - Method in class io.atomix.protocols.raft.protocol.AppendRequest

Returns the term of the log entry preceding the new entry.

primary() - Method in class io.atomix.protocols.raft.partition.RaftPartition

PromotableRole - Class in io.atomix.protocols.raft.roles

Promotable role.

PromotableRole(RaftContext) - Constructor for class io.atomix.protocols.raft.roles.PromotableRole

promote() - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Promotes the member to the next highest type.

promote(RaftMember.Type) - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Promotes the member to the given type.

promote() - Method in interface io.atomix.protocols.raft.RaftServer

Promotes the server to leader if possible.

ProtocolException(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.ProtocolException

publish(NodeId, PublishRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unicasts a publish request to the given node.

publish(PrimitiveEvent) - Method in class io.atomix.protocols.raft.session.RaftSession

PublishRequest - Class in io.atomix.protocols.raft.protocol

Event publish request.

PublishRequest(long, long, long, List<PrimitiveEvent>) - Constructor for class io.atomix.protocols.raft.protocol.PublishRequest

PublishRequest.Builder - Class in io.atomix.protocols.raft.protocol

Publish request builder.

Q

query(NodeId, QueryRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Sends a query request to the given node.

query(NodeId, QueryRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a query request to the given node.

QueryEntry - Class in io.atomix.protocols.raft.storage.log.entry

Represents a state machine query.

QueryEntry(long, long, long, long, PrimitiveOperation) - Constructor for class io.atomix.protocols.raft.storage.log.entry.QueryEntry

QueryFailure(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.QueryFailure

QueryRequest - Class in io.atomix.protocols.raft.protocol

Client query request.

QueryRequest(long, long, PrimitiveOperation, long) - Constructor for class io.atomix.protocols.raft.protocol.QueryRequest

QueryRequest.Builder - Class in io.atomix.protocols.raft.protocol

Query request builder.

QueryResponse - Class in io.atomix.protocols.raft.protocol

Client query response.

QueryResponse(RaftResponse.Status, RaftError, long, long, byte[], long) - Constructor for class io.atomix.protocols.raft.protocol.QueryResponse

QueryResponse.Builder - Class in io.atomix.protocols.raft.protocol

Query response builder.

Quorum - Class in io.atomix.protocols.raft.utils

Quorum helper.

Quorum(int, Consumer<Boolean>) - Constructor for class io.atomix.protocols.raft.utils.Quorum

R

RaftClient - Interface in io.atomix.protocols.raft

Provides an interface for submitting operations to the Raft cluster.

RaftClient.Builder - Class in io.atomix.protocols.raft

Builds a new Raft client.

RaftClientProtocol - Interface in io.atomix.protocols.raft.protocol

Raft client protocol.

RaftCluster - Interface in io.atomix.protocols.raft.cluster

Raft server cluster API.

RaftClusterEvent - Class in io.atomix.protocols.raft.cluster

Raft cluster event.

RaftClusterEvent(RaftClusterEvent.Type, RaftMember) - Constructor for class io.atomix.protocols.raft.cluster.RaftClusterEvent

RaftClusterEvent(RaftClusterEvent.Type, RaftMember, long) - Constructor for class io.atomix.protocols.raft.cluster.RaftClusterEvent

RaftClusterEvent.Type - Enum in io.atomix.protocols.raft.cluster

Raft cluster event type.

RaftClusterEventListener - Interface in io.atomix.protocols.raft.cluster

Raft cluster event listener.

RaftError - Class in io.atomix.protocols.raft

Base type for Raft protocol errors.

RaftError(RaftError.Type, String) - Constructor for class io.atomix.protocols.raft.RaftError

RaftError.Type - Enum in io.atomix.protocols.raft

Raft error types.

RaftException - Exception in io.atomix.protocols.raft

Base Raft protocol exception.

RaftException.ApplicationException - Exception in io.atomix.protocols.raft

RaftException.ClosedSession - Exception in io.atomix.protocols.raft

RaftException.CommandFailure - Exception in io.atomix.protocols.raft

RaftException.ConfigurationException - Exception in io.atomix.protocols.raft

RaftException.IllegalMemberState - Exception in io.atomix.protocols.raft

RaftException.NoLeader - Exception in io.atomix.protocols.raft

RaftException.OperationFailure - Exception in io.atomix.protocols.raft

RaftException.ProtocolException - Exception in io.atomix.protocols.raft

RaftException.QueryFailure - Exception in io.atomix.protocols.raft

RaftException.Unavailable - Exception in io.atomix.protocols.raft

RaftException.UnknownClient - Exception in io.atomix.protocols.raft

RaftException.UnknownService - Exception in io.atomix.protocols.raft

RaftException.UnknownSession - Exception in io.atomix.protocols.raft

RaftLog - Class in io.atomix.protocols.raft.storage.log

Raft log.

RaftLog.Builder - Class in io.atomix.protocols.raft.storage.log

Raft log builder.

RaftLogCompactor - Class in io.atomix.protocols.raft.storage.compactor

Raft log compactor.

RaftLogCompactor(RaftContext, ThreadContext) - Constructor for class io.atomix.protocols.raft.storage.compactor.RaftLogCompactor

RaftLogEntry - Class in io.atomix.protocols.raft.storage.log.entry

Stores a state change in a RaftLog.

RaftLogEntry(long) - Constructor for class io.atomix.protocols.raft.storage.log.entry.RaftLogEntry

RaftLogReader - Class in io.atomix.protocols.raft.storage.log

Raft log reader.

RaftLogReader(SegmentedJournalReader<RaftLogEntry>, RaftLog, RaftLogReader.Mode) - Constructor for class io.atomix.protocols.raft.storage.log.RaftLogReader

RaftLogReader.Mode - Enum in io.atomix.protocols.raft.storage.log

Raft log reader mode.

RaftLogWriter - Class in io.atomix.protocols.raft.storage.log

Raft log writer.

RaftLogWriter(SegmentedJournalWriter<RaftLogEntry>, RaftLog) - Constructor for class io.atomix.protocols.raft.storage.log.RaftLogWriter

RaftMember - Interface in io.atomix.protocols.raft.cluster

Represents a member of a Raft cluster.

RaftMember.Type - Enum in io.atomix.protocols.raft.cluster

Indicates how the member participates in voting and replication.

RaftMessage - Interface in io.atomix.protocols.raft.protocol

Base type for Raft protocol messages.

RaftMetadataClient - Interface in io.atomix.protocols.raft

Raft metadata.

RaftPartition - Class in io.atomix.protocols.raft.partition

Abstract partition.

RaftPartition(PartitionId, StorageLevel, File) - Constructor for class io.atomix.protocols.raft.partition.RaftPartition

RaftPartitionGroup - Class in io.atomix.protocols.raft.partition

Raft partition group.

RaftPartitionGroup(String, Collection<RaftPartition>, int) - Constructor for class io.atomix.protocols.raft.partition.RaftPartitionGroup

RaftPartitionGroup.Builder - Class in io.atomix.protocols.raft.partition

Raft partition group builder.

RaftProtocol - Class in io.atomix.protocols.raft

Raft protocol.

RaftProtocol.Builder - Class in io.atomix.protocols.raft

Raft protocol builder.

RaftProxy - Interface in io.atomix.protocols.raft.proxy

Raft primitive proxy.

RaftRequest - Interface in io.atomix.protocols.raft.protocol

Base interface for requests.

RaftRequest.Builder<T extends RaftRequest.Builder<T,U>,U extends RaftRequest> - Interface in io.atomix.protocols.raft.protocol

Request builder.

RaftResponse - Interface in io.atomix.protocols.raft.protocol

Base interface for responses.

RaftResponse.Builder<T extends RaftResponse.Builder<T,U>,U extends RaftResponse> - Interface in io.atomix.protocols.raft.protocol

Response builder.

RaftResponse.Status - Enum in io.atomix.protocols.raft.protocol

Response status.

RaftRole - Interface in io.atomix.protocols.raft.roles

Raft role interface.

RaftServer - Interface in io.atomix.protocols.raft

Provides a standalone implementation of the Raft consensus algorithm.

RaftServer.Builder - Class in io.atomix.protocols.raft

Builds a single-use Raft server.

RaftServer.Role - Enum in io.atomix.protocols.raft

Raft server state types.

RaftServerProtocol - Interface in io.atomix.protocols.raft.protocol

Raft server protocol.

RaftServiceContext - Class in io.atomix.protocols.raft.service

Raft server state machine executor.

RaftServiceContext(PrimitiveId, String, PrimitiveType, PrimitiveService, RaftContext, ThreadContextFactory) - Constructor for class io.atomix.protocols.raft.service.RaftServiceContext

RaftSession - Class in io.atomix.protocols.raft.session

Raft session.

RaftSession(SessionId, NodeId, String, PrimitiveType, ReadConsistency, long, long, long, RaftServiceContext, RaftContext, ThreadContextFactory) - Constructor for class io.atomix.protocols.raft.session.RaftSession

RaftSessionRegistry - Class in io.atomix.protocols.raft.session

Session manager.

RaftSessionRegistry() - Constructor for class io.atomix.protocols.raft.session.RaftSessionRegistry

RaftStorage - Class in io.atomix.protocols.raft.storage

Immutable log configuration and RaftLog factory.

RaftStorage.Builder - Class in io.atomix.protocols.raft.storage

Builds a RaftStorage configuration.

read(Bytes) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

read(byte[]) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

read(Bytes, int, int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

read(byte[], int, int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

read(Buffer) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readBoolean() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readByte() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readChar() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readConsistency() - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest

Returns the session read consistency level.

readConsistency() - Method in class io.atomix.protocols.raft.RaftProtocol

Returns the read consistency.

ReadConsistency - Enum in io.atomix.protocols.raft

Constants for specifying Raft RaftQuery consistency levels.

readConsistency() - Method in class io.atomix.protocols.raft.session.RaftSession

Returns the session read consistency.

readConsistency() - Method in class io.atomix.protocols.raft.storage.log.entry.OpenSessionEntry

Returns the session read consistency level.

readDouble() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readFloat() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readInt() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readLong() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readMedium() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readShort() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readString() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readString(Charset) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readUnsignedByte() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readUnsignedInt() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readUnsignedMedium() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readUnsignedShort() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

readUTF8() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

reconfigure(NodeId, ReconfigureRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a reconfigure request to the given node.

ReconfigureRequest - Class in io.atomix.protocols.raft.protocol

Member configuration change request.

ReconfigureRequest(RaftMember, long, long) - Constructor for class io.atomix.protocols.raft.protocol.ReconfigureRequest

ReconfigureRequest.Builder - Class in io.atomix.protocols.raft.protocol

Reconfigure request builder.

ReconfigureResponse - Class in io.atomix.protocols.raft.protocol

Server configuration change response.

ReconfigureResponse(RaftResponse.Status, RaftError, long, long, long, Collection<RaftMember>) - Constructor for class io.atomix.protocols.raft.protocol.ReconfigureResponse

ReconfigureResponse.Builder - Class in io.atomix.protocols.raft.protocol

Reconfigure response builder.

recordEvent() - Method in class io.atomix.protocols.raft.utils.LoadMonitor

Records a load event.

RecoveryStrategy - Enum in io.atomix.protocols.raft.proxy

Session recovery strategy.

recoveryStrategy() - Method in class io.atomix.protocols.raft.RaftProtocol

Returns the recovery strategy.

registerAppendHandler(Function<AppendRequest, CompletableFuture<AppendResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers an append request callback.

registerCloseSessionHandler(Function<CloseSessionRequest, CompletableFuture<CloseSessionResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a close session request callback.

registerCommandHandler(Function<CommandRequest, CompletableFuture<CommandResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a command request callback.

registerConfigureHandler(Function<ConfigureRequest, CompletableFuture<ConfigureResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a configure request callback.

registerHeartbeatHandler(Function<HeartbeatRequest, CompletableFuture<HeartbeatResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Registers a heartbeat request callback.

registerIndexQuery(long, Runnable) - Method in class io.atomix.protocols.raft.session.RaftSession

Registers a session index query.

registerInstallHandler(Function<InstallRequest, CompletableFuture<InstallResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a install request callback.

registerJoinHandler(Function<JoinRequest, CompletableFuture<JoinResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a join request callback.

registerKeepAliveHandler(Function<KeepAliveRequest, CompletableFuture<KeepAliveResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a keep alive request callback.

registerLeaveHandler(Function<LeaveRequest, CompletableFuture<LeaveResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a leave request callback.

registerMetadataHandler(Function<MetadataRequest, CompletableFuture<MetadataResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a metadata request callback.

registerOpenSessionHandler(Function<OpenSessionRequest, CompletableFuture<OpenSessionResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers an open session request callback.

registerPollHandler(Function<PollRequest, CompletableFuture<PollResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a poll request callback.

registerPublishListener(SessionId, Consumer<PublishRequest>, Executor) - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Registers a publish request listener.

registerQueryHandler(Function<QueryRequest, CompletableFuture<QueryResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a query request callback.

registerReconfigureHandler(Function<ReconfigureRequest, CompletableFuture<ReconfigureResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a reconfigure request callback.

registerResetListener(SessionId, Consumer<ResetRequest>, Executor) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a reset request listener.

registerResult(long, OperationResult) - Method in class io.atomix.protocols.raft.session.RaftSession

Registers a session result.

registerSequenceQuery(long, Runnable) - Method in class io.atomix.protocols.raft.session.RaftSession

Registers a causal session query.

registerTransferHandler(Function<TransferRequest, CompletableFuture<TransferResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a transfer request callback.

registerVoteHandler(Function<VoteRequest, CompletableFuture<VoteResponse>>) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Registers a vote request callback.

remaining() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

remove() - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Removes the member from the configuration.

removeLeaderElectionListener(Consumer<RaftMember>) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Removes a leader election listener from the cluster.

removeListener(RaftClusterEventListener) - Method in interface io.atomix.protocols.raft.cluster.RaftCluster

Removes a listener from the cluster.

removeListener(SessionEventListener) - Method in class io.atomix.protocols.raft.session.RaftSession

removeRoleChangeListener(Consumer<RaftServer.Role>) - Method in interface io.atomix.protocols.raft.RaftServer

Removes a role change listener.

removeSession(SessionId) - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry

Closes a session.

removeSessions(PrimitiveId) - Method in class io.atomix.protocols.raft.session.RaftSessionRegistry

Removes all sessions registered for the given service.

removeTypeChangeListener(Consumer<RaftMember.Type>) - Method in interface io.atomix.protocols.raft.cluster.RaftMember

Removes a type change listener from the member.

resendEvents(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Resends events from the given sequence.

reset(Set<NodeId>, ResetRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Multicasts a reset request to all nodes in the cluster.

reset(long) - Method in class io.atomix.protocols.raft.storage.log.RaftLogWriter

Resets the head of the log to the given index.

ResetRequest - Class in io.atomix.protocols.raft.protocol

Event reset request.

ResetRequest(long, long) - Constructor for class io.atomix.protocols.raft.protocol.ResetRequest

ResetRequest.Builder - Class in io.atomix.protocols.raft.protocol

Reset request builder.

resetRequestSequence(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Resets the current request sequence number.

result() - Method in class io.atomix.protocols.raft.protocol.OperationResponse

Returns the operation result.

retryDelay() - Method in class io.atomix.protocols.raft.RaftProtocol

Returns the retry delay.

role() - Method in class io.atomix.protocols.raft.roles.AbstractRole

Returns the Raft state represented by this state.

role() - Method in class io.atomix.protocols.raft.roles.CandidateRole

role() - Method in class io.atomix.protocols.raft.roles.FollowerRole

role() - Method in class io.atomix.protocols.raft.roles.InactiveRole

role() - Method in class io.atomix.protocols.raft.roles.LeaderRole

role() - Method in class io.atomix.protocols.raft.roles.PassiveRole

role() - Method in class io.atomix.protocols.raft.roles.PromotableRole

role() - Method in interface io.atomix.protocols.raft.roles.RaftRole

Returns the server state type.

S

selectConnections(NodeId, List<NodeId>) - Method in enum io.atomix.protocols.raft.proxy.CommunicationStrategy

Returns a prioritized list of servers to which the client can connect and submit operations.

sequenceNumber() - Method in class io.atomix.protocols.raft.protocol.OperationRequest

Returns the request sequence number.

sequenceNumber() - Method in class io.atomix.protocols.raft.storage.log.entry.OperationEntry

Returns the operation sequence number.

serializer() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns the storage serializer.

serviceId() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

Returns the snapshot identifier.

serviceId() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

serviceId() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Returns the identifier of the state machine to which the snapshot belongs.

serviceId() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

Returns the service identifier.

serviceName() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

Returns the service name.

serviceName() - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest

Returns the state machine name.

serviceName() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

serviceName() - Method in class io.atomix.protocols.raft.session.RaftSession

serviceName() - Method in class io.atomix.protocols.raft.storage.log.entry.OpenSessionEntry

Returns the session state machine name.

serviceName() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Returns the service name.

serviceType() - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest

Returns the state machine type;

serviceType() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

serviceType() - Method in class io.atomix.protocols.raft.session.RaftSession

serviceType() - Method in class io.atomix.protocols.raft.storage.log.entry.OpenSessionEntry

Returns the session state machine type name.

session() - Method in class io.atomix.protocols.raft.protocol.OpenSessionResponse

Returns the registered session ID.

session() - Method in class io.atomix.protocols.raft.protocol.SessionRequest

Returns the session ID.

session() - Method in class io.atomix.protocols.raft.storage.log.entry.SessionEntry

Returns the session ID.

SessionEntry - Class in io.atomix.protocols.raft.storage.log.entry

Base class for session-related entries.

SessionEntry(long, long, long) - Constructor for class io.atomix.protocols.raft.storage.log.entry.SessionEntry

sessionId() - Method in class io.atomix.protocols.raft.session.RaftSession

sessionIds() - Method in class io.atomix.protocols.raft.protocol.KeepAliveRequest

Returns the session identifiers.

sessionIds() - Method in class io.atomix.protocols.raft.protocol.KeepAliveResponse

Returns the sessions that were successfully kept alive.

sessionIds() - Method in class io.atomix.protocols.raft.storage.log.entry.KeepAliveEntry

Returns the session identifiers.

SessionRequest - Class in io.atomix.protocols.raft.protocol

Base session request.

SessionRequest.Builder<T extends SessionRequest.Builder<T,U>,U extends SessionRequest> - Class in io.atomix.protocols.raft.protocol

Session request builder.

SessionResponse - Class in io.atomix.protocols.raft.protocol

Base session response.

SessionResponse.Builder<T extends SessionResponse.Builder<T,U>,U extends SessionResponse> - Class in io.atomix.protocols.raft.protocol

Session response builder.

sessions() - Method in class io.atomix.protocols.raft.protocol.MetadataResponse

Returns the session metadata.

sessions() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

setCommandSequence(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Sets the session operation sequence number.

setEventIndex(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Sets the session event index.

setLastApplied(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Sets the session index.

setLastCompleted(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Sets the last completed event index for the session.

setLastUpdated(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Updates the session timestamp.

setRequestSequence(long) - Method in class io.atomix.protocols.raft.session.RaftSession

Sets the current request sequence number.

shutdown() - Method in interface io.atomix.protocols.raft.RaftServer

Shuts down the server without leaving the Raft cluster.

skip(int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

Snapshot - Class in io.atomix.protocols.raft.storage.snapshot

Manages reading and writing a single snapshot file.

snapshot() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotReader

Returns the snapshot associated with the reader.

snapshot(SnapshotWriter) - Method in interface io.atomix.protocols.raft.storage.snapshot.Snapshottable

Takes a snapshot of the state machine state.

snapshot() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

Returns the snapshot associated with the writer.

SnapshotDescriptor - Class in io.atomix.protocols.raft.storage.snapshot

Stores information about a Snapshot of the state machine.

SnapshotDescriptor(Buffer) - Constructor for class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

SnapshotDescriptor.Builder - Class in io.atomix.protocols.raft.storage.snapshot

Snapshot descriptor builder.

SnapshotFile - Class in io.atomix.protocols.raft.storage.snapshot

Represents a snapshot file on disk.

snapshotIndex() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

Returns the snapshot index.

SnapshotReader - Class in io.atomix.protocols.raft.storage.snapshot

Reads bytes from a state machine Snapshot.

SnapshotStore - Class in io.atomix.protocols.raft.storage.snapshot

Persists server snapshots via the RaftStorage module.

SnapshotStore(RaftStorage) - Constructor for class io.atomix.protocols.raft.storage.snapshot.SnapshotStore

Snapshottable - Interface in io.atomix.protocols.raft.storage.snapshot

Support for periodically persisting PrimitiveService snapshots to disk.

snapshotTimestamp() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

Returns the snapshot timestamp.

SnapshotWriter - Class in io.atomix.protocols.raft.storage.snapshot

Writes bytes to a state machine Snapshot.

start() - Method in class io.atomix.protocols.raft.roles.AbstractRole

start() - Method in class io.atomix.protocols.raft.roles.CandidateRole

start() - Method in class io.atomix.protocols.raft.roles.FollowerRole

start() - Method in class io.atomix.protocols.raft.roles.LeaderRole

start() - Method in class io.atomix.protocols.raft.roles.PassiveRole

statistics() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns the Raft storage statistics.

status() - Method in class io.atomix.protocols.raft.protocol.AbstractRaftResponse

status() - Method in interface io.atomix.protocols.raft.protocol.RaftResponse

Returns the response status.

stop() - Method in class io.atomix.protocols.raft.roles.AbstractRole

stop() - Method in class io.atomix.protocols.raft.roles.CandidateRole

stop() - Method in class io.atomix.protocols.raft.roles.FollowerRole

stop() - Method in class io.atomix.protocols.raft.roles.LeaderRole

stop() - Method in class io.atomix.protocols.raft.roles.PassiveRole

storageLevel() - Method in class io.atomix.protocols.raft.partition.RaftPartition

Returns the Raft partition storage level.

storageLevel() - Method in class io.atomix.protocols.raft.storage.RaftStorage

Returns the storage level.

storeConfiguration(Configuration) - Method in class io.atomix.protocols.raft.storage.system.MetaStore

Stores the current cluster configuration.

storeTerm(long) - Method in class io.atomix.protocols.raft.storage.system.MetaStore

Stores the current server term.

storeVote(NodeId) - Method in class io.atomix.protocols.raft.storage.system.MetaStore

Stores the last voted server.

succeed() - Method in class io.atomix.protocols.raft.utils.Quorum

Indicates that a call in the quorum succeeded.

succeeded() - Method in class io.atomix.protocols.raft.protocol.AppendResponse

Returns a boolean indicating whether the append was successful.

T

takeSnapshot(long) - Method in class io.atomix.protocols.raft.service.RaftServiceContext

Takes a snapshot of the service state.

term() - Method in class io.atomix.protocols.raft.partition.RaftPartition

term() - Method in class io.atomix.protocols.raft.protocol.AppendRequest

Returns the requesting node's current term.

term() - Method in class io.atomix.protocols.raft.protocol.AppendResponse

Returns the requesting node's current term.

term() - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse

Returns the configuration term.

term() - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest

Returns the requesting node's current term.

term() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

Returns the requesting node's current term.

term() - Method in class io.atomix.protocols.raft.protocol.PollRequest

Returns the requesting node's current term.

term() - Method in class io.atomix.protocols.raft.protocol.PollResponse

Returns the responding node's current term.

term() - Method in class io.atomix.protocols.raft.protocol.ReconfigureRequest

Returns the configuration term.

term() - Method in class io.atomix.protocols.raft.protocol.VoteRequest

Returns the requesting node's current term.

term() - Method in class io.atomix.protocols.raft.protocol.VoteResponse

Returns the responding node's current term.

term() - Method in interface io.atomix.protocols.raft.RaftClient

Returns the current term.

term() - Method in class io.atomix.protocols.raft.storage.log.entry.RaftLogEntry

Returns the entry term.

term() - Method in class io.atomix.protocols.raft.storage.system.Configuration

Returns the configuration term.

time() - Method in class io.atomix.protocols.raft.storage.system.Configuration

Returns the configuration time.

timeout() - Method in class io.atomix.protocols.raft.protocol.OpenSessionResponse

Returns the session timeout.

timestamp() - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse

Returns the response configuration time.

timestamp() - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest

Returns the configuration timestamp.

timestamp() - Method in class io.atomix.protocols.raft.storage.log.entry.TimestampedEntry

Returns the entry timestamp.

timestamp() - Method in class io.atomix.protocols.raft.storage.snapshot.Snapshot

Returns the snapshot timestamp.

timestamp() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor

Returns the snapshot timestamp.

TimestampedEntry - Class in io.atomix.protocols.raft.storage.log.entry

Base class for timestamped entries.

TimestampedEntry(long, long) - Constructor for class io.atomix.protocols.raft.storage.log.entry.TimestampedEntry

toString() - Method in class io.atomix.protocols.raft.partition.RaftPartition

toString() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup

toString() - Method in class io.atomix.protocols.raft.protocol.AbstractRaftResponse

toString() - Method in class io.atomix.protocols.raft.protocol.AppendRequest

toString() - Method in class io.atomix.protocols.raft.protocol.AppendResponse

toString() - Method in class io.atomix.protocols.raft.protocol.CommandRequest

toString() - Method in class io.atomix.protocols.raft.protocol.ConfigurationRequest

toString() - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse

toString() - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest

toString() - Method in class io.atomix.protocols.raft.protocol.HeartbeatRequest

toString() - Method in class io.atomix.protocols.raft.protocol.InstallRequest

toString() - Method in class io.atomix.protocols.raft.protocol.KeepAliveRequest

toString() - Method in class io.atomix.protocols.raft.protocol.KeepAliveResponse

toString() - Method in class io.atomix.protocols.raft.protocol.MetadataResponse

toString() - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest

toString() - Method in class io.atomix.protocols.raft.protocol.OpenSessionResponse

toString() - Method in class io.atomix.protocols.raft.protocol.OperationResponse

toString() - Method in class io.atomix.protocols.raft.protocol.PollRequest

toString() - Method in class io.atomix.protocols.raft.protocol.PollResponse

toString() - Method in class io.atomix.protocols.raft.protocol.PublishRequest

toString() - Method in class io.atomix.protocols.raft.protocol.QueryRequest

toString() - Method in class io.atomix.protocols.raft.protocol.ReconfigureRequest

toString() - Method in class io.atomix.protocols.raft.protocol.ResetRequest

toString() - Method in class io.atomix.protocols.raft.protocol.SessionRequest

toString() - Method in class io.atomix.protocols.raft.protocol.TransferRequest

toString() - Method in class io.atomix.protocols.raft.protocol.VoteRequest

toString() - Method in class io.atomix.protocols.raft.protocol.VoteResponse

toString() - Method in class io.atomix.protocols.raft.RaftError

toString() - Method in class io.atomix.protocols.raft.roles.AbstractRole

toString() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

toString() - Method in class io.atomix.protocols.raft.session.RaftSession

toString() - Method in class io.atomix.protocols.raft.storage.log.entry.CloseSessionEntry

toString() - Method in class io.atomix.protocols.raft.storage.log.entry.ConfigurationEntry

toString() - Method in class io.atomix.protocols.raft.storage.log.entry.KeepAliveEntry

toString() - Method in class io.atomix.protocols.raft.storage.log.entry.OpenSessionEntry

toString() - Method in class io.atomix.protocols.raft.storage.log.entry.OperationEntry

toString() - Method in class io.atomix.protocols.raft.storage.log.entry.RaftLogEntry

toString() - Method in class io.atomix.protocols.raft.storage.log.entry.SessionEntry

toString() - Method in class io.atomix.protocols.raft.storage.log.entry.TimestampedEntry

toString() - Method in class io.atomix.protocols.raft.storage.RaftStorage

toString() - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotStore

toString() - Method in class io.atomix.protocols.raft.storage.system.Configuration

toString() - Method in class io.atomix.protocols.raft.storage.system.MetaStore

toString() - Method in class io.atomix.protocols.raft.utils.LoadMonitor

transfer(NodeId, TransferRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a transfer request to the given node.

TransferRequest - Class in io.atomix.protocols.raft.protocol

Leadership transfer request.

TransferRequest.Builder - Class in io.atomix.protocols.raft.protocol

Transfer request builder.

TransferResponse - Class in io.atomix.protocols.raft.protocol

Leadership transfer response.

TransferResponse(RaftResponse.Status, RaftError) - Constructor for class io.atomix.protocols.raft.protocol.TransferResponse

TransferResponse.Builder - Class in io.atomix.protocols.raft.protocol

Join response builder.

truncate(long) - Method in class io.atomix.protocols.raft.storage.log.RaftLogWriter

type() - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup

type() - Method in class io.atomix.protocols.raft.RaftError

Returns the error type.

TYPE - Static variable in class io.atomix.protocols.raft.RaftProtocol

type() - Method in class io.atomix.protocols.raft.RaftProtocol

U

Unavailable(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.Unavailable

Unavailable(Throwable) - Constructor for exception io.atomix.protocols.raft.RaftException.Unavailable

UnknownClient(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.UnknownClient

UnknownService(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.UnknownService

UnknownSession(String, Object...) - Constructor for exception io.atomix.protocols.raft.RaftException.UnknownSession

unregisterAppendHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the append request handler.

unregisterCloseSessionHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the close session request handler.

unregisterCommandHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the command request handler.

unregisterConfigureHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the configure request handler.

unregisterHeartbeatHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Unregisters the heartbeat request handler.

unregisterInstallHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the install request handler.

unregisterJoinHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the join request handler.

unregisterKeepAliveHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the keep alive request handler.

unregisterLeaveHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the leave request handler.

unregisterMetadataHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the metadata request handler.

unregisterOpenSessionHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the open session request handler.

unregisterPollHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the poll request handler.

unregisterPublishListener(SessionId) - Method in interface io.atomix.protocols.raft.protocol.RaftClientProtocol

Unregisters the publish request listener for the given session.

unregisterQueryHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the query request handler.

unregisterReconfigureHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the reconfigure request handler.

unregisterResetListener(SessionId) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the given reset request listener.

unregisterTransferHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the transfer request handler.

unregisterVoteHandler() - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Unregisters the vote request handler.

V

valueOf(String) - Static method in enum io.atomix.protocols.raft.cluster.RaftClusterEvent.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.protocols.raft.cluster.RaftMember.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.protocols.raft.protocol.RaftResponse.Status

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.protocols.raft.proxy.CommunicationStrategy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.protocols.raft.proxy.RecoveryStrategy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.protocols.raft.RaftError.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.protocols.raft.RaftServer.Role

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.protocols.raft.ReadConsistency

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.protocols.raft.storage.log.RaftLogReader.Mode

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.atomix.protocols.raft.cluster.RaftClusterEvent.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.protocols.raft.cluster.RaftMember.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.protocols.raft.protocol.RaftResponse.Status

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.protocols.raft.proxy.CommunicationStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.protocols.raft.proxy.RecoveryStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.protocols.raft.RaftError.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.protocols.raft.RaftServer.Role

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.protocols.raft.ReadConsistency

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.protocols.raft.storage.log.RaftLogReader.Mode

Returns an array containing the constants of this enum type, in the order they are declared.

vote(NodeId, VoteRequest) - Method in interface io.atomix.protocols.raft.protocol.RaftServerProtocol

Sends a vote request to the given node.

voted() - Method in class io.atomix.protocols.raft.protocol.VoteResponse

Returns a boolean indicating whether the vote was granted.

VoteRequest - Class in io.atomix.protocols.raft.protocol

Server vote request.

VoteRequest(long, String, long, long) - Constructor for class io.atomix.protocols.raft.protocol.VoteRequest

VoteRequest.Builder - Class in io.atomix.protocols.raft.protocol

Vote request builder.

VoteResponse - Class in io.atomix.protocols.raft.protocol

Server vote response.

VoteResponse(RaftResponse.Status, RaftError, long, boolean) - Constructor for class io.atomix.protocols.raft.protocol.VoteResponse

VoteResponse.Builder - Class in io.atomix.protocols.raft.protocol

Poll response builder.

W

wallClock() - Method in class io.atomix.protocols.raft.service.RaftServiceContext

withAccepted(boolean) - Method in class io.atomix.protocols.raft.protocol.PollResponse.Builder

Sets whether the poll was granted.

withCandidate(NodeId) - Method in class io.atomix.protocols.raft.protocol.PollRequest.Builder

Sets the request leader.

withCandidate(NodeId) - Method in class io.atomix.protocols.raft.protocol.VoteRequest.Builder

Sets the request leader.

withClientId(String) - Method in class io.atomix.protocols.raft.RaftClient.Builder

Sets the client ID.

withClusterService(ClusterService) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Sets the cluster service.

withCommandSequences(long[]) - Method in class io.atomix.protocols.raft.protocol.KeepAliveRequest.Builder

Sets the command sequence numbers.

withCommitIndex(long) - Method in class io.atomix.protocols.raft.protocol.AppendRequest.Builder

Sets the request commit index.

withCommunicationStrategy(CommunicationStrategy) - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

Sets the communication strategy.

withComplete(boolean) - Method in class io.atomix.protocols.raft.protocol.InstallRequest.Builder

Sets whether the request is complete.

withData(byte[]) - Method in class io.atomix.protocols.raft.protocol.InstallRequest.Builder

Sets the request snapshot bytes.

withDataDirectory(File) - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup.Builder

Sets the path to the data directory.

withDirectory(String) - Method in class io.atomix.protocols.raft.storage.log.RaftLog.Builder

Sets the log directory, returning the builder for method chaining.

withDirectory(File) - Method in class io.atomix.protocols.raft.storage.log.RaftLog.Builder

Sets the log directory, returning the builder for method chaining.

withDirectory(String) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Sets the log directory, returning the builder for method chaining.

withDirectory(File) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Sets the log directory, returning the builder for method chaining.

withDynamicCompaction() - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Enables dynamic log compaction.

withDynamicCompaction(boolean) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Enables dynamic log compaction.

withElectionTimeout(Duration) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Sets the Raft election timeout, returning the Raft configuration for method chaining.

withEntries(RaftLogEntry...) - Method in class io.atomix.protocols.raft.protocol.AppendRequest.Builder

Sets the request entries.

withEntries(List<RaftLogEntry>) - Method in class io.atomix.protocols.raft.protocol.AppendRequest.Builder

Sets the request entries.

withError(RaftError.Type) - Method in interface io.atomix.protocols.raft.protocol.RaftResponse.Builder

Sets the response error.

withError(RaftError.Type, String) - Method in interface io.atomix.protocols.raft.protocol.RaftResponse.Builder

Sets the response error.

withError(RaftError) - Method in interface io.atomix.protocols.raft.protocol.RaftResponse.Builder

Sets the response error.

withEventIndex(long) - Method in class io.atomix.protocols.raft.protocol.OperationResponse.Builder

Sets the response index.

withEventIndex(long) - Method in class io.atomix.protocols.raft.protocol.PublishRequest.Builder

Sets the event index.

withEventIndexes(long[]) - Method in class io.atomix.protocols.raft.protocol.KeepAliveRequest.Builder

Sets the event indexes.

withEvents(PrimitiveEvent...) - Method in class io.atomix.protocols.raft.protocol.PublishRequest.Builder

Sets the request events.

withEvents(List<PrimitiveEvent>) - Method in class io.atomix.protocols.raft.protocol.PublishRequest.Builder

Sets the request events.

withExecutor(Executor) - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

Sets the executor with which to complete proxy futures.

withFlushOnCommit() - Method in class io.atomix.protocols.raft.storage.log.RaftLog.Builder

Enables flushing buffers to disk when entries are committed to a segment, returning the builder for method chaining.

withFlushOnCommit(boolean) - Method in class io.atomix.protocols.raft.storage.log.RaftLog.Builder

Sets whether to flush buffers to disk when entries are committed to a segment, returning the builder for method chaining.

withFlushOnCommit() - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Enables flushing buffers to disk when entries are committed to a segment, returning the builder for method chaining.

withFlushOnCommit(boolean) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Sets whether to flush buffers to disk when entries are committed to a segment, returning the builder for method chaining.

withFreeDiskBuffer(double) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Sets the percentage of free disk space that must be preserved before log compaction is forced.

withHeartbeatInterval(Duration) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Sets the Raft heartbeat interval, returning the Raft configuration for method chaining.

withIndex(long) - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse.Builder

Sets the response index.

withIndex(long) - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest.Builder

Sets the request index.

withIndex(long) - Method in class io.atomix.protocols.raft.protocol.InstallRequest.Builder

Sets the request index.

withIndex(long) - Method in class io.atomix.protocols.raft.protocol.OperationResponse.Builder

Sets the response index.

withIndex(long) - Method in class io.atomix.protocols.raft.protocol.QueryRequest.Builder

Sets the request index.

withIndex(long) - Method in class io.atomix.protocols.raft.protocol.ReconfigureRequest.Builder

Sets the request index.

withIndex(long) - Method in class io.atomix.protocols.raft.protocol.ResetRequest.Builder

Sets the event index.

withIndex(long) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor.Builder

Sets the snapshot index.

withLastLogIndex(long) - Method in class io.atomix.protocols.raft.protocol.AppendResponse.Builder

Sets the last index of the replica's log.

withLastLogIndex(long) - Method in class io.atomix.protocols.raft.protocol.PollRequest.Builder

Sets the request last log index.

withLastLogIndex(long) - Method in class io.atomix.protocols.raft.protocol.VoteRequest.Builder

Sets the request last log index.

withLastLogTerm(long) - Method in class io.atomix.protocols.raft.protocol.PollRequest.Builder

Sets the request last log term.

withLastLogTerm(long) - Method in class io.atomix.protocols.raft.protocol.VoteRequest.Builder

Sets the request last log term.

withLastSequence(long) - Method in class io.atomix.protocols.raft.protocol.OperationResponse.Builder

Sets the last sequence number.

withLeader(NodeId) - Method in class io.atomix.protocols.raft.protocol.AppendRequest.Builder

Sets the request leader.

withLeader(NodeId) - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest.Builder

Sets the request leader.

withLeader(NodeId) - Method in class io.atomix.protocols.raft.protocol.HeartbeatRequest.Builder

Sets the request leader.

withLeader(NodeId) - Method in class io.atomix.protocols.raft.protocol.InstallRequest.Builder

Sets the request leader.

withLeader(NodeId) - Method in class io.atomix.protocols.raft.protocol.KeepAliveResponse.Builder

Sets the response leader.

withMaxEntriesPerSegment(int) - Method in class io.atomix.protocols.raft.storage.log.RaftLog.Builder

Sets the maximum number of allows entries per segment, returning the builder for method chaining.

withMaxEntriesPerSegment(int) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Sets the maximum number of allows entries per segment, returning the builder for method chaining.

withMaxRetries(int) - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

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

withMaxSegmentSize(int) - Method in class io.atomix.protocols.raft.storage.log.RaftLog.Builder

Sets the maximum segment size in bytes, returning the builder for method chaining.

withMaxSegmentSize(int) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Sets the maximum segment size in bytes, returning the builder for method chaining.

withMaxTimeout(long) - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest.Builder

Sets the maximum session timeout.

withMaxTimeout(Duration) - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

Sets the maximum session timeout.

withMember(RaftMember) - Method in class io.atomix.protocols.raft.protocol.ConfigurationRequest.Builder

Sets the request member.

withMember(NodeId) - Method in class io.atomix.protocols.raft.protocol.TransferRequest.Builder

Sets the request member.

withMembers(Collection<RaftMember>) - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse.Builder

Sets the response members.

withMembers(Collection<RaftMember>) - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest.Builder

Sets the request members.

withMembers(Collection<NodeId>) - Method in class io.atomix.protocols.raft.protocol.HeartbeatRequest.Builder

Sets the request members.

withMembers(Collection<NodeId>) - Method in class io.atomix.protocols.raft.protocol.KeepAliveResponse.Builder

Sets the response members.

withMinTimeout(long) - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest.Builder

Sets the minimum session timeout.

withMinTimeout(Duration) - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

Sets the minimum session timeout.

withName(String) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Sets the server name.

withName(String) - Method in class io.atomix.protocols.raft.storage.log.RaftLog.Builder

Sets the storage name.

withNodeId(NodeId) - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest.Builder

Sets the client node identifier.

withNodeId(NodeId) - Method in class io.atomix.protocols.raft.RaftClient.Builder

Sets the local node identifier.

withNumPartitions(int) - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup.Builder

Sets the number of partitions.

withOffset(int) - Method in class io.atomix.protocols.raft.protocol.InstallRequest.Builder

Sets the request offset.

withOperation(PrimitiveOperation) - Method in class io.atomix.protocols.raft.protocol.OperationRequest.Builder

Sets the request operation.

withPartitionSize(int) - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup.Builder

Sets the partition size.

withPrefix(String) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Sets the storage prefix.

withPreviousIndex(long) - Method in class io.atomix.protocols.raft.protocol.PublishRequest.Builder

Sets the previous event index.

withPrevLogIndex(long) - Method in class io.atomix.protocols.raft.protocol.AppendRequest.Builder

Sets the request last log index.

withPrevLogTerm(long) - Method in class io.atomix.protocols.raft.protocol.AppendRequest.Builder

Sets the request last log term.

withPrimitiveTypes(PrimitiveTypeRegistry) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Sets the primitive types.

withProtocol(RaftClientProtocol) - Method in class io.atomix.protocols.raft.RaftClient.Builder

Sets the client protocol.

withProtocol(RaftServerProtocol) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Sets the server protocol.

withReadConsistency(ReadConsistency) - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest.Builder

Sets the session read consistency.

withReadConsistency(ReadConsistency) - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

Sets the read consistency level.

withRecoveryStrategy(Recovery) - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

Sets the recovery strategy.

withResult(byte[]) - Method in class io.atomix.protocols.raft.protocol.OperationResponse.Builder

Sets the operation response result.

withRetainStaleSnapshots() - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Enables retaining stale snapshots on disk, returning the builder for method chaining.

withRetainStaleSnapshots(boolean) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Sets whether to retain stale snapshots on disk, returning the builder for method chaining.

withRetryDelay(long, TimeUnit) - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

Sets the operation retry delay.

withRetryDelay(Duration) - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

Sets the operation retry delay.

withRetryDelayMillis(long) - Method in class io.atomix.protocols.raft.RaftProtocol.Builder

Sets the operation retry delay.

withSequence(long) - Method in class io.atomix.protocols.raft.protocol.OperationRequest.Builder

Sets the request sequence number.

withSerializer(Serializer) - Method in class io.atomix.protocols.raft.storage.log.RaftLog.Builder

Sets the journal serializer, returning the builder for method chaining.

withSerializer(Serializer) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Sets the storage serializer.

withServiceId(long) - Method in class io.atomix.protocols.raft.protocol.InstallRequest.Builder

Sets the request snapshot identifier.

withServiceId(long) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor.Builder

Sets the snapshot identifier.

withServiceName(String) - Method in class io.atomix.protocols.raft.protocol.InstallRequest.Builder

Sets the request service name.

withServiceName(String) - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest.Builder

Sets the service name.

withServiceType(PrimitiveType) - Method in class io.atomix.protocols.raft.protocol.OpenSessionRequest.Builder

Sets the service type name.

withSession(long) - Method in class io.atomix.protocols.raft.protocol.OpenSessionResponse.Builder

Sets the response session ID.

withSession(long) - Method in class io.atomix.protocols.raft.protocol.SessionRequest.Builder

Sets the session ID.

withSessionIds(long[]) - Method in class io.atomix.protocols.raft.protocol.KeepAliveRequest.Builder

Sets the session identifiers.

withSessionIds(long[]) - Method in class io.atomix.protocols.raft.protocol.KeepAliveResponse.Builder

Sets the response sessions.

withSessions(SessionMetadata...) - Method in class io.atomix.protocols.raft.protocol.MetadataResponse.Builder

Sets the session metadata.

withSessions(Collection<SessionMetadata>) - Method in class io.atomix.protocols.raft.protocol.MetadataResponse.Builder

Sets the session metadata.

withSessionTimeout(Duration) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Sets the Raft session timeout, returning the Raft configuration for method chaining.

withStatus(RaftResponse.Status) - Method in interface io.atomix.protocols.raft.protocol.RaftResponse.Builder

Sets the response status.

withStorage(RaftStorage) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Sets the storage module.

withStorageLevel(StorageLevel) - Method in class io.atomix.protocols.raft.partition.RaftPartitionGroup.Builder

Sets the storage level.

withStorageLevel(StorageLevel) - Method in class io.atomix.protocols.raft.storage.log.RaftLog.Builder

Sets the log storage level, returning the builder for method chaining.

withStorageLevel(StorageLevel) - Method in class io.atomix.protocols.raft.storage.RaftStorage.Builder

Sets the log storage level, returning the builder for method chaining.

withSucceeded(boolean) - Method in class io.atomix.protocols.raft.protocol.AppendResponse.Builder

Sets whether the request succeeded.

withTerm(long) - Method in class io.atomix.protocols.raft.protocol.AppendRequest.Builder

Sets the request term.

withTerm(long) - Method in class io.atomix.protocols.raft.protocol.AppendResponse.Builder

Sets the response term.

withTerm(long) - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse.Builder

Sets the response term.

withTerm(long) - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest.Builder

Sets the request term.

withTerm(long) - Method in class io.atomix.protocols.raft.protocol.InstallRequest.Builder

Sets the request term.

withTerm(long) - Method in class io.atomix.protocols.raft.protocol.PollRequest.Builder

Sets the request term.

withTerm(long) - Method in class io.atomix.protocols.raft.protocol.PollResponse.Builder

Sets the response term.

withTerm(long) - Method in class io.atomix.protocols.raft.protocol.ReconfigureRequest.Builder

Sets the request term.

withTerm(long) - Method in class io.atomix.protocols.raft.protocol.VoteRequest.Builder

Sets the request term.

withTerm(long) - Method in class io.atomix.protocols.raft.protocol.VoteResponse.Builder

Sets the response term.

withThreadModel(ThreadModel) - Method in class io.atomix.protocols.raft.RaftClient.Builder

Sets the client thread model.

withThreadModel(ThreadModel) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Sets the server thread model.

withThreadPoolSize(int) - Method in class io.atomix.protocols.raft.RaftClient.Builder

Sets the client thread pool size.

withThreadPoolSize(int) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Sets the server thread pool size.

withTime(long) - Method in class io.atomix.protocols.raft.protocol.ConfigurationResponse.Builder

Sets the response time.

withTime(long) - Method in class io.atomix.protocols.raft.protocol.ConfigureRequest.Builder

Sets the request timestamp.

withTimeout(long) - Method in class io.atomix.protocols.raft.protocol.OpenSessionResponse.Builder

Sets the session timeout.

withTimestamp(long) - Method in class io.atomix.protocols.raft.protocol.InstallRequest.Builder

Sets the request timestamp.

withTimestamp(long) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotDescriptor.Builder

Sets the snapshot timestamp.

withType(RaftMember.Type) - Method in class io.atomix.protocols.raft.RaftServer.Builder

Deprecated.

withVoted(boolean) - Method in class io.atomix.protocols.raft.protocol.VoteResponse.Builder

Sets whether the vote was granted.

write(Bytes) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

write(byte[]) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

write(Bytes, int, int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

write(byte[], int, int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

write(Buffer) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeBoolean(boolean) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeByte(int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeChar(char) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeDouble(double) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeFloat(float) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeInt(int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeLong(long) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeMedium(int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writer() - Method in class io.atomix.protocols.raft.storage.log.RaftLog

writeShort(short) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeString(String) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeString(String, Charset) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeUnsignedByte(int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeUnsignedInt(long) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeUnsignedMedium(int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeUnsignedShort(int) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

writeUTF8(String) - Method in class io.atomix.protocols.raft.storage.snapshot.SnapshotWriter

A B C D E F G H I J K L M N O P Q R S T U V W