Index
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(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
- 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.
- 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
- 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
- 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
RaftAsyncCounterinstance 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
- bind_addr - Variable in class org.jgroups.protocols.raft.CLIENT
- 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.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.util.ArrayRingBuffer
- clear() - Method in class org.jgroups.raft.util.LogCache
- clearLogCache() - Method in class org.jgroups.protocols.raft.RAFT
- 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
- 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.util.LogCache
- 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
- 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
- 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
- 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.InstallSnapshotRequest
- create() - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
- 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
- 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)
- curr_log_size - Variable in class org.jgroups.protocols.raft.RAFT
- curr_term - Variable in class org.jgroups.protocols.raft.RaftHeader
- 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.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.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.
- 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.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.
- disableLogCache() - Method in class org.jgroups.protocols.raft.RAFT
- down(Event) - Method in class org.jgroups.protocols.raft.NO_DUPES
- down(Event) - Method in class org.jgroups.protocols.raft.RAFT
- 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
headSequencetoindexExclusive.
At the end of this operationheadSequenceis equals toindexExclusive. - dropTailTo(long) - Method in class org.jgroups.raft.util.ArrayRingBuffer
-
Remove all elements from
tailSequenceback toindexInclusive.
At the end of this operationtailSequenceis equals toindexInclusive. - dropTailToHead() - Method in class org.jgroups.raft.util.ArrayRingBuffer
- 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(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 - 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
- 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
- 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
Logimplementation stored in a file. - FileBasedLog() - Constructor for class org.jgroups.protocols.raft.FileBasedLog
- 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
- 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.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) - Method in interface org.jgroups.raft.Settable
-
Synchronous get operation without time bound.
- 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(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 - Static variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
- get_req - Enum constant in enum org.jgroups.protocols.raft.CLIENT.RequestType
- 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.RaftHandle
- getAsync(byte[], int, int, Options) - Method in interface org.jgroups.raft.Settable
-
Asynchronous get operation that returns immediately without blocking.
- getBindAddress() - Method in class org.jgroups.protocols.raft.CLIENT
- getDescriptions(Class<?>, Map<String, String>, String, boolean) - Static method in class org.jgroups.raft.util.PropsToAsciidoc
- 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
- getHeadSequence() - Method in class org.jgroups.raft.util.ArrayRingBuffer
- getIdleTime() - Method in class org.jgroups.protocols.raft.CLIENT
- 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
- 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.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
- 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
- getTailSequence() - Method in class org.jgroups.raft.util.ArrayRingBuffer
- gms_id - Static variable in class org.jgroups.protocols.raft.NO_DUPES
H
- 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.ELECTION2
- handleUpRequest(Message, RaftHeader) - Method in class org.jgroups.protocols.raft.RAFT
- 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
- hashCode() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
- hashCode() - Method in class org.jgroups.raft.Options
- hitRatio() - Method in class org.jgroups.raft.util.LogCache
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
- 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.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(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
Logimplementation 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
- 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
- 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
- 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
- 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
- isPreVoteThreadRunning() - Method in class org.jgroups.protocols.raft.ELECTION2
- 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
- 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
- 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 byLog.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.InstallSnapshotRequest
- leader() - Method in class org.jgroups.protocols.raft.RAFT
- 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
- 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
- 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
Logfacade. - 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
LogEntryelements, 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
- 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.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
- lost - Enum constant in enum org.jgroups.raft.util.Utils.Majority
M
- 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
- min_threads - Variable in class org.jgroups.protocols.raft.CLIENT
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
- 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
- numAccesses() - Method in class org.jgroups.raft.util.LogCache
- 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
- 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.raft - module org.jgroups.raft
- org.jgroups.raft - package org.jgroups.raft
- org.jgroups.raft.blocks - package org.jgroups.raft.blocks
- org.jgroups.raft.util - package org.jgroups.raft.util
- output - Variable in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
P
- parseCommaDelimitedProps(String) - Static method in class org.jgroups.protocols.raft.RAFT
- 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
- poll() - Method in class org.jgroups.raft.util.ArrayRingBuffer
-
Removes the element at head
- port - Variable in class org.jgroups.protocols.raft.CLIENT
- prev_log_index - Variable in class org.jgroups.protocols.raft.AppendEntriesRequest
- prev_log_term - Variable in class org.jgroups.protocols.raft.AppendEntriesRequest
- 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
- 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
- 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 - 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.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() - Method in class org.jgroups.protocols.raft.RaftImpl
- raft() - Method in class org.jgroups.raft.RaftHandle
- 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!
- 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
- RaftSyncCounter - Interface in org.jgroups.raft.blocks
-
TODO!
- reached - Enum constant in enum org.jgroups.raft.util.Utils.Majority
- 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.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
- 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
- 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.util.LogCache
- 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(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 - 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
- removeNotificationListener(ReplicatedStateMachine.Notification<K, V>) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
- 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 - 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.util.RequestTable
- RequestTable<T> - Class in org.jgroups.raft.util
-
Keeps track of
AppendEntriesRequestmessages 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.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
- ROOT_PACKAGE - Static variable in class org.jgroups.raft.util.PropsToAsciidoc
- 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
S
- s - Variable in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
- send(DataOutput, CLIENT.RequestType, int, byte[], int, int) - Method in class org.jgroups.protocols.raft.CLIENT.RequestHandler
- 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
- 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
- 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.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
- 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, 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.RaftHandle
- setAsync(byte[], int, int, Options) - Method in interface org.jgroups.raft.Settable
-
Asynchronous set, returns immediately with a CompletableFuture.
- setBindAddress(InetAddress) - Method in class org.jgroups.protocols.raft.CLIENT
- setChannel(JChannel) - Method in class org.jgroups.raft.blocks.CounterService
- setIdleTime(long) - Method in class org.jgroups.protocols.raft.CLIENT
- 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
- 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.
- 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.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.RaftHandle
- 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
- start() - Method in class org.jgroups.protocols.raft.CLIENT
- start() - Method in class org.jgroups.protocols.raft.RAFT
- 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.RAFT
- 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
- 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
- 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.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.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.Options
- 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
- 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.RAFT
- up(Event) - Method in class org.jgroups.protocols.raft.REDIRECT
- 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(MessageBatch) - Method in class org.jgroups.protocols.raft.CLIENT
- 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.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.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.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.util.Utils.Majority
-
Returns an array containing the constants of this enum type, in the order they are declared.
- 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.
- 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.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
- votes - Variable in class org.jgroups.raft.util.RequestTable.Entry
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
- 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.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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
RaftTestUtils.deleteRaftLog(RAFT)instead.