Index (jgroups-raft 1.1.3.Final API)

A B C D E F G H I K L M N O P R S T U V W _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accept(byte[], Throwable) - Method in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
accept(byte[], Throwable) - Method in class org.jgroups.protocols.raft.REDIRECT.ResponseHandler
acceptor - Variable in class org.jgroups.protocols.raft.CLIENT
add(long, T, Supplier<Integer>) - Method in class org.jgroups.raft.util.RequestTable: Adds a response to the response set.
add(Address, RaftNode) - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Add a new member to the cluster.
add(Address, RaftNode) - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
add(Address, RaftNode) - Method in class org.jgroups.raft.testfwk.RaftCluster
add(LogEntry...) - Method in class org.jgroups.protocols.raft.LogEntries
add(RAFT.Request) - Method in class org.jgroups.protocols.raft.RAFT
add(T) - Method in class org.jgroups.raft.util.ArrayRingBuffer
add(T, Supplier<Integer>) - Method in class org.jgroups.raft.util.RequestTable.Entry
add_server - Enum constant in enum org.jgroups.protocols.raft.CLIENT.RequestType
ADD_SERVER - Enum constant in enum org.jgroups.protocols.raft.REDIRECT.RequestType
add_server_future - Variable in class org.jgroups.protocols.raft.RAFT
addAndGet - Enum constant in enum org.jgroups.raft.blocks.CounterService.Command
addAndGet(long) - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
addCommandInterceptor(Predicate<Message>) - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Intercept messages before sending.
additions - Variable in class org.jgroups.raft.util.CounterStateMachine
additions() - Method in class org.jgroups.raft.util.CounterStateMachine
addNotificationListener(ReplicatedStateMachine.Notification<K, V>) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
addRoleChangeListener(RAFT.RoleChange) - Method in class org.jgroups.raft.blocks.CounterService
addRoleChangeListener(RAFT.RoleChange) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
addRoleListener(RAFT.RoleChange) - Method in class org.jgroups.protocols.raft.RAFT
addRoleListener(RAFT.RoleChange) - Method in class org.jgroups.raft.RaftHandle
addServer - Enum constant in enum org.jgroups.protocols.raft.InternalCommand.Type
addServer(String) - Method in interface org.jgroups.protocols.raft.DynamicMembership
addServer(String) - Method in class org.jgroups.protocols.raft.RAFT
addServer(String) - Method in class org.jgroups.protocols.raft.REDIRECT
addServer(String) - Method in class org.jgroups.raft.RaftHandle: Asynchronously adds a new server to the RAFT cluster.
adjust(List<Address>, long) - Method in class org.jgroups.raft.util.CommitTable
advance(long) - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository: Advances the commit index.
advanceTermForElection() - Method in class org.jgroups.protocols.raft.state.RaftState: Advances the term for leader election.
allow_dirty_reads - Variable in class org.jgroups.raft.blocks.CounterService: If true, reads can return the local counter value directly.
allow_dirty_reads - Variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
allowDirtyReads() - Method in class org.jgroups.raft.blocks.CounterService
allowDirtyReads() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
allowDirtyReads(boolean) - Method in class org.jgroups.raft.blocks.CounterService
allowDirtyReads(boolean) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
AnalyzeLog - Class in org.jgroups.raft.util
AnalyzeLog() - Constructor for class org.jgroups.raft.util.AnalyzeLog
analzye(String...) - Method in class org.jgroups.raft.util.AnalyzeLog
append(long, LogEntries) - Method in class org.jgroups.protocols.raft.FileBasedLog
append(long, LogEntries) - Method in class org.jgroups.protocols.raft.InMemoryLog
append(long, LogEntries) - Method in interface org.jgroups.protocols.raft.Log: Append the entries starting at index.
append(long, LogEntries) - Method in class org.jgroups.protocols.raft.RAFT: Appends to the log and returns true if added or false if not (e.g. because the entry already existed
append(long, LogEntries) - Method in class org.jgroups.raft.util.LogCache
APPEND_ENTRIES_REQ - Static variable in class org.jgroups.protocols.raft.RAFT
APPEND_ENTRIES_RSP - Static variable in class org.jgroups.protocols.raft.RAFT
APPEND_RESULT - Static variable in class org.jgroups.protocols.raft.RAFT
AppendEntriesRequest - Class in org.jgroups.protocols.raft: Used to send AppendEntries messages to cluster members.
AppendEntriesRequest() - Constructor for class org.jgroups.protocols.raft.AppendEntriesRequest
AppendEntriesRequest(Address, long, long, long, long, long) - Constructor for class org.jgroups.protocols.raft.AppendEntriesRequest
AppendEntriesResponse - Class in org.jgroups.protocols.raft
AppendEntriesResponse() - Constructor for class org.jgroups.protocols.raft.AppendEntriesResponse
AppendEntriesResponse(long, AppendResult) - Constructor for class org.jgroups.protocols.raft.AppendEntriesResponse
AppendResult - Class in org.jgroups.protocols.raft: The result of an AppendEntries request
AppendResult() - Constructor for class org.jgroups.protocols.raft.AppendResult
AppendResult(AppendResult.Result, long) - Constructor for class org.jgroups.protocols.raft.AppendResult
AppendResult(AppendResult.Result, long, long) - Constructor for class org.jgroups.protocols.raft.AppendResult
AppendResult.Result - Enum in org.jgroups.protocols.raft
apply(byte[]) - Method in class org.jgroups.protocols.raft.REDIRECT.ResponseHandler
apply(byte[], int, int, boolean) - Method in class org.jgroups.raft.blocks.CounterService
apply(byte[], int, int, boolean) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
apply(byte[], int, int, boolean) - Method in interface org.jgroups.raft.StateMachine: Applies a command to the state machine.
apply(byte[], int, int, boolean) - Method in class org.jgroups.raft.util.CounterStateMachine
apply(byte[], int, int, boolean) - Method in class org.jgroups.raft.util.ReplStateMachine
apply(Throwable) - Method in class org.jgroups.protocols.raft.REDIRECT.ResponseHandler
applyCommit(long, boolean) - Method in class org.jgroups.protocols.raft.RAFT: Applies the commit at index
applyCommits(long, boolean) - Method in class org.jgroups.protocols.raft.RAFT: Applies log entries [commit_index+1 .. to_inclusive] to the state machine and notifies clients in RequestTable.
ArrayRingBuffer<T> - Class in org.jgroups.raft.util: It's a growable ring buffer that allows to move tail/head sequences, clear, append, set/replace at specific positions.
ArrayRingBuffer() - Constructor for class org.jgroups.raft.util.ArrayRingBuffer
ArrayRingBuffer(int, long) - Constructor for class org.jgroups.raft.util.ArrayRingBuffer
ArrayRingBuffer(long) - Constructor for class org.jgroups.raft.util.ArrayRingBuffer
assertInvariant() - Method in class org.jgroups.raft.util.CommitTable.Entry
assertNoBlockedMessages() - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor: Helper to assert there is no more blocked messages.
assertNumberOfBlockedMessages(int) - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor: Helper to assert an expected number of blocked messages.
async - Variable in class org.jgroups.raft.testfwk.MockRaftCluster
async() - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
async() - Method in interface org.jgroups.raft.blocks.RaftAsyncCounter
async() - Method in interface org.jgroups.raft.blocks.RaftCounter
async() - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Check whether the cluster is in asynchronous mode.
async(boolean) - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Update the cluster mode between synchronous and asynchronous.
asyncAddAndGet(AsciiString, long, Options) - Method in class org.jgroups.raft.blocks.CounterService
asyncCompareAndSwap(AsciiString, long, long, Options) - Method in class org.jgroups.raft.blocks.CounterService
asyncCounter(String) - Method in class org.jgroups.raft.blocks.CounterService: Returns an RaftAsyncCounter instance of the counter.
AsyncCounterImpl - Class in org.jgroups.raft.blocks: RAFT Implementation of AsyncCounter.
AsyncCounterImpl(CounterService, String) - Constructor for class org.jgroups.raft.blocks.AsyncCounterImpl
asyncGet(AsciiString) - Method in class org.jgroups.raft.blocks.CounterService
asyncSet(AsciiString, long) - Method in class org.jgroups.raft.blocks.CounterService
asyncUpdate(AsciiString, CounterFunction<T>, Options) - Method in class org.jgroups.raft.blocks.CounterService
availableCapacityWithoutResizing() - Method in class org.jgroups.raft.util.ArrayRingBuffer
avg_append_entries_batch_size - Variable in class org.jgroups.protocols.raft.RAFT

B

BaseElection - Class in org.jgroups.protocols.raft.election: Abstract leader election algorithm functionalities.
BaseElection() - Constructor for class org.jgroups.protocols.raft.election.BaseElection
bind_addr - Variable in class org.jgroups.protocols.raft.CLIENT
BlockingMessageInterceptor - Class in org.jgroups.raft.testfwk: Blocks while handling a message.
BlockingMessageInterceptor(Predicate<Message>) - Constructor for class org.jgroups.raft.testfwk.BlockingMessageInterceptor
blockMessage(Message) - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor: Blocks the invoking thread while sending the given message.
blockMessage(Message, boolean, Runnable) - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor: Blocks or delay the sending of the given message.
BUF - Static variable in class org.jgroups.protocols.raft.CLIENT
build() - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository.Builder
builder(Supplier<Integer>) - Static method in class org.jgroups.raft.util.ReadOnlyRequestRepository

C

cache - Variable in class org.jgroups.raft.util.LogCache
cacheSize() - Method in class org.jgroups.raft.util.LogCache
ch - Variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
ch - Variable in class org.jgroups.raft.demos.CounterServiceDemo
ch - Static variable in class org.jgroups.raft.demos.ProgrammaticRSM
ch - Variable in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
ch - Variable in class org.jgroups.raft.RaftHandle
changeMembers(String, InternalCommand.Type) - Method in class org.jgroups.protocols.raft.RAFT
changeRole(Role) - Method in class org.jgroups.protocols.raft.RAFT
changeServer(String, boolean) - Method in class org.jgroups.protocols.raft.REDIRECT
channel() - Method in class org.jgroups.raft.blocks.CounterService
channel() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
channel() - Method in class org.jgroups.raft.RaftHandle
class_loader - Variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
classLoaderInUse(ClassLoader) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
clear() - Method in class org.jgroups.protocols.raft.LogEntries
clear() - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Remove all members from the cluster.
clear() - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
clear() - Method in class org.jgroups.raft.testfwk.RaftCluster
clear() - Method in class org.jgroups.raft.util.ArrayRingBuffer
clear() - Method in class org.jgroups.raft.util.LogCache
clearDroppedTraffic() - Method in class org.jgroups.raft.testfwk.RaftCluster
clearDroppedTrafficTo(Address) - Method in class org.jgroups.raft.testfwk.RaftCluster
clearLogCache() - Method in class org.jgroups.protocols.raft.RAFT
client - Variable in class org.jgroups.raft.client.ReplicatedStateMachineClient
Client - Class in org.jgroups.raft.client: Client which accesses the CLIENT protocol through a socket.
Client() - Constructor for class org.jgroups.raft.client.Client
CLIENT - Class in org.jgroups.protocols.raft: Protocol listening on a socket for client requests.
CLIENT() - Constructor for class org.jgroups.protocols.raft.CLIENT
client_future - Variable in class org.jgroups.raft.util.RequestTable.Entry
CLIENT_ID - Static variable in class org.jgroups.protocols.raft.CLIENT
client_sock - Variable in class org.jgroups.protocols.raft.CLIENT.RequestHandler
CLIENT.RequestHandler - Class in org.jgroups.protocols.raft
CLIENT.RequestHandler.CompletionHandler - Class in org.jgroups.protocols.raft
CLIENT.RequestType - Enum in org.jgroups.protocols.raft
ClientStub - Class in org.jgroups.raft.client: Client stub which accesses a remote server via the CLIENT protocol through a socket.
ClientStub(InetAddress, int) - Constructor for class org.jgroups.raft.client.ClientStub
close() - Method in class org.jgroups.protocols.raft.FileBasedLog
close() - Method in class org.jgroups.protocols.raft.InMemoryLog
close() - Method in class org.jgroups.raft.client.ClientStub
close() - Method in class org.jgroups.raft.filelog.FileStorage
close() - Method in class org.jgroups.raft.filelog.LogEntryStorage
close() - Method in class org.jgroups.raft.filelog.MetadataStorage
close() - Method in class org.jgroups.raft.testfwk.RaftNode
close() - Method in class org.jgroups.raft.util.LogCache
cluster - Variable in class org.jgroups.raft.testfwk.RaftNode
command - Variable in class org.jgroups.protocols.raft.LogEntry
command() - Method in class org.jgroups.protocols.raft.LogEntry
commit() - Method in class org.jgroups.raft.util.RequestTable.Entry
commit(long) - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository: Register an accept from a follower to the given index.
commit_index - Variable in class org.jgroups.protocols.raft.AppendResult: The commit_index of the follower
commit_index - Variable in class org.jgroups.protocols.raft.RAFT
commit_index - Variable in class org.jgroups.raft.util.CommitTable.Entry
commit_index - Variable in class org.jgroups.raft.util.LogCache
commit_table - Variable in class org.jgroups.protocols.raft.RAFT
commitIndex() - Method in class org.jgroups.protocols.raft.AppendResult
commitIndex() - Method in class org.jgroups.protocols.raft.FileBasedLog
commitIndex() - Method in class org.jgroups.protocols.raft.InMemoryLog
commitIndex() - Method in interface org.jgroups.protocols.raft.Log: Returns the current commit index.
commitIndex() - Method in class org.jgroups.protocols.raft.RAFT
commitIndex() - Method in class org.jgroups.raft.blocks.CounterService
commitIndex() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
commitIndex() - Method in class org.jgroups.raft.RaftHandle
commitIndex() - Method in class org.jgroups.raft.util.CommitTable.Entry
commitIndex() - Method in class org.jgroups.raft.util.LogCache
commitIndex(long) - Method in class org.jgroups.protocols.raft.AppendResult
commitIndex(long) - Method in class org.jgroups.protocols.raft.FileBasedLog
commitIndex(long) - Method in class org.jgroups.protocols.raft.InMemoryLog
commitIndex(long) - Method in interface org.jgroups.protocols.raft.Log: Sets commitIndex to a new value
commitIndex(long) - Method in class org.jgroups.raft.util.CommitTable.Entry
commitIndex(long) - Method in class org.jgroups.raft.util.LogCache
commitLogTo(long, boolean) - Method in class org.jgroups.protocols.raft.RAFT: Tries to move commit_index up to index_inclusive, apply the entries in [commit_index+1 .. index_inclusive] to the state machine and notify the clients for each entry.
commitTable() - Method in class org.jgroups.protocols.raft.RAFT
CommitTable - Class in org.jgroups.raft.util: Keeps track of next_index and match_index for each cluster member (excluding this leader).
CommitTable(List<Address>, long) - Constructor for class org.jgroups.raft.util.CommitTable
CommitTable.Entry - Class in org.jgroups.raft.util
committed - Variable in class org.jgroups.raft.util.RequestTable.Entry
compareAndSwap - Enum constant in enum org.jgroups.raft.blocks.CounterService.Command
compareAndSwap(long, long) - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
CompletionHandler(Socket, DataInputStream, DataOutputStream, int) - Constructor for class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
computeMajority() - Method in class org.jgroups.protocols.raft.RAFT
computeMajority(View, View, int, Address) - Static method in class org.jgroups.raft.util.Utils
computeMajority(View, View, RAFT) - Static method in class org.jgroups.raft.util.Utils
connectionClosed(Connection) - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
connectionEstablished(Connection) - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
contains(long) - Method in class org.jgroups.raft.util.ArrayRingBuffer
contains(View, ExtendedUUID) - Static method in class org.jgroups.protocols.raft.NO_DUPES
convertUnsupportedToAsciidocTable(Properties, List<Class<?>>, String) - Static method in class org.jgroups.raft.util.PropsToAsciidoc
copy(Reader, Writer) - Static method in class org.jgroups.raft.util.PropsToAsciidoc
corr_id - Variable in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
corr_id - Variable in class org.jgroups.protocols.raft.REDIRECT.ResponseHandler
counter - Variable in class org.jgroups.raft.util.CounterStateMachine
counter() - Method in class org.jgroups.raft.util.CounterStateMachine
counter_service - Variable in class org.jgroups.raft.demos.CounterServiceDemo
counters - Variable in class org.jgroups.raft.blocks.CounterService
CounterService - Class in org.jgroups.raft.blocks: Provides a consensus based distributed counter (similar to AtomicLong) which can be atomically updated across a cluster.
CounterService(JChannel) - Constructor for class org.jgroups.raft.blocks.CounterService
CounterService.Command - Enum in org.jgroups.raft.blocks
CounterServiceDemo - Class in org.jgroups.raft.demos: Demo of CounterService.
CounterServiceDemo() - Constructor for class org.jgroups.raft.demos.CounterServiceDemo
CounterStateMachine - Class in org.jgroups.raft.util: Sample state machine accepting additions and subtractions
CounterStateMachine() - Constructor for class org.jgroups.raft.util.CounterStateMachine
create - Enum constant in enum org.jgroups.raft.blocks.CounterService.Command
create() - Method in class org.jgroups.protocols.raft.AppendEntriesRequest
create() - Method in class org.jgroups.protocols.raft.AppendEntriesResponse
create() - Method in class org.jgroups.protocols.raft.election.LeaderElected
create() - Method in class org.jgroups.protocols.raft.election.PreVoteRequest
create() - Method in class org.jgroups.protocols.raft.election.PreVoteResponse
create() - Method in class org.jgroups.protocols.raft.election.VoteRequest
create() - Method in class org.jgroups.protocols.raft.election.VoteResponse
create() - Method in class org.jgroups.protocols.raft.InstallSnapshotRequest
create() - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
create(boolean) - Static method in class org.jgroups.raft.demos.ProgrammaticRSM
create(boolean) - Static method in class org.jgroups.raft.Options
create(long, T, CompletableFuture<byte[]>, Supplier<Integer>) - Method in class org.jgroups.raft.util.RequestTable
create(long, T, CompletableFuture<byte[]>, Supplier<Integer>, Options) - Method in class org.jgroups.raft.util.RequestTable
create(LogEntry...) - Static method in class org.jgroups.protocols.raft.LogEntries
createAsciidocTable(List<String[]>, String, String) - Static method in class org.jgroups.raft.util.PropsToAsciidoc: Creates an AsciiDoc table of the elements in rows.
createCommitTable() - Method in class org.jgroups.protocols.raft.RAFT
createDeleteCopyFrom(long) - Method in class org.jgroups.raft.filelog.FilePositionCache
createLog() - Method in class org.jgroups.raft.util.AnalyzeLog
createLogName(String, String) - Method in class org.jgroups.protocols.raft.RAFT
createNewTerm() - Method in class org.jgroups.protocols.raft.RAFT
createRequestTable() - Method in class org.jgroups.protocols.raft.RAFT: Populate with non-committed entries (from log) (https://github.com/belaban/jgroups-raft/issues/31)
createThreadPool(long) - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Create the Executor to submit tasks during asynchronous mode.
curr_log_size - Variable in class org.jgroups.protocols.raft.RAFT
curr_term - Variable in class org.jgroups.protocols.raft.RaftHeader
current_request_id - Variable in class org.jgroups.raft.client.ClientStub
current_term - Variable in class org.jgroups.raft.util.LogCache
currentLogSize() - Method in class org.jgroups.protocols.raft.RAFT
currentTerm() - Method in class org.jgroups.protocols.raft.FileBasedLog
currentTerm() - Method in class org.jgroups.protocols.raft.InMemoryLog
currentTerm() - Method in interface org.jgroups.protocols.raft.Log: Returns the current term
currentTerm() - Method in class org.jgroups.protocols.raft.RAFT
currentTerm() - Method in class org.jgroups.protocols.raft.state.RaftState
currentTerm() - Method in class org.jgroups.raft.RaftHandle
currentTerm() - Method in class org.jgroups.raft.util.LogCache
currentTerm(long) - Method in class org.jgroups.protocols.raft.FileBasedLog
currentTerm(long) - Method in class org.jgroups.protocols.raft.InMemoryLog
currentTerm(long) - Method in interface org.jgroups.protocols.raft.Log: Sets the current term
currentTerm(long) - Method in class org.jgroups.protocols.raft.RAFT: Sets current_term if new_term is bigger
currentTerm(long) - Method in class org.jgroups.raft.util.LogCache
currTerm() - Method in class org.jgroups.protocols.raft.RaftHeader
currTerm(long) - Method in class org.jgroups.protocols.raft.RaftHeader

D

DEFAULT_OPTIONS - Static variable in class org.jgroups.raft.Options
delete - Enum constant in enum org.jgroups.raft.blocks.CounterService.Command
delete() - Method in class org.jgroups.protocols.raft.FileBasedLog
delete() - Method in class org.jgroups.protocols.raft.InMemoryLog
delete() - Method in interface org.jgroups.protocols.raft.Log: Remove the persistent store, e.g.
delete() - Method in class org.jgroups.raft.filelog.FileStorage
delete() - Method in class org.jgroups.raft.filelog.LogEntryStorage
delete() - Method in class org.jgroups.raft.filelog.MetadataStorage
delete() - Method in class org.jgroups.raft.util.LogCache
deleteAllEntriesStartingFrom(long) - Method in class org.jgroups.protocols.raft.FileBasedLog
deleteAllEntriesStartingFrom(long) - Method in class org.jgroups.protocols.raft.InMemoryLog
deleteAllEntriesStartingFrom(long) - Method in interface org.jgroups.protocols.raft.Log: Delete all entries starting from start_index (including the entry at start_index).
deleteAllEntriesStartingFrom(long) - Method in class org.jgroups.raft.util.LogCache
deleteAllLogEntriesStartingFrom(long) - Method in class org.jgroups.protocols.raft.RAFT
deleteCounter(String) - Method in class org.jgroups.raft.blocks.CounterService: Deletes a counter instance (on the coordinator)
deleteCounterAsync(String) - Method in class org.jgroups.raft.blocks.CounterService: Deletes a counter instance.
deleteLog(RAFT) - Static method in class org.jgroups.raft.util.Utils: Deprecated, for removal: This API element is subject to removal in a future version.
Use RaftTestUtils.deleteRaftLog(RAFT) instead.
deleteRaftLog(RAFT) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils: Deletes all the replicated data and internal state for the given RAFT instance.
deliverAsync(RaftNode, Message) - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Asynchronously sends a message up the node stack.
dest - Variable in class org.jgroups.protocols.raft.REDIRECT.ResponseHandler
destroy() - Method in class org.jgroups.protocols.raft.CLIENT
destroy() - Method in class org.jgroups.protocols.raft.Leader
destroy() - Method in class org.jgroups.protocols.raft.RaftImpl: Called before getting destroyed (on a role change)
destroy() - Method in class org.jgroups.raft.testfwk.RaftNode
destroy() - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository: Invokes the registered destroyer with all pending requests.
destroy(Throwable) - Method in class org.jgroups.raft.util.RequestTable: Completes all uncommitted requests with the provided exception.
determineLeader() - Method in class org.jgroups.protocols.raft.election.BaseElection
disableLogCache() - Method in class org.jgroups.protocols.raft.RAFT
down(Event) - Method in class org.jgroups.protocols.raft.election.BaseElection
down(Event) - Method in class org.jgroups.protocols.raft.NO_DUPES
down(Event) - Method in class org.jgroups.protocols.raft.RAFT
down(Event) - Method in class org.jgroups.raft.testfwk.RaftNode
down(Message) - Method in class org.jgroups.raft.testfwk.RaftNode
DownRequest(CompletableFuture<byte[]>, byte[], int, int, boolean, Options, boolean) - Constructor for class org.jgroups.protocols.raft.RAFT.DownRequest
drainRatio() - Method in class org.jgroups.protocols.raft.RAFT
dropHeadUntil(long) - Method in class org.jgroups.raft.util.ArrayRingBuffer: Remove all elements from headSequence to indexExclusive.
At the end of this operation headSequence is equals to indexExclusive.
dropped_members - Variable in class org.jgroups.raft.testfwk.RaftCluster
dropTailTo(long) - Method in class org.jgroups.raft.util.ArrayRingBuffer: Remove all elements from tailSequence back to indexInclusive.
At the end of this operation tailSequence is equals to indexInclusive.
dropTailToHead() - Method in class org.jgroups.raft.util.ArrayRingBuffer
dropTraffic() - Method in class org.jgroups.raft.testfwk.RaftCluster
dropTrafficTo(Address) - Method in class org.jgroups.raft.testfwk.RaftCluster
DUMP_CMD - Static variable in class org.jgroups.raft.client.ReplicatedStateMachineClient
DUMP_LOG - Enum constant in enum org.jgroups.raft.demos.ReplicatedStateMachineDemo.Command
dumpCommitTable() - Method in class org.jgroups.protocols.raft.RAFT
dumpLog() - Method in class org.jgroups.protocols.raft.RAFT
dumpLog() - Method in class org.jgroups.raft.blocks.CounterService
dumpLog() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
dumpLog() - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
dumpLog() - Method in class org.jgroups.raft.demos.CounterServiceDemo
dumpLog() - Static method in class org.jgroups.raft.demos.ProgrammaticRSM
dumpLog() - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
dumpLog(long) - Method in class org.jgroups.protocols.raft.RAFT
dumpLogEntry(LogEntry) - Static method in class org.jgroups.raft.blocks.CounterService
duplicatesInView(View) - Method in class org.jgroups.protocols.raft.RAFT: Checks if a given view contains duplicate raft-ids.
dyn_membership - Variable in class org.jgroups.protocols.raft.CLIENT
dynamic_view_changes - Variable in class org.jgroups.protocols.raft.RAFT
DynamicMembership - Interface in org.jgroups.protocols.raft: Defines the contract to add and remove servers (RAFT.members).

E

election - Variable in class org.jgroups.raft.testfwk.RaftNode
election() - Method in class org.jgroups.raft.testfwk.RaftNode
election(JChannel) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils: Retrieves the BaseElection protocol from the provided JChannel.
ELECTION - Class in org.jgroups.protocols.raft: The default leader election algorithm.
ELECTION() - Constructor for class org.jgroups.protocols.raft.ELECTION
ELECTION_ID - Static variable in class org.jgroups.protocols.raft.ELECTION
ELECTION_ID - Static variable in class org.jgroups.protocols.raft.ELECTION2
ELECTION2 - Class in org.jgroups.protocols.raft: A leader election protocol.
ELECTION2() - Constructor for class org.jgroups.protocols.raft.ELECTION2
EMPTY - Static variable in class org.jgroups.raft.filelog.FilePositionCache
enableLogCache() - Method in class org.jgroups.protocols.raft.RAFT
entries - Variable in class org.jgroups.protocols.raft.LogEntries
Entry(long) - Constructor for class org.jgroups.raft.util.CommitTable.Entry
Entry(CompletableFuture<byte[]>, Options) - Constructor for class org.jgroups.raft.util.RequestTable.Entry
entry_term - Variable in class org.jgroups.protocols.raft.AppendEntriesRequest
equals(Object) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
equals(Object) - Method in class org.jgroups.raft.Options
eventLoop() - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
eventually(BooleanSupplier, long, TimeUnit) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils: Verify that in the given time constraints, the expression returns true.
eventuallyIsRaftLeader(JChannel, long) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils: Checks that given the time constraints, eventually RaftTestUtils.isRaftLeader(JChannel) is true.
exception - Variable in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
execute(RAFT) - Method in class org.jgroups.protocols.raft.InternalCommand
executeInternalCommand(InternalCommand, byte[], int, int) - Method in class org.jgroups.protocols.raft.RAFT: If cmd is not null, execute it.
extractRaftId(Address) - Static method in class org.jgroups.raft.util.Utils

F

FAIL_CONFLICTING_PREV_TERM - Enum constant in enum org.jgroups.protocols.raft.AppendResult.Result
FAIL_ENTRY_NOT_FOUND - Enum constant in enum org.jgroups.protocols.raft.AppendResult.Result
failed(Throwable) - Method in class org.jgroups.protocols.raft.RAFT.DownRequest
failed(Throwable) - Method in class org.jgroups.protocols.raft.RAFT.Request
failed(Throwable) - Method in class org.jgroups.protocols.raft.RAFT.SnapshotRequest
FileBasedLog - Class in org.jgroups.protocols.raft: A Log implementation stored in a file.
FileBasedLog() - Constructor for class org.jgroups.protocols.raft.FileBasedLog
FilePositionCache - Class in org.jgroups.raft.filelog: A mapping between the RAFT log index and where the log entry is stored in a file.
FilePositionCache(long) - Constructor for class org.jgroups.raft.filelog.FilePositionCache
FilePositionCache(long, int) - Constructor for class org.jgroups.raft.filelog.FilePositionCache
FileProvider - Class in org.jgroups.raft.util.pmem: Creates FileChannel.
FileProvider() - Constructor for class org.jgroups.raft.util.pmem.FileProvider
FileStorage - Class in org.jgroups.raft.filelog: Base class to store data in a file.
FileStorage(File) - Constructor for class org.jgroups.raft.filelog.FileStorage
FileStorage(File, int) - Constructor for class org.jgroups.raft.filelog.FileStorage
find(Class<T>) - Method in class org.jgroups.raft.testfwk.RaftNode
findProtocol(Class<T>, Protocol, boolean) - Static method in class org.jgroups.protocols.raft.RAFT
first_appended - Variable in class org.jgroups.raft.util.LogCache
firstAppended() - Method in class org.jgroups.protocols.raft.FileBasedLog
firstAppended() - Method in class org.jgroups.protocols.raft.InMemoryLog
firstAppended() - Method in interface org.jgroups.protocols.raft.Log: Returns the index of the first log entry
firstAppended() - Method in class org.jgroups.raft.util.LogCache
firstApplied() - Method in class org.jgroups.raft.demos.CounterServiceDemo
firstApplied() - Static method in class org.jgroups.raft.demos.ProgrammaticRSM
firstApplied() - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
flush() - Method in class org.jgroups.raft.filelog.FileStorage
flushCommitTable() - Method in class org.jgroups.protocols.raft.RAFT
flushCommitTable(Address) - Method in class org.jgroups.protocols.raft.RAFT: Triggers a flush of the entries to the given member.
Follower - Class in org.jgroups.protocols.raft: Implements the behavior of a RAFT follower
Follower - Enum constant in enum org.jgroups.protocols.raft.Role
Follower(RAFT) - Constructor for class org.jgroups.protocols.raft.Follower
forEach(BiConsumer<Address, CommitTable.Entry>) - Method in class org.jgroups.raft.util.CommitTable: Applies a function to all elements of the commit table
forEach(ObjLongConsumer<? super T>) - Method in class org.jgroups.raft.util.ArrayRingBuffer
forEach(ObjLongConsumer<LogEntry>) - Method in class org.jgroups.protocols.raft.FileBasedLog
forEach(ObjLongConsumer<LogEntry>) - Method in class org.jgroups.protocols.raft.InMemoryLog
forEach(ObjLongConsumer<LogEntry>) - Method in interface org.jgroups.protocols.raft.Log: Applies a function to all elements in range [first_appended .. last_appended]
forEach(ObjLongConsumer<LogEntry>) - Method in class org.jgroups.raft.util.LogCache
forEach(ObjLongConsumer<LogEntry>, long, long) - Method in class org.jgroups.protocols.raft.FileBasedLog
forEach(ObjLongConsumer<LogEntry>, long, long) - Method in class org.jgroups.protocols.raft.InMemoryLog
forEach(ObjLongConsumer<LogEntry>, long, long) - Method in interface org.jgroups.protocols.raft.Log: Applies function to all elements of the log in range [max(start_index,first_appended) .. min(last_appended,end_index)].
forEach(ObjLongConsumer<LogEntry>, long, long) - Method in class org.jgroups.raft.filelog.LogEntryStorage
forEach(ObjLongConsumer<LogEntry>, long, long) - Method in class org.jgroups.raft.util.LogCache
fromByteArrayToLong(byte[]) - Static method in class org.jgroups.raft.util.LongHelper
fromLongToByteArray(long) - Static method in class org.jgroups.raft.util.LongHelper

G

get - Enum constant in enum org.jgroups.raft.blocks.CounterService.Command
get() - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
get(byte[], int, int, long, TimeUnit) - Method in interface org.jgroups.raft.Settable: Synchronous get operation bounded by a timeout.
get(long) - Method in class org.jgroups.protocols.raft.FileBasedLog
get(long) - Method in class org.jgroups.protocols.raft.InMemoryLog
get(long) - Method in interface org.jgroups.protocols.raft.Log: Gets the entry at start_index.
get(long) - Method in class org.jgroups.raft.util.ArrayRingBuffer
get(long) - Method in class org.jgroups.raft.util.LogCache
get(String) - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
get(String) - Static method in class org.jgroups.raft.demos.ProgrammaticRSM
get(String) - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
get(K) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine: Returns the value for a given key.
get(K, V) - Method in interface org.jgroups.raft.blocks.ReplicatedStateMachine.Notification
get(Address) - Method in class org.jgroups.raft.util.CommitTable
GET - Enum constant in enum org.jgroups.raft.demos.ReplicatedStateMachineDemo.Command
GET - Static variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
get_req - Enum constant in enum org.jgroups.protocols.raft.CLIENT.RequestType
GET_VIEW - Enum constant in enum org.jgroups.raft.demos.ReplicatedStateMachineDemo.Command
GET_VIEW_CMD - Static variable in class org.jgroups.raft.client.ReplicatedStateMachineClient
getAddress() - Method in class org.jgroups.raft.testfwk.RaftNode
getAsync(byte[], int, int) - Method in interface org.jgroups.raft.Settable
getAsync(byte[], int, int, Options) - Method in class org.jgroups.protocols.raft.RAFT
getAsync(byte[], int, int, Options) - Method in class org.jgroups.protocols.raft.REDIRECT
getAsync(byte[], int, int, Options) - Method in class org.jgroups.raft.client.ClientStub
getAsync(byte[], int, int, Options) - Method in class org.jgroups.raft.RaftHandle
getAsync(byte[], int, int, Options) - Method in interface org.jgroups.raft.Settable: Asynchronous get operation that returns immediately without blocking.
getAsync(byte[], int, int, Options) - Method in class org.jgroups.raft.testfwk.RaftNode
getBindAddress() - Method in class org.jgroups.protocols.raft.CLIENT
getCachedFileSize() - Method in class org.jgroups.raft.filelog.FileStorage
getCachedFileSize() - Method in class org.jgroups.raft.filelog.LogEntryStorage
getCommitIndex() - Method in class org.jgroups.raft.filelog.MetadataStorage
getCurrentTerm() - Method in class org.jgroups.raft.filelog.MetadataStorage
getDescriptions(Class<?>, Map<String, String>, String, boolean) - Static method in class org.jgroups.raft.util.PropsToAsciidoc
getFirstAppended() - Method in class org.jgroups.raft.filelog.FilePositionCache
getFirstAppended() - Method in class org.jgroups.raft.filelog.LogEntryStorage
getFirstIndexOfConflictingTerm(long, long) - Method in class org.jgroups.protocols.raft.RaftImpl: Finds the first index at which conflicting_term starts, going back from start_index towards the head of the log, not not going lower than commit-index
getFirstLogIndex() - Method in class org.jgroups.raft.filelog.FilePositionCache
getHeadSequence() - Method in class org.jgroups.raft.util.ArrayRingBuffer
getHost() - Method in class org.jgroups.raft.client.ClientStub
getIdleTime() - Method in class org.jgroups.protocols.raft.CLIENT
getLastAppended() - Method in class org.jgroups.raft.filelog.LogEntryStorage
getLocal() - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
getLocal() - Method in interface org.jgroups.raft.blocks.RaftCounter: Gets the current local value of the counter; this is purely local and the value may be stale
getLogEntry(long) - Method in class org.jgroups.raft.filelog.LogEntryStorage
getMagicId() - Method in class org.jgroups.protocols.raft.AppendEntriesRequest
getMagicId() - Method in class org.jgroups.protocols.raft.AppendEntriesResponse
getMagicId() - Method in class org.jgroups.protocols.raft.election.LeaderElected
getMagicId() - Method in class org.jgroups.protocols.raft.election.PreVoteRequest
getMagicId() - Method in class org.jgroups.protocols.raft.election.PreVoteResponse
getMagicId() - Method in class org.jgroups.protocols.raft.election.VoteRequest
getMagicId() - Method in class org.jgroups.protocols.raft.election.VoteResponse
getMagicId() - Method in class org.jgroups.protocols.raft.InstallSnapshotRequest
getMagicId() - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
getMaxThreads() - Method in class org.jgroups.protocols.raft.CLIENT
getMembers() - Method in class org.jgroups.protocols.raft.PersistentState
getMethod(String, Class<?>) - Static method in class org.jgroups.raft.util.AnalyzeLog
getMinThreads() - Method in class org.jgroups.protocols.raft.CLIENT
getName() - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
getOrCreateAsyncCounter(String, long) - Method in class org.jgroups.raft.blocks.CounterService: Returns an existing counter, or creates a new one if none exists.
getOrCreateCounter(String, long) - Method in class org.jgroups.raft.blocks.CounterService: Returns an existing counter, or creates a new one if none exists.
getPort() - Method in class org.jgroups.protocols.raft.CLIENT
getPort() - Method in class org.jgroups.raft.client.ClientStub
getPosition(long) - Method in class org.jgroups.raft.filelog.FilePositionCache
getReceiveBufferSize() - Method in class org.jgroups.protocols.raft.CLIENT
getSnapshot() - Method in class org.jgroups.protocols.raft.FileBasedLog
getSnapshot() - Method in class org.jgroups.protocols.raft.InMemoryLog
getSnapshot() - Method in interface org.jgroups.protocols.raft.Log: Gets the snapshot from the log
getSnapshot() - Method in class org.jgroups.raft.util.LogCache
getStorageFile() - Method in class org.jgroups.raft.filelog.FileStorage
getTailSequence() - Method in class org.jgroups.raft.util.ArrayRingBuffer
getView() - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
getView() - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
getVotedFor() - Method in class org.jgroups.raft.filelog.MetadataStorage
getVotes() - Method in class org.jgroups.protocols.raft.election.BaseElection
gms_id - Static variable in class org.jgroups.protocols.raft.NO_DUPES

H

h - Static variable in class org.jgroups.raft.demos.ProgrammaticRSM
handleAppendEntriesRequest(LogEntries, Address, long, long, long, long) - Method in class org.jgroups.protocols.raft.RaftImpl: Called (on a follower) when an AppendEntries request is received
handleAppendEntriesResponse(Address, long, AppendResult) - Method in class org.jgroups.protocols.raft.Leader
handleAppendEntriesResponse(Address, long, AppendResult) - Method in class org.jgroups.protocols.raft.RaftImpl
handleDownRequest(CompletableFuture<byte[]>, byte[], int, int, boolean, Options, boolean) - Method in class org.jgroups.protocols.raft.RAFT: This method is always called by a single thread only, and does therefore not need to be reentrant
handleEvent(Message, REDIRECT.RedirectHeader) - Method in class org.jgroups.protocols.raft.REDIRECT
handleGmsHeader(GMS.GmsHeader, Address) - Method in class org.jgroups.protocols.raft.NO_DUPES
handleInstallSnapshotRequest(Message, Address, long, long) - Method in class org.jgroups.protocols.raft.Follower
handleInstallSnapshotRequest(Message, Address, long, long) - Method in class org.jgroups.protocols.raft.RaftImpl: Called when a snapshot sent by the leader is received by a follower.
handleMessage(Message, RaftHeader) - Method in class org.jgroups.protocols.raft.election.BaseElection
handleMessage(Message, RaftHeader) - Method in class org.jgroups.protocols.raft.ELECTION2
handleUpRequest(Message, RaftHeader) - Method in class org.jgroups.protocols.raft.RAFT
handleView(View) - Method in class org.jgroups.protocols.raft.election.BaseElection
handleView(View) - Method in class org.jgroups.protocols.raft.ELECTION
handleView(View) - Method in class org.jgroups.protocols.raft.ELECTION2
handleView(View) - Method in class org.jgroups.protocols.raft.RAFT
handleView(View) - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Emit the view update to all cluster members.
handleView(View) - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
handleView(View) - Method in class org.jgroups.raft.testfwk.RaftCluster
handleView(View) - Method in class org.jgroups.raft.testfwk.RaftNode
hashCode() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
hashCode() - Method in class org.jgroups.raft.Options
help() - Static method in class org.jgroups.raft.client.Client
hitRatio() - Method in class org.jgroups.raft.util.LogCache
host - Variable in class org.jgroups.raft.client.ClientStub

I

idle_time - Variable in class org.jgroups.protocols.raft.CLIENT
ignore_return_value - Variable in class org.jgroups.raft.Options
ignoreReturnValue() - Method in class org.jgroups.raft.Options
ignoreReturnValue(boolean) - Method in class org.jgroups.raft.Options
impl - Variable in class org.jgroups.protocols.raft.RAFT: The current role (follower, candidate or leader).
impl() - Method in class org.jgroups.protocols.raft.RAFT
in - Variable in class org.jgroups.raft.client.ClientStub
index - Variable in class org.jgroups.protocols.raft.AppendResult: The index of the last appended entry if success == true.
index() - Method in class org.jgroups.protocols.raft.AppendResult
init() - Method in class org.jgroups.protocols.raft.CLIENT
init() - Method in class org.jgroups.protocols.raft.election.BaseElection
init() - Method in class org.jgroups.protocols.raft.Leader
init() - Method in class org.jgroups.protocols.raft.RAFT
init() - Method in class org.jgroups.protocols.raft.RaftImpl: Called right after instantiation
init() - Method in class org.jgroups.protocols.raft.REDIRECT
init() - Method in class org.jgroups.raft.testfwk.RaftNode
init(String, Map<String, String>) - Method in class org.jgroups.protocols.raft.FileBasedLog
init(String, Map<String, String>) - Method in class org.jgroups.protocols.raft.InMemoryLog
init(String, Map<String, String>) - Method in class org.jgroups.protocols.raft.LevelDBLog: Deprecated.
init(String, Map<String, String>) - Method in interface org.jgroups.protocols.raft.Log: Called after the instance has been created
init(String, Map<String, String>) - Method in class org.jgroups.raft.util.LogCache
initStateMachineFromLog() - Method in class org.jgroups.protocols.raft.RAFT: Loads the log entries from [first .. commit_index] into the state machine
InMemoryLog - Class in org.jgroups.protocols.raft: An in-memory Log implementation without any persistence.
InMemoryLog() - Constructor for class org.jgroups.protocols.raft.InMemoryLog
input - Variable in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
INSTALL_SNAPSHOT_REQ - Static variable in class org.jgroups.protocols.raft.RAFT
InstallSnapshotRequest - Class in org.jgroups.protocols.raft
InstallSnapshotRequest() - Constructor for class org.jgroups.protocols.raft.InstallSnapshotRequest
InstallSnapshotRequest(long) - Constructor for class org.jgroups.protocols.raft.InstallSnapshotRequest
InstallSnapshotRequest(long, Address, long, long) - Constructor for class org.jgroups.protocols.raft.InstallSnapshotRequest
interceptor - Variable in class org.jgroups.raft.testfwk.MockRaftCluster
internal - Variable in class org.jgroups.protocols.raft.LogEntry
internal() - Method in class org.jgroups.protocols.raft.LogEntry
internal(boolean) - Method in class org.jgroups.protocols.raft.LogEntry
internal_state - Variable in class org.jgroups.protocols.raft.RAFT
InternalCommand - Class in org.jgroups.protocols.raft: Internal command to be added to the log, e.g. adding or removing a server
InternalCommand() - Constructor for class org.jgroups.protocols.raft.InternalCommand
InternalCommand(InternalCommand.Type, String) - Constructor for class org.jgroups.protocols.raft.InternalCommand
InternalCommand.Type - Enum in org.jgroups.protocols.raft
invalidateFrom(long) - Method in class org.jgroups.raft.filelog.FilePositionCache
invoke(byte, K, V, boolean, boolean) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
invoke(Method, Object) - Static method in class org.jgroups.raft.util.AnalyzeLog
invokeAsync(CounterService.Command, AsciiString, long) - Method in class org.jgroups.raft.blocks.CounterService
invokeAsyncAddAndGet(AsciiString, long, Options) - Method in class org.jgroups.raft.blocks.CounterService
invokeAsyncAndGet(CounterService.Command, AsciiString, Options) - Method in class org.jgroups.raft.blocks.CounterService
ioBufferWith(int) - Method in class org.jgroups.raft.filelog.FileStorage
isCommitted(long) - Method in class org.jgroups.raft.util.RequestTable: Whether or not the entry at index is committed
isEmpty() - Method in class org.jgroups.raft.util.ArrayRingBuffer
isLeader() - Method in class org.jgroups.protocols.raft.RAFT
isLeader() - Method in class org.jgroups.raft.RaftHandle
isMajorityAvailable() - Method in class org.jgroups.protocols.raft.election.BaseElection
isMajorityLost(Collection<String>, Collection<String>, int) - Static method in class org.jgroups.raft.util.Utils
isMajorityReached(Collection<String>, Collection<String>, int) - Static method in class org.jgroups.raft.util.Utils
isOpened() - Method in class org.jgroups.raft.filelog.FileStorage
isPMEMAvailable() - Static method in class org.jgroups.raft.util.pmem.FileProvider
isPreVoteThreadRunning() - Method in class org.jgroups.protocols.raft.ELECTION2
isRaftLeader(JChannel) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils: Checks if the node is the current RAFT leader.
isRaftMember(String, Collection<String>) - Static method in class org.jgroups.raft.util.Utils: Verifies if the given raft ID belongs to the list of members.
isReadOnly() - Method in class org.jgroups.protocols.raft.RAFT.DownRequest
isReadOnly() - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
isViewCoordinator() - Method in class org.jgroups.protocols.raft.election.BaseElection
isVotingThreadRunning() - Method in class org.jgroups.protocols.raft.election.BaseElection
iterator() - Method in class org.jgroups.protocols.raft.LogEntries

K

keys() - Method in class org.jgroups.raft.util.CommitTable

L

last_appended - Variable in class org.jgroups.protocols.raft.RAFT
last_appended - Variable in class org.jgroups.raft.util.LogCache
last_included_index - Variable in class org.jgroups.protocols.raft.InstallSnapshotRequest
last_included_term - Variable in class org.jgroups.protocols.raft.InstallSnapshotRequest
last_log_index - Variable in class org.jgroups.protocols.raft.election.VoteResponse
last_log_term - Variable in class org.jgroups.protocols.raft.election.VoteResponse
lastAppended() - Method in class org.jgroups.protocols.raft.FileBasedLog
lastAppended() - Method in class org.jgroups.protocols.raft.InMemoryLog
lastAppended() - Method in interface org.jgroups.protocols.raft.Log: Returns the index of the last append entry
This value is set by Log.append(long,LogEntries)
lastAppended() - Method in class org.jgroups.protocols.raft.RAFT
lastAppended() - Method in class org.jgroups.raft.util.LogCache
lastApplied() - Method in class org.jgroups.raft.blocks.CounterService
lastApplied() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
lastApplied() - Method in class org.jgroups.raft.RaftHandle
leader - Variable in class org.jgroups.protocols.raft.AppendEntriesRequest
leader - Variable in class org.jgroups.protocols.raft.election.LeaderElected
leader - Variable in class org.jgroups.protocols.raft.election.PreVoteResponse
leader - Variable in class org.jgroups.protocols.raft.InstallSnapshotRequest
leader() - Method in class org.jgroups.protocols.raft.election.LeaderElected
leader() - Method in class org.jgroups.protocols.raft.election.PreVoteResponse
leader() - Method in class org.jgroups.protocols.raft.RAFT
leader() - Method in class org.jgroups.protocols.raft.state.RaftState
leader() - Method in class org.jgroups.raft.RaftHandle
leader(String) - Method in class org.jgroups.protocols.raft.REDIRECT
leader(Address) - Method in class org.jgroups.protocols.raft.RAFT
Leader - Class in org.jgroups.protocols.raft: Implements the behavior of a RAFT leader
Leader - Enum constant in enum org.jgroups.protocols.raft.Role
Leader(RAFT) - Constructor for class org.jgroups.protocols.raft.Leader
leader_commit - Variable in class org.jgroups.protocols.raft.AppendEntriesRequest
leader_lost - Enum constant in enum org.jgroups.raft.util.Utils.Majority
LeaderElected - Class in org.jgroups.protocols.raft.election: Sent by the freshly elected leader to all members (-self)
LeaderElected() - Constructor for class org.jgroups.protocols.raft.election.LeaderElected
LeaderElected(Address) - Constructor for class org.jgroups.protocols.raft.election.LeaderElected
Learner - Class in org.jgroups.protocols.raft: Implements the behavior of a learner node.
Learner - Enum constant in enum org.jgroups.protocols.raft.Role
Learner(RAFT) - Constructor for class org.jgroups.protocols.raft.Learner
length - Variable in class org.jgroups.protocols.raft.LogEntry
length() - Method in class org.jgroups.protocols.raft.LogEntry
LevelDBLog - Class in org.jgroups.protocols.raft: Deprecated, for removal: This API element is subject to removal in a future version.
Delegates to FileBasedLog.
LevelDBLog() - Constructor for class org.jgroups.protocols.raft.LevelDBLog: Deprecated.
listeners - Variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
localAddress() - Method in class org.jgroups.raft.testfwk.RaftNode
log - Variable in class org.jgroups.raft.client.ClientStub
log - Variable in class org.jgroups.raft.util.LogCache
log() - Method in class org.jgroups.protocols.raft.RAFT
log() - Method in class org.jgroups.raft.RaftHandle
log() - Method in class org.jgroups.raft.util.LogCache
log(Log) - Method in class org.jgroups.protocols.raft.RAFT
Log - Interface in org.jgroups.protocols.raft: The interface for a persistent log.
LOG - Variable in class org.jgroups.protocols.raft.LevelDBLog: Deprecated.
log_args - Variable in class org.jgroups.protocols.raft.RAFT
log_class - Variable in class org.jgroups.protocols.raft.RAFT
log_class - Variable in class org.jgroups.raft.util.AnalyzeLog
log_dir - Variable in class org.jgroups.protocols.raft.RAFT
LOG_ENTRIES - Static variable in class org.jgroups.protocols.raft.RAFT
log_impl - Variable in class org.jgroups.protocols.raft.RAFT
log_name - Variable in class org.jgroups.protocols.raft.RAFT
log_prefix - Variable in class org.jgroups.protocols.raft.RAFT
logArgs() - Method in class org.jgroups.protocols.raft.RAFT
logArgs(String) - Method in class org.jgroups.protocols.raft.RAFT
LogCache - Class in org.jgroups.raft.util: Bounded caching Log facade.
LogCache(Log) - Constructor for class org.jgroups.raft.util.LogCache
LogCache(Log, int) - Constructor for class org.jgroups.raft.util.LogCache
logCacheHitRatio() - Method in class org.jgroups.protocols.raft.RAFT
LogCacheNumAccesses() - Method in class org.jgroups.protocols.raft.RAFT
logCacheNumTrims() - Method in class org.jgroups.protocols.raft.RAFT
logClass() - Method in class org.jgroups.protocols.raft.RAFT
logClass(String) - Method in class org.jgroups.protocols.raft.RAFT
logClass(String) - Method in class org.jgroups.raft.util.AnalyzeLog
logDescription() - Method in class org.jgroups.protocols.raft.RAFT
logDir(String) - Method in class org.jgroups.protocols.raft.RAFT
logEntries(ObjLongConsumer<LogEntry>) - Method in class org.jgroups.protocols.raft.RAFT
logEntries(ObjLongConsumer<LogEntry>) - Method in class org.jgroups.raft.RaftHandle
LogEntries - Class in org.jgroups.protocols.raft: List of LogEntry elements, provides efficient serialization.
LogEntries() - Constructor for class org.jgroups.protocols.raft.LogEntries
LogEntry - Class in org.jgroups.protocols.raft: An element in a log.
LogEntry() - Constructor for class org.jgroups.protocols.raft.LogEntry
LogEntry(long, byte[]) - Constructor for class org.jgroups.protocols.raft.LogEntry
LogEntry(long, byte[], int, int) - Constructor for class org.jgroups.protocols.raft.LogEntry
LogEntry(long, byte[], int, int, boolean) - Constructor for class org.jgroups.protocols.raft.LogEntry
LogEntryStorage - Class in org.jgroups.raft.filelog: Stores the LogEntry into a file.
LogEntryStorage(File, boolean) - Constructor for class org.jgroups.raft.filelog.LogEntryStorage
logName() - Method in class org.jgroups.protocols.raft.RAFT
logPrefix() - Method in class org.jgroups.protocols.raft.RAFT
logPrefix(String) - Method in class org.jgroups.protocols.raft.RAFT
logs - Static variable in class org.jgroups.protocols.raft.InMemoryLog
logSize() - Method in class org.jgroups.protocols.raft.RAFT
logSize() - Method in class org.jgroups.raft.blocks.CounterService
logSize() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
logSize() - Method in class org.jgroups.raft.demos.CounterServiceDemo
logSize() - Static method in class org.jgroups.raft.demos.ProgrammaticRSM
logSize() - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
logSize() - Method in class org.jgroups.raft.RaftHandle
logSizeInBytes() - Method in class org.jgroups.protocols.raft.RAFT: This is a managed operation because it should invoked sparingly (costly)
logUseFsync() - Method in class org.jgroups.protocols.raft.RAFT
logUseFsync(boolean) - Method in class org.jgroups.protocols.raft.RAFT
LongHelper - Class in org.jgroups.raft.util
LongHelper() - Constructor for class org.jgroups.raft.util.LongHelper
loop() - Method in class org.jgroups.raft.demos.CounterServiceDemo
loop() - Static method in class org.jgroups.raft.demos.ProgrammaticRSM
loop() - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
lost - Enum constant in enum org.jgroups.raft.util.Utils.Majority

M

main(String[]) - Static method in class org.jgroups.raft.client.Client
main(String[]) - Static method in class org.jgroups.raft.client.ReplicatedStateMachineClient
main(String[]) - Static method in class org.jgroups.raft.demos.CounterServiceDemo
main(String[]) - Static method in class org.jgroups.raft.demos.ProgrammaticRSM
main(String[]) - Static method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
main(String[]) - Static method in class org.jgroups.raft.util.AnalyzeLog
main(String[]) - Static method in class org.jgroups.raft.util.PropsToAsciidoc
majority - Variable in class org.jgroups.protocols.raft.Leader
majority - Variable in class org.jgroups.protocols.raft.RAFT
majority() - Method in class org.jgroups.protocols.raft.RAFT
majorityLost(View, View, int) - Static method in class org.jgroups.raft.util.Utils
majorityReached(View, View, int) - Static method in class org.jgroups.raft.util.Utils
map - Variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
map - Variable in class org.jgroups.raft.util.CommitTable
map - Variable in class org.jgroups.raft.util.ReplStateMachine
match_index - Variable in class org.jgroups.raft.util.CommitTable.Entry
matchIndex() - Method in class org.jgroups.raft.util.CommitTable.Entry
matchIndex(long) - Method in class org.jgroups.raft.util.CommitTable.Entry
max_log_size - Variable in class org.jgroups.protocols.raft.RAFT
max_size - Variable in class org.jgroups.raft.util.LogCache
max_threads - Variable in class org.jgroups.protocols.raft.CLIENT
maxLogCacheSize() - Method in class org.jgroups.protocols.raft.RAFT
maxLogCacheSize(int) - Method in class org.jgroups.protocols.raft.RAFT
maxLogSize() - Method in class org.jgroups.protocols.raft.RAFT
maxLogSize(long) - Method in class org.jgroups.protocols.raft.RAFT
maxSize() - Method in class org.jgroups.raft.util.LogCache
maxSize(int) - Method in class org.jgroups.raft.util.LogCache
members() - Method in class org.jgroups.protocols.raft.RAFT
members(Collection<String>) - Method in class org.jgroups.protocols.raft.RAFT
MetadataStorage - Class in org.jgroups.raft.filelog: Stores the RAFT log metadata in a file.
MetadataStorage(File, boolean) - Constructor for class org.jgroups.raft.filelog.MetadataStorage
min_threads - Variable in class org.jgroups.protocols.raft.CLIENT
MockRaftCluster - Class in org.jgroups.raft.testfwk: Base class for the cluster implementations in the test framework.
MockRaftCluster() - Constructor for class org.jgroups.raft.testfwk.MockRaftCluster
move(Address, Map<Address, RaftNode>, Map<Address, RaftNode>) - Static method in class org.jgroups.raft.testfwk.RaftCluster
moveAll(Map<Address, RaftNode>, Map<Address, RaftNode>) - Static method in class org.jgroups.raft.testfwk.RaftCluster

N

name - Variable in class org.jgroups.protocols.raft.InMemoryLog
name - Variable in class org.jgroups.protocols.raft.InternalCommand
next_index - Variable in class org.jgroups.raft.util.CommitTable.Entry
nextIndex() - Method in class org.jgroups.raft.util.CommitTable.Entry
nextIndex(long) - Method in class org.jgroups.raft.util.CommitTable.Entry
no_change - Enum constant in enum org.jgroups.raft.util.Utils.Majority
NO_DUPES - Class in org.jgroups.protocols.raft: Intercepts JOIN and MERGE requests on the coordinator and rejects members whose addition would lead to members with duplicate raft-ids in the view.
NO_DUPES() - Constructor for class org.jgroups.protocols.raft.NO_DUPES
nodes - Variable in class org.jgroups.raft.testfwk.PartitionedRaftCluster
nodes - Variable in class org.jgroups.raft.testfwk.RaftCluster
non_matching_term - Variable in class org.jgroups.protocols.raft.AppendResult: Ignored if success == true.
nonMatchingTerm() - Method in class org.jgroups.protocols.raft.AppendResult
noop - Enum constant in enum org.jgroups.protocols.raft.InternalCommand.Type
notify(byte[]) - Method in class org.jgroups.raft.util.RequestTable.Entry
notify(Throwable) - Method in class org.jgroups.raft.util.RequestTable.Entry
notify(RequestTable.Entry<T>, byte[]) - Static method in class org.jgroups.protocols.raft.RAFT
notify(RequestTable.Entry<T>, Throwable) - Static method in class org.jgroups.protocols.raft.RAFT
notifyAndRemove(long, byte[]) - Method in class org.jgroups.raft.util.RequestTable: Notifies the CompletableFuture and then removes the entry for index
notifyGet(K, V) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
notifyPut(K, V, V) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
notifyRemove(K, V) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
notifyRoleChangeListeners(Role) - Method in class org.jgroups.protocols.raft.RAFT
num_failed_append_requests_not_found - Variable in class org.jgroups.protocols.raft.RAFT
num_failed_append_requests_wrong_term - Variable in class org.jgroups.protocols.raft.RAFT
num_hits - Variable in class org.jgroups.raft.util.LogCache
num_misses - Variable in class org.jgroups.raft.util.LogCache
num_resends - Variable in class org.jgroups.protocols.raft.RAFT
num_snapshot_received - Variable in class org.jgroups.protocols.raft.RAFT
num_snapshots - Variable in class org.jgroups.protocols.raft.RAFT
num_successful_append_requests - Variable in class org.jgroups.protocols.raft.RAFT
num_trims - Variable in class org.jgroups.raft.util.LogCache
num_voting_rounds - Variable in class org.jgroups.protocols.raft.election.BaseElection
numAccesses() - Method in class org.jgroups.raft.util.LogCache
numberOfBlockedMessages() - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor: The number of blocked messages.
numSnapshots() - Method in class org.jgroups.protocols.raft.RAFT
numTrims() - Method in class org.jgroups.raft.util.LogCache

O

offer(RAFT.Request) - Method in class org.jgroups.protocols.raft.RAFT
offset - Variable in class org.jgroups.protocols.raft.LogEntry
offset() - Method in class org.jgroups.protocols.raft.LogEntry
OK - Enum constant in enum org.jgroups.protocols.raft.AppendResult.Result
open() - Method in class org.jgroups.raft.filelog.FileStorage
open() - Method in class org.jgroups.raft.filelog.LogEntryStorage
open() - Method in class org.jgroups.raft.filelog.MetadataStorage
openPMEMChannel(File, int, boolean, boolean) - Static method in class org.jgroups.raft.util.pmem.FileProvider
options - Variable in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
options - Variable in class org.jgroups.protocols.raft.REDIRECT.ResponseHandler
options() - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
options() - Method in class org.jgroups.raft.util.RequestTable.Entry
options(Options) - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
Options - Class in org.jgroups.raft: Options to pass to Settable.setAsync(byte[], int, int) call
Options() - Constructor for class org.jgroups.raft.Options
opts - Variable in class org.jgroups.raft.util.RequestTable.Entry
org.jgroups.protocols.raft - package org.jgroups.protocols.raft
org.jgroups.protocols.raft.election - package org.jgroups.protocols.raft.election
org.jgroups.protocols.raft.state - package org.jgroups.protocols.raft.state
org.jgroups.raft - package org.jgroups.raft
org.jgroups.raft.blocks - package org.jgroups.raft.blocks
org.jgroups.raft.client - package org.jgroups.raft.client
org.jgroups.raft.demos - package org.jgroups.raft.demos
org.jgroups.raft.filelog - package org.jgroups.raft.filelog
org.jgroups.raft.testfwk - package org.jgroups.raft.testfwk
org.jgroups.raft.util - package org.jgroups.raft.util
org.jgroups.raft.util.pmem - package org.jgroups.raft.util.pmem
out - Variable in class org.jgroups.raft.client.ClientStub
output - Variable in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler

P

parseCommaDelimitedProps(String) - Static method in class org.jgroups.protocols.raft.RAFT
PartitionedRaftCluster - Class in org.jgroups.raft.testfwk: Manipulate the cluster during tests.
PartitionedRaftCluster() - Constructor for class org.jgroups.raft.testfwk.PartitionedRaftCluster
partitions - Variable in class org.jgroups.raft.testfwk.PartitionedRaftCluster
peek() - Method in class org.jgroups.raft.util.ArrayRingBuffer
persistent_state - Variable in class org.jgroups.raft.util.AnalyzeLog
PersistentState - Class in org.jgroups.protocols.raft: Responsible for a node's internal state.
PersistentState() - Constructor for class org.jgroups.protocols.raft.PersistentState
pmemChannelFor(File, int, boolean, boolean) - Static method in class org.jgroups.raft.util.pmem.PmemUtilWrapper: Same as PmemUtil.pmemChannelFor(File, int, boolean, boolean).
PmemUtilWrapper - Class in org.jgroups.raft.util.pmem: This class is here solely for the purpose of encapsulating the PmemUtil class so we do not load it unless necessary, allowing this to be an optional dependency.
PmemUtilWrapper() - Constructor for class org.jgroups.raft.util.pmem.PmemUtilWrapper
poll() - Method in class org.jgroups.raft.util.ArrayRingBuffer: Removes the element at head
port - Variable in class org.jgroups.protocols.raft.CLIENT
port - Variable in class org.jgroups.raft.client.ClientStub
PRE_VOTE_REQ - Static variable in class org.jgroups.protocols.raft.election.BaseElection
PRE_VOTE_RSP - Static variable in class org.jgroups.protocols.raft.election.BaseElection
prev_log_index - Variable in class org.jgroups.protocols.raft.AppendEntriesRequest
prev_log_term - Variable in class org.jgroups.protocols.raft.AppendEntriesRequest
PreVoteRequest - Class in org.jgroups.protocols.raft.election: Utilized during the pre-voting phase to ask nodes information about their leader.
PreVoteRequest() - Constructor for class org.jgroups.protocols.raft.election.PreVoteRequest
PreVoteResponse - Class in org.jgroups.protocols.raft.election: Utilized during the pre-voting phase to return information about the current seen leader.
PreVoteResponse() - Constructor for class org.jgroups.protocols.raft.election.PreVoteResponse
PreVoteResponse(Address) - Constructor for class org.jgroups.protocols.raft.election.PreVoteResponse
Pre-Voting phase: - Search tag in class org.jgroups.protocols.raft.ELECTION2: Section
print(CounterService.Command, String, int, DataInput) - Static method in class org.jgroups.raft.blocks.CounterService
print_function - Static variable in class org.jgroups.protocols.raft.RAFT
printCounters() - Method in class org.jgroups.raft.blocks.CounterService
process(List<RAFT.Request>) - Method in class org.jgroups.protocols.raft.RAFT
processing_queue - Variable in class org.jgroups.protocols.raft.RAFT: All requests are added to this queue; a single thread processes this queue - hence no synchronization issues
processing_queue_max_size - Variable in class org.jgroups.protocols.raft.RAFT
processingQueueSize() - Method in class org.jgroups.protocols.raft.RAFT
processQueue() - Method in class org.jgroups.protocols.raft.RAFT
ProgrammaticRSM - Class in org.jgroups.raft.demos: Demos ReplicatedStateMachine.
ProgrammaticRSM() - Constructor for class org.jgroups.raft.demos.ProgrammaticRSM
PropsToAsciidoc - Class in org.jgroups.raft.util: Iterates over all concrete Protocol classes and creates tables with Protocol's properties.
PropsToAsciidoc() - Constructor for class org.jgroups.raft.util.PropsToAsciidoc
protocols() - Method in class org.jgroups.raft.testfwk.RaftNode
prots - Variable in class org.jgroups.raft.testfwk.RaftNode
put(String, String) - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
put(String, String) - Static method in class org.jgroups.raft.demos.ProgrammaticRSM
put(String, String) - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
put(K, V) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine: Adds a key value pair to the state machine.
put(K, V, V) - Method in interface org.jgroups.raft.blocks.ReplicatedStateMachine.Notification
PUT - Enum constant in enum org.jgroups.raft.demos.ReplicatedStateMachineDemo.Command
PUT - Static variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
PUT - Static variable in class org.jgroups.raft.util.ReplStateMachine

R

raft - Variable in class org.jgroups.protocols.raft.election.BaseElection
raft - Variable in class org.jgroups.protocols.raft.RaftImpl
raft - Variable in class org.jgroups.protocols.raft.REDIRECT
raft - Variable in class org.jgroups.raft.blocks.CounterService
raft - Variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
raft - Variable in class org.jgroups.raft.RaftHandle
raft - Variable in class org.jgroups.raft.testfwk.RaftNode
raft() - Method in class org.jgroups.protocols.raft.election.BaseElection
raft() - Method in class org.jgroups.protocols.raft.RaftImpl
raft() - Method in class org.jgroups.raft.RaftHandle
raft() - Method in class org.jgroups.raft.testfwk.RaftNode
raft(JChannel) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils: Retrieves the RAFT protocol from the provided JChannel.
raft(RAFT) - Method in class org.jgroups.protocols.raft.election.BaseElection
raft(RAFT) - Method in class org.jgroups.protocols.raft.RaftImpl
RAFT - Class in org.jgroups.protocols.raft: Implementation of the RAFT consensus protocol in JGroups
RAFT() - Constructor for class org.jgroups.protocols.raft.RAFT
raft_id - Variable in class org.jgroups.protocols.raft.RAFT
RAFT_ID - Static variable in class org.jgroups.protocols.raft.RAFT
raft_id_key - Static variable in class org.jgroups.protocols.raft.RAFT
raft_state - Variable in class org.jgroups.protocols.raft.RAFT
RAFT.DownRequest - Class in org.jgroups.protocols.raft: Generated by Settable.setAsync(byte[], int, int)
RAFT.Request - Class in org.jgroups.protocols.raft
RAFT.RoleChange - Interface in org.jgroups.protocols.raft
RAFT.SnapshotRequest - Class in org.jgroups.protocols.raft
RAFT.UpRequest - Class in org.jgroups.protocols.raft: Received by up(Message) or up(MessageBatch)
RaftAsyncCounter - Interface in org.jgroups.raft.blocks: TODO!
RaftCluster - Class in org.jgroups.raft.testfwk: Orchestrates a number of RaftNode objects, to be used in a unit test, for example a leader and a follower.
RaftCluster() - Constructor for class org.jgroups.raft.testfwk.RaftCluster
RaftCounter - Interface in org.jgroups.raft.blocks: TODO!
RaftHandle - Class in org.jgroups.raft: Main interaction point for applications with jgroups-raft.
RaftHandle(JChannel, StateMachine) - Constructor for class org.jgroups.raft.RaftHandle: Creates a RaftHandle instance.
RaftHeader - Class in org.jgroups.protocols.raft
RaftHeader() - Constructor for class org.jgroups.protocols.raft.RaftHeader
RaftHeader(long) - Constructor for class org.jgroups.protocols.raft.RaftHeader
raftId() - Method in class org.jgroups.protocols.raft.RAFT
raftId() - Method in class org.jgroups.raft.blocks.CounterService
raftId() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
raftId() - Method in class org.jgroups.raft.RaftHandle
raftId(String) - Method in class org.jgroups.protocols.raft.RAFT
raftId(String) - Method in class org.jgroups.raft.blocks.CounterService
raftId(String) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
raftId(String) - Method in class org.jgroups.raft.RaftHandle
RaftImpl - Class in org.jgroups.protocols.raft: Base class for the different roles a RAFT node can have (follower, candidate, leader)
RaftImpl(RAFT) - Constructor for class org.jgroups.protocols.raft.RaftImpl
RaftLeaderException - Exception Class in org.jgroups.protocols.raft
RaftLeaderException(String) - Constructor for exception class org.jgroups.protocols.raft.RaftLeaderException
RaftNode - Class in org.jgroups.raft.testfwk: Wraps the RAFT and/or ELECTION protocols
RaftNode(MockRaftCluster, Protocol[]) - Constructor for class org.jgroups.raft.testfwk.RaftNode
RaftNode(RaftCluster, RAFT) - Constructor for class org.jgroups.raft.testfwk.RaftNode
RaftState - Class in org.jgroups.protocols.raft.state: Keep track of part of the algorithm state.
RaftState(RAFT, Consumer<Address>) - Constructor for class org.jgroups.protocols.raft.state.RaftState
RaftSyncCounter - Interface in org.jgroups.raft.blocks: TODO!
RaftTestUtils - Class in org.jgroups.raft.testfwk: Utilities for developing tests with Raft.
reached - Enum constant in enum org.jgroups.raft.util.Utils.Majority
read(long, int) - Method in class org.jgroups.raft.filelog.FileStorage
read(String) - Static method in class org.jgroups.raft.client.ReplicatedStateMachineClient
read(String) - Static method in class org.jgroups.raft.demos.ProgrammaticRSM
read(String) - Static method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
readAndDumpSnapshot(DataInput) - Static method in class org.jgroups.raft.blocks.CounterService
readAndDumpSnapshot(DataInput) - Static method in class org.jgroups.raft.util.CounterStateMachine
readContentFrom(DataInput) - Method in class org.jgroups.raft.blocks.CounterService
readContentFrom(DataInput) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
readContentFrom(DataInput) - Method in interface org.jgroups.raft.StateMachine: Reads the contents of the state machine from an input stream.
readContentFrom(DataInput) - Method in class org.jgroups.raft.util.CounterStateMachine
readContentFrom(DataInput) - Method in class org.jgroups.raft.util.ReplStateMachine
reader - Variable in class org.jgroups.raft.util.AnalyzeLog
reader(String) - Method in class org.jgroups.raft.util.AnalyzeLog
reader(LogEntry) - Static method in class org.jgroups.raft.util.CounterStateMachine
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.AppendEntriesRequest
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.AppendEntriesResponse
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.AppendResult
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.election.LeaderElected
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.election.PreVoteResponse
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.election.VoteResponse
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.InstallSnapshotRequest
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.InternalCommand
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.LogEntries
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.LogEntry
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.PersistentState
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.RaftHeader
readFrom(DataInput) - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
readFrom(DataInput) - Method in class org.jgroups.raft.Options
readOnly - Variable in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
readOnly(boolean) - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
ReadOnlyRequestRepository<R> - Class in org.jgroups.raft.util: Repository for read-only operations.
ReadOnlyRequestRepository.Builder<R> - Class in org.jgroups.raft.util
readOnlyRequests - Variable in class org.jgroups.protocols.raft.RAFT
readResponse() - Method in class org.jgroups.raft.client.ClientStub
readUntilBracket(InputStream) - Static method in class org.jgroups.raft.util.PropsToAsciidoc: Reads until the next bracket '}' and returns the string excluding the bracket, or throws an exception if no bracket has been found
receive(Address, byte[], int, int) - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
receive(Address, byte[], int, int) - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
receive(Address, DataInput) - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
receive(Address, DataInput) - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
receive(Address, ByteBuffer) - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
receive(Address, ByteBuffer) - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
recv_buf_size - Variable in class org.jgroups.protocols.raft.CLIENT
REDIRECT - Class in org.jgroups.protocols.raft: Protocol that redirects RAFT commands from clients to the actual RAFT leader.
REDIRECT() - Constructor for class org.jgroups.protocols.raft.REDIRECT
REDIRECT_HDR - Static variable in class org.jgroups.protocols.raft.REDIRECT
REDIRECT_ID - Static variable in class org.jgroups.protocols.raft.REDIRECT
REDIRECT.RedirectHeader - Class in org.jgroups.protocols.raft
REDIRECT.RequestType - Enum in org.jgroups.protocols.raft
REDIRECT.ResponseHandler - Class in org.jgroups.protocols.raft
RedirectHeader() - Constructor for class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
RedirectHeader(REDIRECT.RequestType, int, boolean) - Constructor for class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
register(long, R) - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository: Register a new request submitted at the given index.
reinitializeTo(long, LogEntry) - Method in class org.jgroups.protocols.raft.FileBasedLog
reinitializeTo(long, LogEntry) - Method in class org.jgroups.protocols.raft.InMemoryLog
reinitializeTo(long, LogEntry) - Method in interface org.jgroups.protocols.raft.Log: Clears all entries and sets first_appended/last_appended/commit_index to index and appends entry at index.
reinitializeTo(long, LogEntry) - Method in class org.jgroups.raft.filelog.LogEntryStorage
reinitializeTo(long, LogEntry) - Method in class org.jgroups.raft.util.LogCache
releaseNext() - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor: Releases the next blocked message in line.
reload() - Method in class org.jgroups.protocols.raft.state.RaftState: Read the state information from the RAFT's log.
reload() - Method in class org.jgroups.raft.filelog.LogEntryStorage
remove(long) - Method in class org.jgroups.raft.util.ArrayRingBuffer: Removes an element at index
remove(long) - Method in class org.jgroups.raft.util.RequestTable
remove(String) - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
remove(String) - Static method in class org.jgroups.raft.demos.ProgrammaticRSM
remove(String) - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
remove(K) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine: Removes a key-value pair from the state machine.
remove(K, V) - Method in interface org.jgroups.raft.blocks.ReplicatedStateMachine.Notification
remove(Address) - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Remove a member from the cluster.
remove(Address) - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
remove(Address) - Method in class org.jgroups.raft.testfwk.RaftCluster
REMOVE - Enum constant in enum org.jgroups.raft.demos.ReplicatedStateMachineDemo.Command
REMOVE - Static variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
REMOVE - Static variable in class org.jgroups.raft.util.ReplStateMachine
remove_queue - Variable in class org.jgroups.protocols.raft.RAFT
remove_server - Enum constant in enum org.jgroups.protocols.raft.CLIENT.RequestType
REMOVE_SERVER - Enum constant in enum org.jgroups.protocols.raft.REDIRECT.RequestType
removeNew(long) - Method in class org.jgroups.raft.filelog.LogEntryStorage
removeNotificationListener(ReplicatedStateMachine.Notification<K, V>) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
removeOld(long) - Method in class org.jgroups.raft.filelog.LogEntryStorage
removeQueueSize() - Method in class org.jgroups.protocols.raft.RAFT
removeRoleChangeListener(RAFT.RoleChange) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
removeRoleListener(RAFT.RoleChange) - Method in class org.jgroups.raft.RaftHandle
removeServer - Enum constant in enum org.jgroups.protocols.raft.InternalCommand.Type
removeServer(String) - Method in interface org.jgroups.protocols.raft.DynamicMembership
removeServer(String) - Method in class org.jgroups.protocols.raft.RAFT
removeServer(String) - Method in class org.jgroups.protocols.raft.REDIRECT
removeServer(String) - Method in class org.jgroups.raft.RaftHandle: Asynchronously removes a server from the RAFT cluster.
remRoleListener(RAFT.RoleChange) - Method in class org.jgroups.protocols.raft.RAFT
repl_timeout - Variable in class org.jgroups.raft.blocks.CounterService
repl_timeout - Variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
replaceVariables(InputStream, OutputStream, Properties) - Static method in class org.jgroups.raft.util.PropsToAsciidoc: Reads from the input stream and replaces occurrences of ${PROT} with p.get("PROT") and writes this to the output stream.
ReplicatedStateMachine<K,V> - Class in org.jgroups.raft.blocks: A key-value store replicating its contents with RAFT via consensus
ReplicatedStateMachine(JChannel) - Constructor for class org.jgroups.raft.blocks.ReplicatedStateMachine
ReplicatedStateMachine.Notification<K,V> - Interface in org.jgroups.raft.blocks
ReplicatedStateMachineClient - Class in org.jgroups.raft.client: Client connecting to a remote ReplicatedStateMachineDemo.
ReplicatedStateMachineClient(boolean) - Constructor for class org.jgroups.raft.client.ReplicatedStateMachineClient
ReplicatedStateMachineDemo - Class in org.jgroups.raft.demos: Demos ReplicatedStateMachine
ReplicatedStateMachineDemo() - Constructor for class org.jgroups.raft.demos.ReplicatedStateMachineDemo
ReplicatedStateMachineDemo.Command - Enum in org.jgroups.raft.demos
ReplStateMachine<K,V> - Class in org.jgroups.raft.util: Dummy replicated hashmap state machine
ReplStateMachine() - Constructor for class org.jgroups.raft.util.ReplStateMachine
replTimeout() - Method in class org.jgroups.raft.blocks.CounterService
replTimeout(long) - Method in class org.jgroups.raft.blocks.CounterService
REQ - Enum constant in enum org.jgroups.protocols.raft.REDIRECT.RequestType
req_id - Variable in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
Request() - Constructor for class org.jgroups.protocols.raft.RAFT.Request
request_ids - Variable in class org.jgroups.protocols.raft.REDIRECT
request_table - Variable in class org.jgroups.protocols.raft.RAFT
RequestHandler(Socket) - Constructor for class org.jgroups.protocols.raft.CLIENT.RequestHandler
requests - Variable in class org.jgroups.protocols.raft.REDIRECT
requests - Variable in class org.jgroups.raft.client.ClientStub
requests - Variable in class org.jgroups.raft.util.RequestTable
RequestTable<T> - Class in org.jgroups.raft.util: Keeps track of AppendEntriesRequest messages and responses.
RequestTable() - Constructor for class org.jgroups.raft.util.RequestTable
RequestTable.Entry<T> - Class in org.jgroups.raft.util
requestTableSize() - Method in class org.jgroups.protocols.raft.RAFT
resend(Address, long) - Method in class org.jgroups.protocols.raft.RAFT
resend(Address, long, long) - Method in class org.jgroups.protocols.raft.RAFT: Resends all entries in range [from .. to] to target
resend_interval - Variable in class org.jgroups.protocols.raft.RAFT
resendInterval() - Method in class org.jgroups.protocols.raft.RAFT
resendInterval(long) - Method in class org.jgroups.protocols.raft.RAFT
reset() - Method in class org.jgroups.raft.util.CounterStateMachine
resetStats() - Method in class org.jgroups.protocols.raft.election.BaseElection
resetStats() - Method in class org.jgroups.protocols.raft.RAFT
resetStats() - Method in class org.jgroups.raft.util.LogCache
ResponseHandler(Address, int, Options) - Constructor for class org.jgroups.protocols.raft.REDIRECT.ResponseHandler
result - Variable in class org.jgroups.protocols.raft.AppendEntriesResponse
result - Variable in class org.jgroups.protocols.raft.AppendResult: True if the append succeeded, false otherwise
role() - Method in class org.jgroups.protocols.raft.RAFT
Role - Enum in org.jgroups.protocols.raft
role_change_listeners - Variable in class org.jgroups.protocols.raft.RAFT
roleChanged(Role) - Method in interface org.jgroups.protocols.raft.RAFT.RoleChange
roleChanged(Role) - Method in class org.jgroups.raft.blocks.CounterService
roleChanged(Role) - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
ROOT_PACKAGE - Static variable in class org.jgroups.raft.util.PropsToAsciidoc
rsm - Static variable in class org.jgroups.raft.demos.ProgrammaticRSM
rsm - Variable in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
rsp - Enum constant in enum org.jgroups.protocols.raft.CLIENT.RequestType
RSP - Enum constant in enum org.jgroups.protocols.raft.REDIRECT.RequestType
run() - Method in class org.jgroups.protocols.raft.CLIENT.RequestHandler
run() - Method in class org.jgroups.protocols.raft.CLIENT
runner - Variable in class org.jgroups.protocols.raft.RAFT
runner - Variable in class org.jgroups.raft.client.ClientStub
running - Variable in class org.jgroups.raft.client.ReplicatedStateMachineClient
runVotingProcess() - Method in class org.jgroups.protocols.raft.election.BaseElection: The mechanism for deciding a new leader.
runVotingThread() - Method in class org.jgroups.protocols.raft.election.BaseElection

S

s - Variable in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
self() - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Utility to create a fluent use.
send(DataOutput, CLIENT.RequestType, int, byte[], int, int) - Method in class org.jgroups.protocols.raft.CLIENT.RequestHandler
send(Message) - Method in class org.jgroups.raft.testfwk.MockRaftCluster: Send a message in the cluster.
send(Message) - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
send(Message) - Method in class org.jgroups.raft.testfwk.RaftCluster
send(Message, boolean) - Method in class org.jgroups.raft.testfwk.RaftCluster
send_commits_immediately - Variable in class org.jgroups.protocols.raft.RAFT
send_single_msg - Variable in class org.jgroups.raft.util.CommitTable.Entry
sendAppendEntriesMessage(Address, CommitTable.Entry) - Method in class org.jgroups.protocols.raft.RAFT: Runs (on the leader) as part of the queue handling loop: checks if all members (except the leader) in the commit table have received all messages and resends AppendEntries messages to members who haven't.
For each member, a next-index and match-index is maintained: next-index is the index of the next message to send to that member (initialized to last-applied) and match-index is the index of the highest message known to have been received by the member.
Messages are resent to a given member as long as that member's match-index is smaller than its next-index.
sendCommitsImmediately() - Method in class org.jgroups.protocols.raft.RAFT
sendCommitsImmediately(boolean) - Method in class org.jgroups.protocols.raft.RAFT
sendJoinRejectedMessageTo(Address, String) - Method in class org.jgroups.protocols.raft.NO_DUPES
sendLeaderElectedMessage(Address, long) - Method in class org.jgroups.protocols.raft.election.BaseElection
sendResponse(Address, Object) - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
sendSingleMessage() - Method in class org.jgroups.raft.util.CommitTable.Entry
sendSingleMessage(boolean) - Method in class org.jgroups.raft.util.CommitTable.Entry
sendSnapshotTo(Address) - Method in class org.jgroups.protocols.raft.RAFT
sendVoteRequest(long) - Method in class org.jgroups.protocols.raft.election.BaseElection
sendVoteResponse(Address, long, long, long) - Method in class org.jgroups.protocols.raft.election.BaseElection
serializedSize() - Method in class org.jgroups.protocols.raft.AppendEntriesRequest
serializedSize() - Method in class org.jgroups.protocols.raft.AppendEntriesResponse
serializedSize() - Method in class org.jgroups.protocols.raft.election.LeaderElected
serializedSize() - Method in class org.jgroups.protocols.raft.election.PreVoteResponse
serializedSize() - Method in class org.jgroups.protocols.raft.election.VoteResponse
serializedSize() - Method in class org.jgroups.protocols.raft.InstallSnapshotRequest
serializedSize() - Method in class org.jgroups.protocols.raft.LogEntries
serializedSize() - Method in class org.jgroups.protocols.raft.LogEntry
serializedSize() - Method in class org.jgroups.protocols.raft.PersistentState
serializedSize() - Method in class org.jgroups.protocols.raft.RaftHeader
serializedSize() - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
serializedSize() - Method in class org.jgroups.raft.Options
server - Variable in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
set - Enum constant in enum org.jgroups.raft.blocks.CounterService.Command
set(byte[], int, int) - Method in interface org.jgroups.raft.Settable: Synchronous set.
set(byte[], int, int, long, TimeUnit) - Method in interface org.jgroups.raft.Settable: Synchronous set bounded by a timeout.
set(long) - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
set(long, long) - Method in class org.jgroups.raft.filelog.FilePositionCache
set(long, T) - Method in class org.jgroups.raft.util.ArrayRingBuffer
set_req - Enum constant in enum org.jgroups.protocols.raft.CLIENT.RequestType
setAsync(byte[], int, int) - Method in interface org.jgroups.raft.Settable
setAsync(byte[], int, int, boolean, Options) - Method in class org.jgroups.protocols.raft.RAFT
setAsync(byte[], int, int, Options) - Method in class org.jgroups.protocols.raft.RAFT: Called by a building block to apply a change to all state machines in a cluster.
setAsync(byte[], int, int, Options) - Method in class org.jgroups.protocols.raft.REDIRECT
setAsync(byte[], int, int, Options) - Method in class org.jgroups.raft.client.ClientStub
setAsync(byte[], int, int, Options) - Method in class org.jgroups.raft.RaftHandle
setAsync(byte[], int, int, Options) - Method in interface org.jgroups.raft.Settable: Asynchronous set, returns immediately with a CompletableFuture.
setAsync(byte[], int, int, Options) - Method in class org.jgroups.raft.testfwk.RaftNode
setAsync(CLIENT.RequestType, byte[], int, int) - Method in class org.jgroups.raft.client.ClientStub
setBindAddress(InetAddress) - Method in class org.jgroups.protocols.raft.CLIENT
setChannel(JChannel) - Method in class org.jgroups.raft.blocks.CounterService
setCommitIndex(long) - Method in class org.jgroups.raft.filelog.MetadataStorage
setCurrentTerm(long) - Method in class org.jgroups.raft.filelog.MetadataStorage
setHost(InetAddress) - Method in class org.jgroups.raft.client.ClientStub
setIdleTime(long) - Method in class org.jgroups.protocols.raft.CLIENT
setLeader(Address) - Method in class org.jgroups.protocols.raft.state.RaftState: Update the leader in the current term.
setLeaderAndTerm(Address) - Method in class org.jgroups.protocols.raft.RAFT
setLeaderAndTerm(Address, long) - Method in class org.jgroups.protocols.raft.RAFT: Sets the new leader and term
setMaxThreads(int) - Method in class org.jgroups.protocols.raft.CLIENT
setMembers(String) - Method in class org.jgroups.protocols.raft.RAFT
setMembers(Collection<String>) - Method in class org.jgroups.protocols.raft.PersistentState
setMinThreads(int) - Method in class org.jgroups.protocols.raft.CLIENT
setPort(int) - Method in class org.jgroups.protocols.raft.CLIENT
setPort(int) - Method in class org.jgroups.raft.client.ClientStub
setReceiveBufferSize(int) - Method in class org.jgroups.protocols.raft.CLIENT
setSnapshot(ByteBuffer) - Method in class org.jgroups.protocols.raft.FileBasedLog
setSnapshot(ByteBuffer) - Method in class org.jgroups.protocols.raft.InMemoryLog
setSnapshot(ByteBuffer) - Method in interface org.jgroups.protocols.raft.Log: Stores a snapshot in the log.
setSnapshot(ByteBuffer) - Method in class org.jgroups.raft.util.LogCache
settable - Variable in class org.jgroups.protocols.raft.CLIENT
settable - Variable in class org.jgroups.raft.RaftHandle
Settable - Interface in org.jgroups.raft: Interface to make changes to the Raft state machine.
setVotedFor(Address) - Method in class org.jgroups.protocols.raft.state.RaftState: Set the vote in the current term.
setVotedFor(Address) - Method in class org.jgroups.raft.filelog.MetadataStorage
shouldBlock(Message) - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor: Check if the given message should be blocked.
SHOW_ALL - Enum constant in enum org.jgroups.raft.demos.ReplicatedStateMachineDemo.Command
SHOW_ALL_CMD - Static variable in class org.jgroups.raft.client.ReplicatedStateMachineClient
showAll() - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
size() - Method in class org.jgroups.protocols.raft.AppendResult
size() - Method in interface org.jgroups.protocols.raft.Log: The number of entries in the log
size() - Method in class org.jgroups.protocols.raft.LogEntries
size() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine: Returns the number of elements in the RSM
size() - Method in class org.jgroups.raft.testfwk.MockRaftCluster: The number of member in the cluster.
size() - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
size() - Method in class org.jgroups.raft.testfwk.RaftCluster
size() - Method in class org.jgroups.raft.util.ArrayRingBuffer
size() - Method in class org.jgroups.raft.util.RequestTable: number of requests being processed
size(boolean) - Method in class org.jgroups.raft.util.ArrayRingBuffer
sizeInBytes() - Method in class org.jgroups.protocols.raft.FileBasedLog
sizeInBytes() - Method in class org.jgroups.protocols.raft.InMemoryLog
sizeInBytes() - Method in interface org.jgroups.protocols.raft.Log
sizeInBytes() - Method in class org.jgroups.raft.util.LogCache
snapshot - Variable in class org.jgroups.protocols.raft.InMemoryLog
snapshot() - Method in class org.jgroups.protocols.raft.RAFT: Creates a snapshot and truncates the log.
snapshot() - Method in class org.jgroups.raft.blocks.CounterService
snapshot() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
snapshot() - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
snapshot() - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
snapshot() - Method in class org.jgroups.raft.RaftHandle
SNAPSHOT - Enum constant in enum org.jgroups.raft.demos.ReplicatedStateMachineDemo.Command
SNAPSHOT_CMD - Static variable in class org.jgroups.raft.client.ReplicatedStateMachineClient
snapshot_reader - Variable in class org.jgroups.raft.util.AnalyzeLog
snapshotAsync() - Method in class org.jgroups.protocols.raft.RAFT
snapshotIfNeeded(int) - Method in class org.jgroups.protocols.raft.RAFT
snapshotReader(String) - Method in class org.jgroups.raft.util.AnalyzeLog
SnapshotRequest(CompletableFuture<Void>) - Constructor for class org.jgroups.protocols.raft.RAFT.SnapshotRequest
sock - Variable in class org.jgroups.protocols.raft.CLIENT
sock - Variable in class org.jgroups.raft.client.ClientStub
start() - Method in class org.jgroups.protocols.raft.CLIENT
start() - Method in class org.jgroups.protocols.raft.RAFT
start() - Method in class org.jgroups.raft.client.ClientStub
start() - Method in class org.jgroups.raft.testfwk.RaftNode
start(String, String, long, InetAddress, int, boolean, boolean) - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
start(InetAddress, int) - Method in class org.jgroups.raft.client.ReplicatedStateMachineClient
start(InetAddress, int) - Method in class org.jgroups.raft.demos.ReplicatedStateMachineDemo
start(InetAddress, int, String, String) - Static method in class org.jgroups.raft.client.Client
startVotingThread() - Method in class org.jgroups.protocols.raft.election.BaseElection
state_machine - Variable in class org.jgroups.protocols.raft.RAFT
state_machine_loaded - Variable in class org.jgroups.protocols.raft.RAFT
stateMachine() - Method in class org.jgroups.protocols.raft.RAFT
stateMachine() - Method in class org.jgroups.raft.RaftHandle
stateMachine(StateMachine) - Method in class org.jgroups.protocols.raft.RAFT
stateMachine(StateMachine) - Method in class org.jgroups.raft.RaftHandle
StateMachine - Interface in org.jgroups.raft: Interface of a state machine which stores data in memory.
stateMachineLoaded(boolean) - Method in class org.jgroups.protocols.raft.RAFT
stop() - Method in class org.jgroups.protocols.raft.CLIENT
stop() - Method in class org.jgroups.protocols.raft.election.BaseElection
stop() - Method in class org.jgroups.protocols.raft.RAFT
stop() - Method in class org.jgroups.raft.client.ClientStub
stop() - Method in class org.jgroups.raft.testfwk.RaftNode
stopVotingThread() - Method in class org.jgroups.protocols.raft.election.BaseElection
subtractions - Variable in class org.jgroups.raft.util.CounterStateMachine
subtractions() - Method in class org.jgroups.raft.util.CounterStateMachine
success() - Method in class org.jgroups.protocols.raft.AppendResult
sync() - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
sync() - Method in interface org.jgroups.raft.blocks.RaftCounter
sync() - Method in interface org.jgroups.raft.blocks.RaftSyncCounter
synchronous - Variable in class org.jgroups.protocols.raft.RAFT
synchronous() - Method in class org.jgroups.protocols.raft.RAFT
synchronous(boolean) - Method in class org.jgroups.protocols.raft.RAFT

T

takeSnapshot() - Method in class org.jgroups.protocols.raft.RAFT
term - Variable in class org.jgroups.protocols.raft.LogEntry
term() - Method in class org.jgroups.protocols.raft.LogEntry
term(long) - Method in class org.jgroups.protocols.raft.LogEntry
thread_pool - Variable in class org.jgroups.protocols.raft.CLIENT
thread_pool - Variable in class org.jgroups.raft.testfwk.MockRaftCluster
timeout() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
timeout(long) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
toArray() - Method in class org.jgroups.protocols.raft.LogEntries
TOO_OLD - Static variable in class org.jgroups.raft.filelog.FilePositionCache
toString() - Method in class org.jgroups.protocols.raft.AppendEntriesRequest
toString() - Method in class org.jgroups.protocols.raft.AppendEntriesResponse
toString() - Method in class org.jgroups.protocols.raft.AppendResult
toString() - Method in class org.jgroups.protocols.raft.election.LeaderElected
toString() - Method in class org.jgroups.protocols.raft.election.PreVoteRequest
toString() - Method in class org.jgroups.protocols.raft.election.PreVoteResponse
toString() - Method in class org.jgroups.protocols.raft.election.VoteResponse
toString() - Method in class org.jgroups.protocols.raft.FileBasedLog
toString() - Method in class org.jgroups.protocols.raft.InMemoryLog
toString() - Method in class org.jgroups.protocols.raft.InstallSnapshotRequest
toString() - Method in class org.jgroups.protocols.raft.InternalCommand
toString() - Method in class org.jgroups.protocols.raft.LogEntries
toString() - Method in class org.jgroups.protocols.raft.LogEntry
toString() - Method in class org.jgroups.protocols.raft.PersistentState
toString() - Method in class org.jgroups.protocols.raft.RAFT.DownRequest
toString() - Method in class org.jgroups.protocols.raft.RAFT.SnapshotRequest
toString() - Method in class org.jgroups.protocols.raft.RAFT
toString() - Method in class org.jgroups.protocols.raft.RAFT.UpRequest
toString() - Method in class org.jgroups.protocols.raft.RaftHeader
toString() - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
toString() - Method in class org.jgroups.protocols.raft.state.RaftState
toString() - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
toString() - Method in class org.jgroups.raft.blocks.CounterService
toString() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
toString() - Method in class org.jgroups.raft.client.ClientStub
toString() - Method in class org.jgroups.raft.Options
toString() - Method in class org.jgroups.raft.testfwk.RaftCluster
toString() - Method in class org.jgroups.raft.testfwk.RaftNode
toString() - Method in class org.jgroups.raft.util.ArrayRingBuffer
toString() - Method in class org.jgroups.raft.util.CommitTable.Entry
toString() - Method in class org.jgroups.raft.util.CommitTable
toString() - Method in class org.jgroups.raft.util.CounterStateMachine
toString() - Method in class org.jgroups.raft.util.LogCache
toString() - Method in class org.jgroups.raft.util.RequestTable.Entry
toString() - Method in class org.jgroups.raft.util.RequestTable
toStringDetails() - Method in class org.jgroups.raft.util.LogCache
totalSize() - Method in class org.jgroups.protocols.raft.LogEntries
trim() - Method in class org.jgroups.raft.util.LogCache
trimLogCache() - Method in class org.jgroups.protocols.raft.RAFT
truncate(long) - Method in class org.jgroups.protocols.raft.FileBasedLog
truncate(long) - Method in class org.jgroups.protocols.raft.InMemoryLog
truncate(long) - Method in interface org.jgroups.protocols.raft.Log: Truncates the log up to (and excluding) index.
truncate(long) - Method in class org.jgroups.raft.util.LogCache
truncateFrom(long) - Method in class org.jgroups.raft.filelog.FileStorage
truncateTo(long) - Method in class org.jgroups.raft.filelog.FileStorage
tryAdvanceTerm(long) - Method in class org.jgroups.protocols.raft.state.RaftState: Try advancing the term, and if succeeding, the leader is null.
tryAdvanceTermAndLeader(long, Address) - Method in class org.jgroups.protocols.raft.state.RaftState: Try to advance the current term and set the leader.
trySetLeaderAndTerm(Address, long) - Method in class org.jgroups.protocols.raft.RAFT
type - Enum constant in enum org.jgroups.protocols.raft.CLIENT.RequestType
type - Variable in class org.jgroups.protocols.raft.InternalCommand
type - Variable in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
type() - Method in class org.jgroups.protocols.raft.InternalCommand

U

up(Event) - Method in class org.jgroups.protocols.raft.election.BaseElection
up(Event) - Method in class org.jgroups.protocols.raft.RAFT
up(Event) - Method in class org.jgroups.protocols.raft.REDIRECT
up(Message) - Method in class org.jgroups.protocols.raft.election.BaseElection
up(Message) - Method in class org.jgroups.protocols.raft.NO_DUPES
up(Message) - Method in class org.jgroups.protocols.raft.RAFT
up(Message) - Method in class org.jgroups.protocols.raft.REDIRECT
up(Message) - Method in class org.jgroups.raft.testfwk.RaftNode
up(MessageBatch) - Method in class org.jgroups.protocols.raft.CLIENT
up(MessageBatch) - Method in class org.jgroups.protocols.raft.election.BaseElection
up(MessageBatch) - Method in class org.jgroups.protocols.raft.NO_DUPES
up(MessageBatch) - Method in class org.jgroups.protocols.raft.RAFT
up(MessageBatch) - Method in class org.jgroups.protocols.raft.REDIRECT
update(Address, long, long, long, boolean) - Method in class org.jgroups.raft.util.CommitTable
update(Address, long, long, long, boolean, boolean) - Method in class org.jgroups.raft.util.CommitTable
update(CounterFunction<T>) - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
updateFunction - Enum constant in enum org.jgroups.raft.blocks.CounterService.Command
UpRequest(Message, RaftHeader) - Constructor for class org.jgroups.protocols.raft.RAFT.UpRequest
useClassLoader(ClassLoader) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
useFsync() - Method in class org.jgroups.protocols.raft.FileBasedLog
useFsync() - Method in class org.jgroups.protocols.raft.InMemoryLog
useFsync() - Method in interface org.jgroups.protocols.raft.Log
useFsync() - Method in class org.jgroups.raft.filelog.MetadataStorage
useFsync() - Method in class org.jgroups.raft.util.LogCache
useFsync(boolean) - Method in class org.jgroups.protocols.raft.FileBasedLog
useFsync(boolean) - Method in class org.jgroups.protocols.raft.InMemoryLog
useFsync(boolean) - Method in interface org.jgroups.protocols.raft.Log: Do not cache a change (e.g.
useFsync(boolean) - Method in class org.jgroups.raft.filelog.LogEntryStorage
useFsync(boolean) - Method in class org.jgroups.raft.filelog.MetadataStorage
useFsync(boolean) - Method in class org.jgroups.raft.util.LogCache
Utils - Class in org.jgroups.raft.util
Utils() - Constructor for class org.jgroups.raft.util.Utils
Utils.Majority - Enum in org.jgroups.raft.util

V

valueOf(String) - Static method in enum org.jgroups.protocols.raft.AppendResult.Result: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.jgroups.protocols.raft.CLIENT.RequestType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.jgroups.protocols.raft.InternalCommand.Type: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.jgroups.protocols.raft.REDIRECT.RequestType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.jgroups.protocols.raft.Role: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.jgroups.raft.blocks.CounterService.Command: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.jgroups.raft.demos.ReplicatedStateMachineDemo.Command: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.jgroups.raft.util.Utils.Majority: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.jgroups.protocols.raft.AppendResult.Result: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.jgroups.protocols.raft.CLIENT.RequestType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.jgroups.protocols.raft.InternalCommand.Type: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.jgroups.protocols.raft.REDIRECT.RequestType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.jgroups.protocols.raft.Role: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.jgroups.raft.blocks.CounterService.Command: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.jgroups.raft.demos.ReplicatedStateMachineDemo.Command: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.jgroups.raft.util.Utils.Majority: Returns an array containing the constants of this enum type, in the order they are declared.
verbose - Variable in class org.jgroups.raft.client.ReplicatedStateMachineClient
view - Variable in class org.jgroups.protocols.raft.election.BaseElection
view - Variable in class org.jgroups.protocols.raft.NO_DUPES
view - Variable in class org.jgroups.protocols.raft.RAFT
view - Variable in class org.jgroups.protocols.raft.REDIRECT
viewCoordinatorChanged(View, View) - Static method in class org.jgroups.raft.util.Utils: Verify if the coordinator change between two views.
VOTE_REQ - Static variable in class org.jgroups.protocols.raft.election.BaseElection
vote_timeout - Variable in class org.jgroups.protocols.raft.election.BaseElection
voted_for - Variable in class org.jgroups.protocols.raft.InMemoryLog
voted_for - Variable in class org.jgroups.raft.util.LogCache
votedFor() - Method in class org.jgroups.protocols.raft.FileBasedLog
votedFor() - Method in class org.jgroups.protocols.raft.InMemoryLog
votedFor() - Method in interface org.jgroups.protocols.raft.Log: Returns the address of the candidate that this node voted for in the current term
votedFor() - Method in class org.jgroups.protocols.raft.RAFT
votedFor() - Method in class org.jgroups.protocols.raft.state.RaftState
votedFor() - Method in class org.jgroups.raft.util.LogCache
votedFor(Address) - Method in class org.jgroups.protocols.raft.FileBasedLog
votedFor(Address) - Method in class org.jgroups.protocols.raft.InMemoryLog
votedFor(Address) - Method in interface org.jgroups.protocols.raft.Log: Sets the address of the member this node voted for in the current term.
votedFor(Address) - Method in class org.jgroups.protocols.raft.RAFT
votedFor(Address) - Method in class org.jgroups.raft.util.LogCache
VoteRequest - Class in org.jgroups.protocols.raft.election
VoteRequest() - Constructor for class org.jgroups.protocols.raft.election.VoteRequest
VoteRequest(long) - Constructor for class org.jgroups.protocols.raft.election.VoteRequest
VoteResponse - Class in org.jgroups.protocols.raft.election
VoteResponse() - Constructor for class org.jgroups.protocols.raft.election.VoteResponse
VoteResponse(long, long, long) - Constructor for class org.jgroups.protocols.raft.election.VoteResponse
votes - Variable in class org.jgroups.raft.util.RequestTable.Entry
voteTimeout() - Method in class org.jgroups.protocols.raft.election.BaseElection
voteTimeout(long) - Method in class org.jgroups.protocols.raft.election.BaseElection: Defines the default timeout in milliseconds to utilize during any election operation.

W

withCommitter(Consumer<Collection<R>>) - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository.Builder
withDestroyer(Consumer<Collection<R>>) - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository.Builder
withOptions(Options) - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
withOptions(Options) - Method in interface org.jgroups.raft.blocks.RaftAsyncCounter
withOptions(Options) - Method in interface org.jgroups.raft.blocks.RaftCounter: Returns an instance of a counter with the given options
withOptions(Options) - Method in interface org.jgroups.raft.blocks.RaftSyncCounter
write(long) - Method in class org.jgroups.raft.filelog.FileStorage
write(long, LogEntries) - Method in class org.jgroups.raft.filelog.LogEntryStorage
writeContentTo(DataOutput) - Method in class org.jgroups.raft.blocks.CounterService
writeContentTo(DataOutput) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
writeContentTo(DataOutput) - Method in interface org.jgroups.raft.StateMachine: Writes the contents of the state machine to an output stream.
writeContentTo(DataOutput) - Method in class org.jgroups.raft.util.CounterStateMachine
writeContentTo(DataOutput) - Method in class org.jgroups.raft.util.ReplStateMachine
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.AppendEntriesRequest
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.AppendEntriesResponse
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.AppendResult
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.election.LeaderElected
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.election.PreVoteResponse
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.election.VoteResponse
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.InstallSnapshotRequest
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.InternalCommand
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.LogEntries
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.LogEntry
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.PersistentState
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.RaftHeader
writeTo(DataOutput) - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
writeTo(DataOutput) - Method in class org.jgroups.raft.Options
writeVarToStream(String, Properties, OutputStream) - Static method in class org.jgroups.raft.util.PropsToAsciidoc

_

_add(String, long) - Method in class org.jgroups.raft.blocks.CounterService
_addServer(String) - Method in class org.jgroups.protocols.raft.RAFT
_analyze(String) - Method in class org.jgroups.raft.util.AnalyzeLog
_compareAndSwap(String, long, long) - Method in class org.jgroups.raft.blocks.CounterService
_create(String, long) - Method in class org.jgroups.raft.blocks.CounterService
_delete(String) - Method in class org.jgroups.raft.blocks.CounterService
_get(String) - Method in class org.jgroups.raft.blocks.CounterService
_log_use_fsync - Variable in class org.jgroups.protocols.raft.RAFT
_max_log_cache_size - Variable in class org.jgroups.protocols.raft.RAFT
_removeServer(String) - Method in class org.jgroups.protocols.raft.RAFT
_set(String, long) - Method in class org.jgroups.raft.blocks.CounterService
_update(String, CounterFunction<T>) - Method in class org.jgroups.raft.blocks.CounterService

A B C D E F G H I K L M N O P R S T U V W _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form