Index

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(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 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

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.
Use RaftTestUtils.deleteRaftLog(RAFT) instead.
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 headSequence to indexExclusive.
At the end of this operation headSequence is equals to indexExclusive.
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
 
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 Log implementation 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 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
 
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 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.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 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
 
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
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 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.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
 
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