Index

A B C D E F G H I J 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
 
acceptor - Variable in class org.jgroups.protocols.raft.CLIENT
 
activeTransferChunksInFlight() - Method in class org.jgroups.protocols.raft.RAFT
 
activeTransferChunksReceived() - Method in class org.jgroups.protocols.raft.RAFT
 
activeTransferHighestRequested() - Method in class org.jgroups.protocols.raft.RAFT
 
activeTransferMissingChunks() - Method in class org.jgroups.protocols.raft.RAFT
 
activeTransferTotalChunks() - Method in class org.jgroups.protocols.raft.RAFT
 
add(long, T, Supplier) - Method in class org.jgroups.raft.util.RequestTable
Adds a response to the response set.
add(Address, RaftNode) - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Add a new member to the cluster.
add(Address, RaftNode) - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
 
add(Address, RaftNode) - Method in class org.jgroups.raft.testfwk.RaftCluster
 
add(BaseRequest) - Method in class org.jgroups.protocols.raft.RAFT
 
add(LogEntry...) - Method in class org.jgroups.protocols.raft.LogEntries
 
add(T) - Method in class org.jgroups.raft.util.ArrayRingBuffer
 
add(T, Supplier) - Method in class org.jgroups.raft.util.RequestTable.Entry
 
add_server - Enum constant in enum class org.jgroups.protocols.raft.CLIENT.RequestType
 
ADD_SERVER - Enum constant in enum class org.jgroups.protocols.raft.REDIRECT.RequestType
 
add_server_future - Variable in class org.jgroups.protocols.raft.RAFT
 
addAndGet - Enum constant in enum class org.jgroups.raft.blocks.CounterService.Command
 
addAndGet(long) - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
 
addCommandInterceptor(Predicate) - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Intercept messages before sending.
additions - Variable in class org.jgroups.raft.util.CounterStateMachine
 
additions() - Method in class org.jgroups.raft.util.CounterStateMachine
 
addNode(String) - Method in interface org.jgroups.raft.JGroupsRaftAdministration
Adds a new voting member to the Raft cluster.
addNotificationListener(ReplicatedStateMachine.Notification) - 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 class 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, long) - Method in class org.jgroups.raft.util.CommitTable
 
administration() - Method in interface org.jgroups.raft.JGroupsRaft
Administrative interface to manage the cluster.
Administration - Section in interface org.jgroups.raft.JGroupsRaft
 
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
 
and() - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
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
Appends entries starting at the given index and advances Log.lastAppended() accordingly.
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 Class in org.jgroups.protocols.raft
 
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
////////////////////////////////////// StateMachine callbacks /////////////////////////////////////
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(Consumer) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Apply the function to this builder.
apply(Consumer) - Method in class org.jgroups.raft.configuration.RuntimeProperties.Builder
 
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
 
asMap() - Method in interface org.jgroups.raft.configuration.RuntimeProperties
Get a copy of these configuration properties as a Properties object.
asProperties() - Method in interface org.jgroups.raft.configuration.RuntimeProperties
Get a copy of these configuration properties as a Properties object.
assertInvariant() - Method in class org.jgroups.raft.util.CommitTable.Entry
 
assertNoBlockedMessages() - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor
Helper to assert there is no more blocked messages.
assertNumberOfBlockedMessages(int) - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor
Helper to assert an expected number of blocked messages.
async - Variable in class org.jgroups.raft.testfwk.MockRaftCluster
 
async() - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
 
async() - Method in interface org.jgroups.raft.blocks.RaftAsyncCounter
 
async() - Method in interface org.jgroups.raft.blocks.RaftCounter
 
async() - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Check whether the cluster is in asynchronous mode.
async(boolean) - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Update the cluster mode between synchronous and asynchronous.
asyncAddAndGet(AsciiString, long, Options) - Method in class org.jgroups.raft.blocks.CounterService
 
asyncCompareAndSwap(AsciiString, long, long, Options) - Method in class org.jgroups.raft.blocks.CounterService
 
asyncCounter(String) - Method in class org.jgroups.raft.blocks.CounterService
Returns an RaftAsyncCounter instance of the counter.
AsyncCounterImpl - Class in org.jgroups.raft.blocks
RAFT Implementation of AsyncCounter.
AsyncCounterImpl(CounterService, String) - Constructor for class org.jgroups.raft.blocks.AsyncCounterImpl
 
asyncGet(AsciiString) - Method in class org.jgroups.raft.blocks.CounterService
 
asyncSet(AsciiString, long) - Method in class org.jgroups.raft.blocks.CounterService
 
AsyncSnapshot - Interface in org.jgroups.raft
Optional interface for state machines that support non-blocking snapshot creation.
asyncUpdate(AsciiString, CounterFunction, Options) - Method in class org.jgroups.raft.blocks.CounterService
 
Availability Before Start - Section in interface org.jgroups.raft.JGroupsRaftHealthCheck
 
availableCapacityWithoutResizing() - Method in class org.jgroups.raft.util.ArrayRingBuffer
 
avg_append_entries_batch_size - Variable in class org.jgroups.protocols.raft.RAFT
 
avgChunkIntervalNanos() - Method in class org.jgroups.protocols.raft.RAFT
 

B

Backward Compatibility Considerations - Section in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
Basic Usage - Section in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
bind_addr - Variable in class org.jgroups.protocols.raft.CLIENT
 
BlockingMessageInterceptor - Class in org.jgroups.raft.testfwk
Blocks while handling a message.
BlockingMessageInterceptor(Predicate) - Constructor for class org.jgroups.raft.testfwk.BlockingMessageInterceptor
 
blockMessage(Message) - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor
Blocks the invoking thread while sending the given message.
blockMessage(Message, boolean, Runnable) - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor
Blocks or delay the sending of the given message.
BUF - Static variable in class org.jgroups.protocols.raft.CLIENT
 
Buffer Ownership & Determinism - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Buffer Ownership & Determinism - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Buffer Ownership & Determinism - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Buffer Ownership & Determinism - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Buffer Ownership & Determinism - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Buffer Ownership & Determinism - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Buffer Ownership & Determinism - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Buffer Ownership & Determinism - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Buffer Ownership & Determinism - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Buffer Ownership & Determinism - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
build() - Method in class org.jgroups.raft.command.JGroupsRaftCommandOptions.ReadBuilder
Builds the read command options.
build() - Method in class org.jgroups.raft.command.JGroupsRaftCommandOptions.WriteBuilder
Builds the write command options.
build() - Method in class org.jgroups.raft.configuration.Property.Builder
 
build() - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
build() - Method in class org.jgroups.raft.configuration.RuntimeProperties.Builder
 
build() - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Build and return the immutable configuration.
build() - Method in class org.jgroups.raft.JGroupsRaft.Builder
Validates the builder and creates a new JGroupsRaft instance.
build() - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository.Builder
 
build(RAFT) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
builder(Supplier) - Static method in class org.jgroups.raft.util.ReadOnlyRequestRepository
 
builder(T, Class) - Static method in interface org.jgroups.raft.JGroupsRaft
Creates a new builder to configure the JGroupsRaft instance.
Byte Arrays - Section in interface org.jgroups.raft.serialization.SerializationContextRead
 
Byte Arrays - Section in interface org.jgroups.raft.serialization.SerializationContextWrite
 

C

cacheSize() - Method in interface org.jgroups.protocols.raft.LogCacheControl
Returns the current number of entries in the cache.
cacheSize() - Method in class org.jgroups.raft.util.LogCache
 
Cancellation - Section in org.jgroups.raft.SnapshotHandle.writeTo(DataOutput)
 
canHandleRequests() - Method in class org.jgroups.protocols.raft.RAFT
 
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
 
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
 
ClassUtil - Class in org.jgroups.raft.util
 
clear() - Method in interface org.jgroups.protocols.raft.LogCacheControl
Evicts all cached entries without disabling the cache.
clear() - Method in class org.jgroups.protocols.raft.LogEntries
 
clear() - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Remove all members from the cluster.
clear() - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
 
clear() - Method in class org.jgroups.raft.testfwk.RaftCluster
 
clear() - Method in class org.jgroups.raft.util.ArrayRingBuffer
 
clear() - Method in class org.jgroups.raft.util.LogCache
 
clearDroppedTraffic() - Method in class org.jgroups.raft.testfwk.RaftCluster
 
clearDroppedTrafficTo(Address) - Method in class org.jgroups.raft.testfwk.RaftCluster
 
clearLogCache() - Method in class org.jgroups.protocols.raft.RAFT
 
CLIENT - 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 Class 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.testfwk.RaftNode
 
close() - Method in class org.jgroups.raft.util.LogCache
 
cluster - Variable in class org.jgroups.raft.testfwk.RaftNode
 
Cluster Health - Section in interface org.jgroups.raft.JGroupsRaftHealthCheck
 
command - Variable in class org.jgroups.protocols.raft.LogEntry
 
command() - Method in class org.jgroups.protocols.raft.LogEntry
 
Command Submission - Section in interface org.jgroups.raft.JGroupsRaft
 
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(OutputStream) - Method in interface org.jgroups.protocols.raft.StagedSnapshotCapability
Atomically installs a previously staged snapshot as the active snapshot.
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_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 interface org.jgroups.raft.JGroupsRaftState
Returns the index of the highest log entry known to be committed.
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
Persists the commit index.
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, 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
 
Common Causes - Section in exception class org.jgroups.raft.exceptions.JGroupsRaftSerializationException
 
compareAndSwap - Enum constant in enum class 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
 
configureRaft() - Method in class org.jgroups.raft.JGroupsRaft.Builder
Configures the underlying RAFT protocol.
Consistency Contract - Section in interface org.jgroups.raft.AsyncSnapshot
 
Consistency Guarantee - Section in org.jgroups.raft.AsyncSnapshot.prepareSnapshot()
 
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, String) - Static method in class org.jgroups.raft.util.PropsToAsciidoc
 
copy(Reader, Writer) - Static method in class org.jgroups.raft.util.PropsToAsciidoc
 
copy(RuntimeProperties) - Static method in interface org.jgroups.raft.configuration.RuntimeProperties
Create a new configuration builder that starts with a copy of the supplied configuration.
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 Class 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 class 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() - Static method in interface org.jgroups.raft.configuration.RuntimeProperties
Create a new configuration builder.
create(boolean) - Static method in class org.jgroups.raft.Options
 
create(boolean) - Static method in interface org.jgroups.raft.util.TimeService
Creates a TimeService instance.
create(long, T, CompletableFuture, Supplier) - Method in class org.jgroups.raft.util.RequestTable
 
create(long, T, CompletableFuture, Supplier, Options) - Method in class org.jgroups.raft.util.RequestTable
 
create(String) - Static method in class org.jgroups.raft.configuration.Property
 
create(LogEntry...) - Static method in class org.jgroups.protocols.raft.LogEntries
 
createAsciidocTable(List, 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/jgroups-extras/jgroups-raft/issues/31)
createThreadPool(long) - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Create the Executor to submit tasks during asynchronous mode.
curr_log_size - Variable in class org.jgroups.protocols.raft.RAFT
 
curr_term - Variable in class org.jgroups.protocols.raft.RaftHeader
 
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 Raft 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
Persists the current Raft 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
 
defaultValue() - Method in class org.jgroups.raft.configuration.Property
Get the default value of the field.
defaultValueAsString() - Method in class org.jgroups.raft.configuration.Property
Get the string representation of the default value of the field.
DEGRADED - Enum constant in enum class org.jgroups.raft.JGroupsRaftHealthCheck.ClusterHealth
A leader exists and a majority of voting members are active, but some are missing.
Delegation - Section in interface org.jgroups.protocols.raft.Log
 
delete - Enum constant in enum class org.jgroups.raft.blocks.CounterService.Command
 
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
Deletes all entries at and after 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.
deleteRaftLog(RAFT) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils
Deletes all the replicated data and internal state for the given RAFT instance.
deliverAsync(RaftNode, Message) - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Asynchronously sends a message up the node stack.
description() - Method in interface org.jgroups.protocols.raft.LogCacheControl
Returns a human-readable summary of the cache and its underlying log.
description() - Method in class org.jgroups.raft.configuration.Property
Get the description of the field.
description() - Method in class org.jgroups.raft.util.LogCache
 
destroy() - Method in class org.jgroups.protocols.raft.CLIENT
 
destroy() - Method in class org.jgroups.protocols.raft.Leader
 
destroy() - Method in class org.jgroups.protocols.raft.RaftImpl
Called before getting destroyed (on a role change)
destroy() - Method in class org.jgroups.raft.testfwk.RaftNode
 
destroy() - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository
Invokes the registered destroyer with all pending requests.
destroy(Throwable) - Method in class org.jgroups.raft.util.RequestTable
Completes all uncommitted requests with the provided exception.
determineLeader(Address) - Method in class org.jgroups.protocols.raft.ELECTION
 
determineLeader(Address) - Method in class org.jgroups.protocols.raft.ELECTION2
 
Diagnosing Bottlenecks - Section in interface org.jgroups.raft.metrics.PerformanceMetrics
 
disable() - Method in interface org.jgroups.protocols.raft.LogCacheControl
Disables caching.
disable() - Method in class org.jgroups.raft.util.LogCache
 
disabled() - Static method in interface org.jgroups.raft.JGroupsRaftMetrics
 
disabled() - Static method in interface org.jgroups.raft.metrics.LatencyMetrics
 
disableLogCache() - Method in class org.jgroups.protocols.raft.RAFT
 
displayName() - Method in class org.jgroups.raft.configuration.Property
Get the display name of the field.
down(Event) - Method in class org.jgroups.protocols.raft.ELECTION
 
down(Event) - Method in class org.jgroups.protocols.raft.ELECTION2
 
down(Event) - Method in class org.jgroups.protocols.raft.NO_DUPES
 
down(Event) - Method in class org.jgroups.protocols.raft.RAFT
 
down(Event) - Method in class org.jgroups.raft.testfwk.RaftNode
 
down(Message) - Method in class org.jgroups.raft.testfwk.RaftNode
 
drainRatio() - Method in class org.jgroups.protocols.raft.RAFT
 
dropHeadUntil(long) - Method in class org.jgroups.raft.util.ArrayRingBuffer
Remove all elements from headSequence to indexExclusive.
At the end of this operation headSequence is equals to indexExclusive.
dropped_members - Variable in class org.jgroups.raft.testfwk.RaftCluster
 
dropTailTo(long) - Method in class org.jgroups.raft.util.ArrayRingBuffer
Remove all elements from tailSequence back to indexInclusive.
At the end of this operation tailSequence is equals to indexInclusive.
dropTailToHead() - Method in class org.jgroups.raft.util.ArrayRingBuffer
 
dropTraffic() - Method in class org.jgroups.raft.testfwk.RaftCluster
 
dropTrafficTo(Address) - Method in class org.jgroups.raft.testfwk.RaftCluster
 
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.
Durability and failure - Section in interface org.jgroups.protocols.raft.Log
 
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).
Dynamic Membership - Section in interface org.jgroups.raft.JGroupsRaftAdministration
 

E

election - Variable in class org.jgroups.raft.testfwk.RaftNode
 
election() - Method in class org.jgroups.raft.testfwk.RaftNode
 
election(JChannel) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils
Retrieves the BaseElection protocol from the provided JChannel.
ELECTION - Class in org.jgroups.protocols.raft
The default leader election algorithm.
ELECTION() - Constructor for class org.jgroups.protocols.raft.ELECTION
 
ELECTION_ID - Static variable in class org.jgroups.protocols.raft.ELECTION
 
ELECTION_ID - Static variable in class org.jgroups.protocols.raft.ELECTION2
 
ELECTION2 - Class in org.jgroups.protocols.raft
A leader election protocol.
ELECTION2() - Constructor for class org.jgroups.protocols.raft.ELECTION2
 
electionEnd() - Method in class org.jgroups.protocols.raft.ELECTION
 
electionEnd() - Method in class org.jgroups.protocols.raft.ELECTION2
 
electionLatency() - Method in class org.jgroups.protocols.raft.ELECTION
 
electionLatency() - Method in class org.jgroups.protocols.raft.ELECTION2
 
electionMeanLatency() - Method in class org.jgroups.protocols.raft.ELECTION
 
electionMeanLatency() - Method in class org.jgroups.protocols.raft.ELECTION2
 
ElectionMetrics - Interface in org.jgroups.raft.metrics
Metrics about leader election and leadership stability.
electionStart() - Method in class org.jgroups.protocols.raft.ELECTION
 
electionStart() - Method in class org.jgroups.protocols.raft.ELECTION2
 
enable(int) - Method in interface org.jgroups.protocols.raft.LogCacheControl
Enables caching with the given maximum number of entries.
enable(int) - Method in class org.jgroups.raft.util.LogCache
 
enableLogCache() - Method in class org.jgroups.protocols.raft.RAFT
 
Enabling Metrics - Section in interface org.jgroups.raft.JGroupsRaftMetrics
 
entries - Variable in class org.jgroups.protocols.raft.LogEntries
 
Entry(long) - Constructor for class org.jgroups.raft.util.CommitTable.Entry
 
Entry(CompletableFuture, Options) - Constructor for class org.jgroups.raft.util.RequestTable.Entry
 
entry_term - Variable in class org.jgroups.protocols.raft.AppendEntriesRequest
 
entryTerm(long) - Method in class org.jgroups.protocols.raft.RAFT
 
equals(Object) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
 
equals(Object) - Method in class org.jgroups.raft.command.JGroupsRaftReadCommandOptions.ReadImpl
 
equals(Object) - Method in class org.jgroups.raft.command.JGroupsRaftWriteCommandOptions.WriteImpl
 
equals(Object) - Method in class org.jgroups.raft.Options
 
eventually(BooleanSupplier, long, TimeUnit) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils
Verify that in the given time constraints, the expression returns true.
eventuallyIsRaftLeader(JChannel, long) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils
Checks that given the time constraints, eventually RaftTestUtils.isRaftLeader(JChannel) is true.
Example - Section in org.jgroups.raft.JGroupsRaftStateMachine.retiredReads()
 
Example - Section in org.jgroups.raft.JGroupsRaftStateMachine.retiredWrites()
 
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.protocols.raft.RAFT
 
extractRaftId(Address) - Static method in class org.jgroups.raft.util.Utils
 
extractRaftId(ExtendedUUID) - Static method in class org.jgroups.protocols.raft.RAFT
 

F

FAIL_CONFLICTING_PREV_TERM - Enum constant in enum class org.jgroups.protocols.raft.AppendResult.Result
 
FAIL_ENTRY_NOT_FOUND - Enum constant in enum class org.jgroups.protocols.raft.AppendResult.Result
 
FAILURE - Enum constant in enum class org.jgroups.raft.JGroupsRaftHealthCheck.ClusterHealth
No leader is elected, or active voting members are below the majority threshold.
Failure Handling - Section in interface org.jgroups.raft.StateMachine
 
Failures - Section in org.jgroups.raft.AsyncSnapshot.prepareSnapshot()
 
Failures - Section in org.jgroups.raft.AsyncSnapshot.readContentFrom(DataInput)
 
Failures - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Failures - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Failures - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Failures - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Failures - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Failures - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Failures - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Failures - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Failures - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Failures - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
FileBasedLog - Class in org.jgroups.protocols.raft
A Log implementation stored in a file.
FileBasedLog() - Constructor for class org.jgroups.protocols.raft.FileBasedLog
 
find(Class) - Method in class org.jgroups.raft.testfwk.RaftNode
 
findCapability(Class) - Method in class org.jgroups.protocols.raft.FileBasedLog
 
findCapability(Class) - Method in interface org.jgroups.protocols.raft.Log
Looks up an optional capability provided by this log or any log in the delegation chain.
findCapability(Class) - Method in class org.jgroups.raft.util.LogCache
 
findProtocol(Class, Protocol, boolean) - Static method in class org.jgroups.protocols.raft.RAFT
 
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 entry in the log.
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 class org.jgroups.protocols.raft.Role
 
Follower(RAFT) - Constructor for class org.jgroups.protocols.raft.Follower
 
FOLLOWER - Enum constant in enum class org.jgroups.raft.JGroupsRaftRole
The follower role in the Raft consensus algorithm.
forceLeaderElection() - Method in interface org.jgroups.raft.JGroupsRaftAdministration
Forces a new leader election, excluding the current leader from candidacy.
forEach(BiConsumer) - Method in interface org.jgroups.raft.configuration.RuntimeProperties
Call the supplied function for each of the fields.
forEach(BiConsumer) - Method in class org.jgroups.raft.util.CommitTable
Applies a function to all elements of the commit table
forEach(ObjLongConsumer) - Method in class org.jgroups.raft.util.ArrayRingBuffer
 
forEach(ObjLongConsumer) - Method in class org.jgroups.protocols.raft.FileBasedLog
 
forEach(ObjLongConsumer) - Method in class org.jgroups.protocols.raft.InMemoryLog
 
forEach(ObjLongConsumer) - Method in interface org.jgroups.protocols.raft.Log
Applies the function to every entry in the log.
forEach(ObjLongConsumer) - Method in class org.jgroups.raft.util.LogCache
 
forEach(ObjLongConsumer, long, long) - Method in class org.jgroups.protocols.raft.FileBasedLog
 
forEach(ObjLongConsumer, long, long) - Method in class org.jgroups.protocols.raft.InMemoryLog
 
forEach(ObjLongConsumer, long, long) - Method in interface org.jgroups.protocols.raft.Log
Applies the function to each entry in the range [max(start_index, firstAppended) ..
forEach(ObjLongConsumer, long, long) - Method in class org.jgroups.raft.util.LogCache
 
Forward Compatibility - Section in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
from(Map) - Static method in interface org.jgroups.raft.configuration.RuntimeProperties
Obtain a configuration instance by copying the supplied map of string keys and object values.
from(Map, Function) - Static method in interface org.jgroups.raft.configuration.RuntimeProperties
Obtain a configuration instance by copying the supplied map of string keys and object values.
from(Properties) - Static method in interface org.jgroups.raft.configuration.RuntimeProperties
Obtain a configuration instance by copying the supplied Properties object.

G

get - Enum constant in enum class 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
Returns the entry at the given 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 class org.jgroups.protocols.raft.CLIENT.RequestType
 
getActiveNodes() - Method in class org.jgroups.raft.JGroupsRaftMetrics.DisabledJGroupsRaftMetrics
 
getActiveNodes() - Method in interface org.jgroups.raft.JGroupsRaftMetrics
The number of nodes currently reachable in the cluster view.
getAddress() - Method in class org.jgroups.raft.testfwk.RaftNode
 
getAsync(byte[], int, int) - Method in interface org.jgroups.raft.Settable
 
getAsync(byte[], int, int, Options) - Method in class org.jgroups.protocols.raft.RAFT
 
getAsync(byte[], int, int, Options) - Method in class org.jgroups.protocols.raft.REDIRECT
 
getAsync(byte[], int, int, Options) - Method in class org.jgroups.raft.RaftHandle
 
getAsync(byte[], int, int, Options) - Method in interface org.jgroups.raft.Settable
Asynchronous get operation that returns immediately without blocking.
getAsync(byte[], int, int, Options) - Method in class org.jgroups.raft.testfwk.RaftNode
 
getAvgLatency() - Method in interface org.jgroups.raft.metrics.LatencyMetrics
The arithmetic mean of all recorded latency samples, in nanoseconds.
getBindAddress() - Method in class org.jgroups.protocols.raft.CLIENT
 
getBoolean(String, BooleanSupplier) - Method in interface org.jgroups.raft.configuration.RuntimeProperties
Get the boolean value associated with the given key, using the given supplier to obtain a default value if there is no such key-value pair.
getBoolean(Property) - Method in interface org.jgroups.raft.configuration.RuntimeProperties
Get the boolean value associated with the given field when that field has a default value.
getClusterHealth() - Method in interface org.jgroups.raft.JGroupsRaftHealthCheck
Overall cluster health from this node's perspective.
getCommitIndex() - Method in interface org.jgroups.raft.metrics.LogMetrics
The current commit index on this node.
getCommittedLogEntries() - Method in interface org.jgroups.raft.metrics.LogMetrics
The number of entries committed on this node.
getCurrentTerm() - Method in interface org.jgroups.raft.metrics.LogMetrics
The current Raft term as observed by this node.
getDescriptions(Class, Map, String, boolean) - Static method in class org.jgroups.raft.util.PropsToAsciidoc
 
getFailedSnapshotCreations() - Method in interface org.jgroups.raft.metrics.LogMetrics
The number of times snapshot creation failed on this node.
getFailedSnapshotInstallations() - Method in interface org.jgroups.raft.metrics.LogMetrics
The number of times snapshot installation failed on this node.
getFailedSnapshotTransfers() - Method in interface org.jgroups.raft.metrics.LogMetrics
The number of chunked snapshot transfers that started but failed before completion.
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
 
getLastSnapshotTransferDuration() - Method in interface org.jgroups.raft.metrics.LogMetrics
The duration of the last completed chunked snapshot transfer on this node.
getLeaderElectionLatency() - Method in interface org.jgroups.raft.metrics.PerformanceMetrics
Latency of leader elections.
getLeaderElectionTime() - Method in interface org.jgroups.raft.metrics.ElectionMetrics
The instant at which the last leader election started, as observed by this node.
getLeaderRaftId() - Method in interface org.jgroups.raft.metrics.ElectionMetrics
The Raft identifier of the current leader.
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
getLogSizeInBytes() - Method in interface org.jgroups.raft.metrics.LogMetrics
The physical storage size of the log, in bytes.
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
 
getMaxLatency() - Method in interface org.jgroups.raft.metrics.LatencyMetrics
The highest latency recorded across all samples, in nanoseconds.
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.
getP95Latency() - Method in interface org.jgroups.raft.metrics.LatencyMetrics
The 95th percentile latency, in nanoseconds.
getP99Latency() - Method in interface org.jgroups.raft.metrics.LatencyMetrics
The 99th percentile latency, in nanoseconds.
getPercentile(double) - Method in interface org.jgroups.raft.metrics.LatencyMetrics
The latency at a custom percentile, in nanoseconds.
getPort() - Method in class org.jgroups.protocols.raft.CLIENT
 
getProcessingLatency() - Method in interface org.jgroups.raft.metrics.PerformanceMetrics
Latency of the consensus process.
getReceiveBufferSize() - Method in class org.jgroups.protocols.raft.CLIENT
 
getRedirectLatency() - Method in interface org.jgroups.raft.metrics.PerformanceMetrics
Round-trip latency for requests forwarded from a non-leader node to the leader.
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
Returns the most recently stored snapshot.
getSnapshot() - Method in class org.jgroups.raft.util.LogCache
 
getSnapshotCount() - Method in interface org.jgroups.raft.metrics.LogMetrics
The number of snapshots this node has performed.
getSnapshotsReceived() - Method in interface org.jgroups.raft.metrics.LogMetrics
The number of snapshot-install messages received from the leader.
getString(String) - Method in interface org.jgroups.raft.configuration.RuntimeProperties
Get the string value associated with the given key.
getTailSequence() - Method in class org.jgroups.raft.util.ArrayRingBuffer
 
getTimeSinceLastLeaderChange() - Method in interface org.jgroups.raft.metrics.ElectionMetrics
The time elapsed since the last leader election ended.
getTotalLatency() - Method in interface org.jgroups.raft.metrics.PerformanceMetrics
End-to-end latency from request submission to response.
getTotalLogEntries() - Method in interface org.jgroups.raft.metrics.LogMetrics
The total number of entries currently in the log.
getTotalMeasurements() - Method in interface org.jgroups.raft.metrics.LatencyMetrics
The total number of latency samples recorded.
getTotalNodes() - Method in class org.jgroups.raft.JGroupsRaftMetrics.DisabledJGroupsRaftMetrics
 
getTotalNodes() - Method in interface org.jgroups.raft.JGroupsRaftMetrics
The total number of nodes configured in the cluster, excluding learners.
getUncommittedLogEntries() - Method in interface org.jgroups.raft.metrics.LogMetrics
The number of entries appended but not yet committed on this node.
getVotes() - Method in class org.jgroups.protocols.raft.ELECTION
 
getVotes() - Method in class org.jgroups.protocols.raft.ELECTION2
 
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[], 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, RaftHeader, Address) - Method in class org.jgroups.protocols.raft.Follower
 
handleInstallSnapshotRequest(Message, RaftHeader, Address) - Method in class org.jgroups.protocols.raft.RaftImpl
Called when a snapshot sent by the leader is received by a follower.
handleMessage(Message, RaftHeader) - Method in class org.jgroups.protocols.raft.ELECTION
 
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
 
handleView(View) - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Emit the view update to all cluster members.
handleView(View) - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
 
handleView(View) - Method in class org.jgroups.raft.testfwk.RaftCluster
 
handleView(View) - Method in class org.jgroups.raft.testfwk.RaftNode
 
Handling Strategy - Section in exception class org.jgroups.raft.exceptions.JGroupsRaftSerializationException
 
hashCode() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
 
hashCode() - Method in class org.jgroups.raft.command.JGroupsRaftReadCommandOptions.ReadImpl
 
hashCode() - Method in class org.jgroups.raft.command.JGroupsRaftWriteCommandOptions.WriteImpl
 
hashCode() - Method in class org.jgroups.raft.Options
 
healthCheck() - Method in interface org.jgroups.raft.JGroupsRaft
Health check utility to check the node health.
HEALTHY - Enum constant in enum class org.jgroups.raft.JGroupsRaftHealthCheck.ClusterHealth
A leader exists and all configured voting members are active.
hitRatio() - Method in interface org.jgroups.protocols.raft.LogCacheControl
Returns the fraction of cache lookups that were served from the cache.
hitRatio() - Method in class org.jgroups.raft.util.LogCache
 

I

id() - Method in interface org.jgroups.raft.JGroupsRaftState
Returns the identifier of the local node.
id() - Element in annotation interface org.jgroups.raft.StateMachineRead
Unique identifier for this read operation within the state machine definition.
id() - Element in annotation interface org.jgroups.raft.StateMachineWrite
Unique identifier for this write operation within the state machine definition.
idle_time - Variable in class org.jgroups.protocols.raft.CLIENT
 
ignoreReturnValue - Variable in class org.jgroups.raft.Options
 
ignoreReturnValue() - Method in interface org.jgroups.raft.command.JGroupsRaftCommandOptions
Whether to ignore the return value of the command execution.
ignoreReturnValue() - Method in class org.jgroups.raft.command.JGroupsRaftReadCommandOptions.ReadImpl
 
ignoreReturnValue() - Method in class org.jgroups.raft.command.JGroupsRaftWriteCommandOptions.WriteImpl
 
ignoreReturnValue() - Method in class org.jgroups.raft.Options
 
ignoreReturnValue(boolean) - Method in class org.jgroups.raft.command.JGroupsRaftCommandOptions.ReadBuilder
Sets whether to ignore the return value of the read operation.
ignoreReturnValue(boolean) - Method in class org.jgroups.raft.command.JGroupsRaftCommandOptions.WriteBuilder
Sets whether to ignore the return value of the write operation.
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.ELECTION
 
init() - Method in class org.jgroups.protocols.raft.ELECTION2
 
init() - Method in class org.jgroups.protocols.raft.Leader
 
init() - Method in class org.jgroups.protocols.raft.RAFT
 
init() - Method in class org.jgroups.protocols.raft.RaftImpl
Called right after instantiation
init() - Method in class org.jgroups.protocols.raft.REDIRECT
 
init() - Method in class org.jgroups.raft.testfwk.RaftNode
 
init(String, Map) - Method in class org.jgroups.protocols.raft.FileBasedLog
 
init(String, Map) - Method in class org.jgroups.protocols.raft.InMemoryLog
 
init(String, Map) - Method in interface org.jgroups.protocols.raft.Log
Initializes this log with the given identity and optional configuration.
init(String, Map) - Method in class org.jgroups.raft.util.LogCache
 
initialize() - Static method in class org.jgroups.raft.util.RaftClassConfigurator
 
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
 
Instantiation - Section in interface org.jgroups.raft.JGroupsRaft
 
interceptor - Variable in class org.jgroups.raft.testfwk.MockRaftCluster
 
internal - Variable in class org.jgroups.protocols.raft.LogEntry
 
internal() - Method in class org.jgroups.protocols.raft.LogEntry
 
internal(boolean) - Method in class org.jgroups.protocols.raft.LogEntry
 
internal_state - Variable in class org.jgroups.protocols.raft.RAFT
 
InternalCommand - Class in org.jgroups.protocols.raft
Internal command to be added to the log, e.g. adding or removing a server
InternalCommand() - Constructor for class org.jgroups.protocols.raft.InternalCommand
 
InternalCommand(InternalCommand.Type, String) - Constructor for class org.jgroups.protocols.raft.InternalCommand
 
InternalCommand.Type - Enum Class in org.jgroups.protocols.raft
 
Interpreting the Distribution - Section in interface org.jgroups.raft.metrics.LatencyMetrics
 
interval(long) - Method in class org.jgroups.raft.util.TimeService.DisabledTimeService
 
interval(long) - Method in interface org.jgroups.raft.util.TimeService
Computes the elapsed nanoseconds since a previously captured TimeService.nanos() value.
interval(long) - Method in class org.jgroups.raft.util.TimeService.SystemTimeService
 
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
 
isEquivalent(Class, Class) - Static method in class org.jgroups.raft.util.ClassUtil
Evaluates strict equivalence between two concrete classes, accounting for primitive wrappers.
isEquivalent(Class, Type) - Static method in class org.jgroups.raft.util.ClassUtil
Recursively evaluates strict equivalence between a concrete class and a generic type.
isLeader() - Method in class org.jgroups.protocols.raft.RAFT
 
isLeader() - Method in class org.jgroups.raft.RaftHandle
 
isMajorityAvailable() - Method in class org.jgroups.protocols.raft.ELECTION
 
isMajorityAvailable() - Method in class org.jgroups.protocols.raft.ELECTION2
 
isMajorityLost(Collection, Collection, int) - Static method in class org.jgroups.raft.util.Utils
 
isMajorityReached(Collection, Collection, int) - Static method in class org.jgroups.raft.util.Utils
 
isNodeLive() - Method in interface org.jgroups.raft.JGroupsRaftHealthCheck
Whether the node process is functional.
isNodeReady() - Method in interface org.jgroups.raft.JGroupsRaftHealthCheck
Whether the node can serve requests.
isPreVoteThreadRunning() - Method in class org.jgroups.protocols.raft.ELECTION2
 
isPrimitiveMatch(Class, Class) - Static method in class org.jgroups.raft.util.ClassUtil
Maps primitive classes to their corresponding wrapper classes.
isRaftLeader(JChannel) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils
Checks if the node is the current RAFT leader.
isRaftMember(String, Collection) - 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.REDIRECT.RedirectHeader
 
isViewCoordinator() - Method in class org.jgroups.protocols.raft.ELECTION
 
isViewCoordinator() - Method in class org.jgroups.protocols.raft.ELECTION2
 
isVotingThreadRunning() - Method in class org.jgroups.protocols.raft.ELECTION
 
isVotingThreadRunning() - Method in class org.jgroups.protocols.raft.ELECTION2
 
iterator() - Method in class org.jgroups.protocols.raft.LogEntries
 

J

javaClass() - Method in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
Returns the Java class this serializer handles.
JGroupsRaft<T> - Interface in org.jgroups.raft
Entry point for the JGroups Raft API.
JGroupsRaft.Builder<T> - Class in org.jgroups.raft
 
JGroupsRaft.JGroupsBuilderStep<R,B> - Interface in org.jgroups.raft
 
JGroupsRaftAdministration - Interface in org.jgroups.raft
Administrative operations for the Raft cluster.
JGroupsRaftCommandOptions - Interface in org.jgroups.raft.command
Customizes how commands behave during execution.
JGroupsRaftCommandOptions.ReadBuilder - Class in org.jgroups.raft.command
Builder for read command options.
JGroupsRaftCommandOptions.WriteBuilder - Class in org.jgroups.raft.command
Builder for write command options.
JGroupsRaftCustomMarshaller<T> - Interface in org.jgroups.raft.serialization
Custom serializer for user-defined types in JGroups Raft.
JGroupsRaftHealthCheck - Interface in org.jgroups.raft
Health monitoring for a Raft node.
JGroupsRaftHealthCheck.ClusterHealth - Enum Class in org.jgroups.raft
Coarse-grained cluster health status from a single node's perspective.
JGroupsRaftMetrics - Interface in org.jgroups.raft
Monitoring interface for a Raft node.
JGroupsRaftMetrics.DisabledJGroupsRaftMetrics - Class in org.jgroups.raft
 
JGroupsRaftReadCommandOptions - Interface in org.jgroups.raft.command
Command options for read operations.
JGroupsRaftReadCommandOptions.ReadImpl - Class in org.jgroups.raft.command
 
JGroupsRaftRole - Enum Class in org.jgroups.raft
Represents the role of a Raft node.
JGroupsRaftSerializationException - Exception Class in org.jgroups.raft.exceptions
Exception thrown when serialization or deserialization operations fail.
JGroupsRaftSerializationException(String, Throwable) - Constructor for exception class org.jgroups.raft.exceptions.JGroupsRaftSerializationException
 
JGroupsRaftState - Interface in org.jgroups.raft
Read-only view of the current Raft protocol state.
JGroupsRaftStateMachine - Annotation Interface in org.jgroups.raft
Marks a class as a Raft state machine.
JGroupsRaftWriteCommandOptions - Interface in org.jgroups.raft.command
Command options for write operations.
JGroupsRaftWriteCommandOptions.WriteImpl - Class in org.jgroups.raft.command
 
JRaftException - Exception Class in org.jgroups.raft.exceptions
Base unchecked exception for JGroups Raft.
JRaftException() - Constructor for exception class org.jgroups.raft.exceptions.JRaftException
 
JRaftException(String) - Constructor for exception class org.jgroups.raft.exceptions.JRaftException
 
JRaftException(String, Throwable) - Constructor for exception class org.jgroups.raft.exceptions.JRaftException
 
JRaftException(String, Throwable, boolean, boolean) - Constructor for exception class org.jgroups.raft.exceptions.JRaftException
 
JRaftException(Throwable) - Constructor for exception class org.jgroups.raft.exceptions.JRaftException
 

K

keys() - Method in interface org.jgroups.raft.configuration.RuntimeProperties
Get the set of keys in this configuration.
keys() - Method in class org.jgroups.raft.util.CommitTable
 

L

last_appended - Variable in class org.jgroups.protocols.raft.RAFT
 
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 appended entry.
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 interface org.jgroups.raft.JGroupsRaftState
Returns the index of the highest log entry applied to the state machine.
lastApplied() - Method in class org.jgroups.raft.RaftHandle
 
lastIncludedIndex() - Method in class org.jgroups.protocols.raft.InstallSnapshotRequest
 
lastIncludedTerm() - Method in class org.jgroups.protocols.raft.InstallSnapshotRequest
 
lastTerm() - Method in class org.jgroups.protocols.raft.RAFT
 
lastTransferDurationNanos() - Method in class org.jgroups.protocols.raft.RAFT
 
LatencyMetrics - Interface in org.jgroups.raft.metrics
Latency distribution for a specific operation category.
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.InstallSnapshotRequest
 
leader() - Method in class org.jgroups.protocols.raft.RAFT
 
leader() - Method in interface org.jgroups.raft.JGroupsRaftState
Returns the identifier of the current leader node.
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 class org.jgroups.protocols.raft.Role
 
Leader(RAFT) - Constructor for class org.jgroups.protocols.raft.Leader
 
LEADER - Enum constant in enum class org.jgroups.raft.JGroupsRaftRole
The leader role in the Raft consensus algorithm.
leader_commit - Variable in class org.jgroups.protocols.raft.AppendEntriesRequest
 
LEADER_ELECTED - Static variable in class org.jgroups.protocols.raft.ELECTION
 
LEADER_ELECTED - Static variable in class org.jgroups.protocols.raft.ELECTION2
 
leader_lost - Enum constant in enum class org.jgroups.raft.util.Utils.Majority
 
Leader Election - Section in interface org.jgroups.raft.JGroupsRaftAdministration
 
leaderMetrics() - Method in class org.jgroups.raft.JGroupsRaftMetrics.DisabledJGroupsRaftMetrics
 
leaderMetrics() - Method in interface org.jgroups.raft.JGroupsRaftMetrics
Metrics about the current leader and election timing.
leaderRaftId() - Method in class org.jgroups.protocols.raft.RAFT
 
Learner - Class in org.jgroups.protocols.raft
Implements the behavior of a learner node.
Learner - Enum constant in enum class org.jgroups.protocols.raft.Role
 
Learner(RAFT) - Constructor for class org.jgroups.protocols.raft.Learner
 
LEARNER - Enum constant in enum class org.jgroups.raft.JGroupsRaftRole
The learner role as described in Raft optimizations.
length - Variable in class org.jgroups.protocols.raft.LogEntry
 
length() - Method in class org.jgroups.protocols.raft.LogEntry
 
Lifecycle - Section in interface org.jgroups.protocols.raft.Log
 
Lifecycle - Section in interface org.jgroups.raft.JGroupsRaft
 
Lifecycle - Section in interface org.jgroups.raft.SnapshotHandle
 
Lifecycle in the Raft Protocol - Section in interface org.jgroups.raft.StateMachine
 
linearizable() - Method in interface org.jgroups.raft.command.JGroupsRaftReadCommandOptions
Whether this read operation should be linearizable.
linearizable() - Method in class org.jgroups.raft.command.JGroupsRaftReadCommandOptions.ReadImpl
 
linearizable(boolean) - Method in class org.jgroups.raft.command.JGroupsRaftCommandOptions.ReadBuilder
Sets whether the read operation should be linearizable.
listeners - Variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
 
listenRoleChanges(BiConsumer) - Method in interface org.jgroups.raft.JGroupsRaft
Registers a listener to be notified when the role of the node changes.
Liveness and Readiness Probes - Section in interface org.jgroups.raft.JGroupsRaftHealthCheck
 
load(File) - Static method in interface org.jgroups.raft.configuration.RuntimeProperties
Obtain a configuration instance by loading the Properties from the supplied file.
load(InputStream) - Static method in interface org.jgroups.raft.configuration.RuntimeProperties
Obtain a configuration instance by loading the Properties from the supplied stream.
load(URL) - Static method in interface org.jgroups.raft.configuration.RuntimeProperties
Obtain a configuration instance by loading the Properties from the supplied URL.
localAddress() - Method in class org.jgroups.raft.testfwk.RaftNode
 
log() - Method in class org.jgroups.protocols.raft.RAFT
 
log() - Method in class org.jgroups.raft.RaftHandle
 
log(Log) - Method in class org.jgroups.protocols.raft.RAFT
 
Log - Interface in org.jgroups.protocols.raft
Durable storage for Raft consensus log entries, election metadata (term and vote), and state machine snapshots.
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_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
 
LogCacheControl - Interface in org.jgroups.protocols.raft
Controls the log entry cache that sits between the Raft protocol and the underlying persistent log.
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
 
LogCapability - Interface in org.jgroups.protocols.raft
Marker interface for optional capabilities that a Log implementation may provide.
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() - Method in class org.jgroups.protocols.raft.RAFT
 
logDir(String) - Method in class org.jgroups.protocols.raft.RAFT
 
logEntries(ObjLongConsumer) - Method in class org.jgroups.protocols.raft.RAFT
 
logEntries(ObjLongConsumer) - 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
 
Log Lifecycle - Section in interface org.jgroups.raft.metrics.LogMetrics
 
LogMetrics - Interface in org.jgroups.raft.metrics
Metrics about the Raft log state on this node.
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
 
lost - Enum constant in enum class 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_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 interface org.jgroups.protocols.raft.LogCacheControl
Returns the maximum number of entries the cache will retain.
maxSize() - Method in class org.jgroups.raft.util.LogCache
 
maxSize(int) - Method in interface org.jgroups.protocols.raft.LogCacheControl
Sets the maximum number of entries the cache will retain.
maxSize(int) - Method in class org.jgroups.raft.util.LogCache
 
members() - Method in class org.jgroups.protocols.raft.RAFT
 
members() - Method in interface org.jgroups.raft.JGroupsRaftAdministration
Returns the current set of voting members in the Raft cluster.
members(Collection) - Method in class org.jgroups.protocols.raft.RAFT
 
metrics() - Method in interface org.jgroups.raft.JGroupsRaft
Metrics related to the Raft algorithm and command execution.
METRICS_ENABLED - Static variable in interface org.jgroups.raft.JGroupsRaftMetrics
 
METRICS_PROPERTY_PREFIX - Static variable in interface org.jgroups.raft.JGroupsRaftMetrics
 
min_threads - Variable in class org.jgroups.protocols.raft.CLIENT
 
MINIMUM_TYPE_ID - Static variable in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
MockRaftCluster - Class in org.jgroups.raft.testfwk
Base class for the cluster implementations in the test framework.
MockRaftCluster() - Constructor for class org.jgroups.raft.testfwk.MockRaftCluster
 
move(Address, Map, Map) - Static method in class org.jgroups.raft.testfwk.RaftCluster
 
moveAll(Map, Map) - Static method in class org.jgroups.raft.testfwk.RaftCluster
 

N

name - Variable in class org.jgroups.protocols.raft.InMemoryLog
 
name - Variable in class org.jgroups.protocols.raft.InternalCommand
 
name() - Method in class org.jgroups.raft.configuration.Property
Get the name of the field.
nanos() - Method in class org.jgroups.raft.util.TimeService.DisabledTimeService
 
nanos() - Method in interface org.jgroups.raft.util.TimeService
Returns a monotonic nanosecond timestamp.
nanos() - Method in class org.jgroups.raft.util.TimeService.SystemTimeService
 
Nested Objects - Section in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
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 class 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
 
Node-Local Metrics - Section in interface org.jgroups.raft.JGroupsRaftMetrics
 
Node-Local Perspective - Section in interface org.jgroups.raft.metrics.ElectionMetrics
 
Node-Local Perspective - Section in interface org.jgroups.raft.metrics.LogMetrics
 
nodes - Variable in class org.jgroups.raft.testfwk.PartitionedRaftCluster
 
nodes - Variable in class org.jgroups.raft.testfwk.RaftCluster
 
non_matching_term - Variable in class org.jgroups.protocols.raft.AppendResult
Ignored if success == true.
NONE - Enum constant in enum class org.jgroups.raft.JGroupsRaftRole
Indicates no active role.
nonMatchingTerm() - Method in class org.jgroups.protocols.raft.AppendResult
 
noop - Enum constant in enum class org.jgroups.protocols.raft.InternalCommand.Type
 
NOT_RUNNING - Enum constant in enum class org.jgroups.raft.JGroupsRaftHealthCheck.ClusterHealth
The channel is disconnected or the node has not started.
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, byte[]) - Static method in class org.jgroups.protocols.raft.RAFT
 
notify(RequestTable.Entry, 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
 
now() - Method in class org.jgroups.raft.util.TimeService.DisabledTimeService
 
now() - Method in interface org.jgroups.raft.util.TimeService
Returns the current wall-clock time.
now() - Method in class org.jgroups.raft.util.TimeService.SystemTimeService
 
Null Handling - Section in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
Null Values - Section in interface org.jgroups.raft.serialization.SerializationContextRead
 
Null Values - Section in interface org.jgroups.raft.serialization.SerializationContextWrite
 
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_resends - Variable in class org.jgroups.protocols.raft.RAFT
 
num_successful_append_requests - Variable in class org.jgroups.protocols.raft.RAFT
 
num_voting_rounds - Variable in class org.jgroups.protocols.raft.ELECTION
 
num_voting_rounds - Variable in class org.jgroups.protocols.raft.ELECTION2
 
numAccesses() - Method in interface org.jgroups.protocols.raft.LogCacheControl
Returns the total number of cache lookups (hits + misses).
numAccesses() - Method in class org.jgroups.raft.util.LogCache
 
numberOfBlockedMessages() - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor
The number of blocked messages.
numBytesReceived() - Method in class org.jgroups.protocols.raft.RAFT
 
numChunksReceived() - Method in class org.jgroups.protocols.raft.RAFT
 
numFailedChunkTransfers() - Method in class org.jgroups.protocols.raft.RAFT
 
numSnapshotInstallFailed() - Method in class org.jgroups.protocols.raft.RAFT
 
numSnapshotReceived() - Method in class org.jgroups.protocols.raft.RAFT
 
numSnapshots() - Method in class org.jgroups.protocols.raft.RAFT
 
numSnapshotsCreateFailed() - Method in class org.jgroups.protocols.raft.RAFT
 
numTrims() - Method in interface org.jgroups.protocols.raft.LogCacheControl
Returns the number of times the cache has been trimmed to stay within capacity.
numTrims() - Method in class org.jgroups.raft.util.LogCache
 

O

Obtaining an Instance - Section in interface org.jgroups.raft.util.TimeService
 
offer(BaseRequest) - 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 class org.jgroups.protocols.raft.AppendResult.Result
 
Optimization Recommendations - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Optimization Recommendations - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Optimization Recommendations - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Optimization Recommendations - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Optimization Recommendations - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
options() - Method in class org.jgroups.protocols.raft.REDIRECT.RedirectHeader
 
options() - Static method in interface org.jgroups.raft.command.JGroupsRaftReadCommandOptions
Creates a builder for read command options.
options() - Static method in interface org.jgroups.raft.command.JGroupsRaftWriteCommandOptions
Creates a builder for write command options.
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
 
order() - Element in annotation interface org.jgroups.raft.StateMachineField
The order of the field to be stored in the snapshot.
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.command - package org.jgroups.raft.command
 
org.jgroups.raft.configuration - package org.jgroups.raft.configuration
 
org.jgroups.raft.exceptions - package org.jgroups.raft.exceptions
 
org.jgroups.raft.metrics - package org.jgroups.raft.metrics
 
org.jgroups.raft.serialization - package org.jgroups.raft.serialization
 
org.jgroups.raft.testfwk - package org.jgroups.raft.testfwk
 
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
 
PartitionedRaftCluster - Class in org.jgroups.raft.testfwk
Manipulate the cluster during tests.
PartitionedRaftCluster() - Constructor for class org.jgroups.raft.testfwk.PartitionedRaftCluster
 
partitions - Variable in class org.jgroups.raft.testfwk.PartitionedRaftCluster
 
peek() - Method in class org.jgroups.raft.util.ArrayRingBuffer
 
Performance Considerations - Section in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
performanceMetrics() - Method in class org.jgroups.raft.JGroupsRaftMetrics.DisabledJGroupsRaftMetrics
 
performanceMetrics() - Method in interface org.jgroups.raft.JGroupsRaftMetrics
Latency measurements for the main operations: request processing, consensus, leader election, and request forwarding.
PerformanceMetrics - Interface in org.jgroups.raft.metrics
Latency measurements for the main operations in a Raft cluster.
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
 
PRE_VOTE_REQ - Static variable in class org.jgroups.protocols.raft.ELECTION
 
PRE_VOTE_REQ - Static variable in class org.jgroups.protocols.raft.ELECTION2
 
PRE_VOTE_RSP - Static variable in class org.jgroups.protocols.raft.ELECTION
 
PRE_VOTE_RSP - Static variable in class org.jgroups.protocols.raft.ELECTION2
 
prepareSnapshot() - Method in interface org.jgroups.raft.AsyncSnapshot
Captures a point-in-time consistent view of the state machine.
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: - Section in class org.jgroups.protocols.raft.ELECTION2
 
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) - 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
 
processingLatency() - Method 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
 
Property - Class in org.jgroups.raft.configuration
 
Property(String, String, String, Supplier) - Constructor for class org.jgroups.raft.configuration.Property
 
PROPERTY_PREFIX - Static variable in interface org.jgroups.raft.configuration.RuntimeProperties
 
Property.Builder - Class in org.jgroups.raft.configuration
 
PropsToAsciidoc - Class in org.jgroups.raft.util
Iterates over all concrete Protocol classes and creates tables with Protocol's properties.
PropsToAsciidoc() - Constructor for class org.jgroups.raft.util.PropsToAsciidoc
 
protocols() - Method in class org.jgroups.raft.testfwk.RaftNode
 
prots - Variable in class org.jgroups.raft.testfwk.RaftNode
 
put(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.ELECTION
 
raft - Variable in class org.jgroups.protocols.raft.ELECTION2
 
raft - Variable in class org.jgroups.protocols.raft.RaftImpl
 
raft - Variable in class org.jgroups.protocols.raft.REDIRECT
 
raft - Variable in class org.jgroups.raft.blocks.CounterService
 
raft - Variable in class org.jgroups.raft.blocks.ReplicatedStateMachine
 
raft - Variable in class org.jgroups.raft.RaftHandle
 
raft - Variable in class org.jgroups.raft.testfwk.RaftNode
 
raft() - Method in class org.jgroups.protocols.raft.ELECTION
 
raft() - Method in class org.jgroups.protocols.raft.ELECTION2
 
raft() - Method in class org.jgroups.protocols.raft.RaftImpl
 
raft() - Method in class org.jgroups.raft.RaftHandle
 
raft() - Method in class org.jgroups.raft.testfwk.RaftNode
 
raft(JChannel) - Static method in class org.jgroups.raft.testfwk.RaftTestUtils
Retrieves the RAFT protocol from the provided JChannel.
raft(RAFT) - Method in class org.jgroups.protocols.raft.ELECTION
 
raft(RAFT) - Method in class org.jgroups.protocols.raft.ELECTION2
 
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.RoleChange - Interface in org.jgroups.protocols.raft
 
RaftAsyncCounter - Interface in org.jgroups.raft.blocks
TODO!
RaftClassConfigurator - Class in org.jgroups.raft.util
Centralized registration of all RAFT protocol types with JGroups ClassConfigurator.
RaftCluster - Class in org.jgroups.raft.testfwk
Orchestrates a number of RaftNode objects, to be used in a unit test, for example a leader and a follower.
RaftCluster() - Constructor for class org.jgroups.raft.testfwk.RaftCluster
 
RaftCounter - Interface in org.jgroups.raft.blocks
TODO!
RaftHandle - Class in org.jgroups.raft
Main interaction point for applications with jgroups-raft.
RaftHandle(JChannel, StateMachine) - Constructor for class org.jgroups.raft.RaftHandle
Creates a RaftHandle instance.
RaftHeader - Class in org.jgroups.protocols.raft
 
RaftHeader() - Constructor for class org.jgroups.protocols.raft.RaftHeader
 
RaftHeader(long) - Constructor for class org.jgroups.protocols.raft.RaftHeader
 
raftId() - Method in class org.jgroups.protocols.raft.RAFT
 
raftId() - Method in class org.jgroups.raft.blocks.CounterService
 
raftId() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
 
raftId() - Method in class org.jgroups.raft.RaftHandle
 
raftId(String) - Method in class org.jgroups.protocols.raft.RAFT
 
raftId(String) - Method in class org.jgroups.raft.blocks.CounterService
 
raftId(String) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
 
raftId(String) - Method in class org.jgroups.raft.RaftHandle
 
RaftImpl - Class in org.jgroups.protocols.raft
Base class for the different roles a RAFT node can have (follower, candidate, leader)
RaftImpl(RAFT) - Constructor for class org.jgroups.protocols.raft.RaftImpl
 
RaftLeaderException - Exception Class in org.jgroups.protocols.raft
 
RaftLeaderException(String) - Constructor for exception class org.jgroups.protocols.raft.RaftLeaderException
 
RaftLogException - Exception Class in org.jgroups.protocols.raft
Unchecked exception thrown by RaftLogAdapter after the log has been poisoned due to an unrecoverable storage failure.
RaftLogException(String, Throwable) - Constructor for exception class org.jgroups.protocols.raft.RaftLogException
 
RaftNode - Class in org.jgroups.raft.testfwk
Wraps the RAFT and/or ELECTION protocols
RaftNode(MockRaftCluster, Protocol[]) - Constructor for class org.jgroups.raft.testfwk.RaftNode
 
RaftNode(RaftCluster, RAFT) - Constructor for class org.jgroups.raft.testfwk.RaftNode
 
RaftProtocolBuilder<T> - Class in org.jgroups.raft.configuration
 
RaftProtocolBuilder(JGroupsRaft.Builder) - Constructor for class org.jgroups.raft.configuration.RaftProtocolBuilder
 
RaftSyncCounter - Interface in org.jgroups.raft.blocks
TODO!
RaftTestUtils - Class in org.jgroups.raft.testfwk
Utilities for developing tests with Raft.
reached - Enum constant in enum class org.jgroups.raft.util.Utils.Majority
 
read(Function) - Method in interface org.jgroups.raft.JGroupsRaft
Submits a read command to the state machine.
read(Function, JGroupsRaftReadCommandOptions) - Method in interface org.jgroups.raft.JGroupsRaft
Submits a read command to the state machine.
read(SerializationContextRead, byte) - Method in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
Reads an object from the input context.
readAndDumpSnapshot(DataInput) - Static method in class org.jgroups.raft.blocks.CounterService
 
readAndDumpSnapshot(DataInput) - Static method in class org.jgroups.raft.util.CounterStateMachine
 
readBoolean() - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads a boolean (1 byte).
ReadBuilder() - Constructor for class org.jgroups.raft.command.JGroupsRaftCommandOptions.ReadBuilder
 
readByte() - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads a single byte.
readBytes(byte[]) - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads bytes into an existing array.
readBytes(byte[], int, int) - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads bytes into a portion of an existing array.
readBytes(int) - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads bytes into a new array.
readContentFrom(DataInput) - Method in interface org.jgroups.raft.AsyncSnapshot
Restores the state machine from a snapshot stream.
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
 
readDouble() - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads a double (8 bytes).
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
 
readFloat() - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads a float (4 bytes).
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
 
Reading Nested Objects - Section in interface org.jgroups.raft.serialization.SerializationContextRead
 
Reading Primitives - Section in interface org.jgroups.raft.serialization.SerializationContextRead
 
readInt() - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads an int (4 bytes).
readLong() - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads a long (8 bytes).
readObject() - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads an object with automatic type identification.
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
 
readOptions() - Static method in interface org.jgroups.raft.command.JGroupsRaftCommandOptions
Creates a builder for read command options.
Read Order - Section in interface org.jgroups.raft.serialization.SerializationContextRead
 
readShort() - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads a short (2 bytes).
readSnapshotRegion(long, byte[], int, int) - Method in class org.jgroups.protocols.raft.FileBasedLog
 
readSnapshotRegion(long, byte[], int, int) - Method in class org.jgroups.protocols.raft.InMemoryLog
 
readSnapshotRegion(long, byte[], int, int) - Method in interface org.jgroups.protocols.raft.Log
Reads up to length bytes from the snapshot data starting at offset.
readSnapshotRegion(long, byte[], int, int) - Method in class org.jgroups.raft.util.LogCache
 
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
readUTF() - Method in interface org.jgroups.raft.serialization.SerializationContextRead
Reads a UTF-8 encoded string with length prefix.
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 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
 
redirectionOperationMeanLatency() - Method in class org.jgroups.protocols.raft.REDIRECT
 
redirectLatency() - Method in class org.jgroups.protocols.raft.REDIRECT
 
register(long, R) - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository
Register a new request submitted at the given index.
registerMarshaller(JGroupsRaftCustomMarshaller) - Method in class org.jgroups.raft.JGroupsRaft.Builder
Register a new marshaler to serialize commands.
registerRedirect() - Method in class org.jgroups.raft.util.RaftClassConfigurator
Registers the REDIRECT protocol and its header type with JGroups.
Registration - Section in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
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
Resets the log to contain only the given entry at the given index.
reinitializeTo(long, LogEntry) - Method in class org.jgroups.raft.util.LogCache
 
release() - Method in interface org.jgroups.raft.SnapshotHandle
Releases resources held by this snapshot handle.
releaseNext() - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor
Releases the next blocked message in line.
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(Address) - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Remove a member from the cluster.
remove(Address) - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
 
remove(Address) - Method in class org.jgroups.raft.testfwk.RaftCluster
 
REMOVE - 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 class org.jgroups.protocols.raft.CLIENT.RequestType
 
REMOVE_SERVER - Enum constant in enum class org.jgroups.protocols.raft.REDIRECT.RequestType
 
removeNode(String) - Method in interface org.jgroups.raft.JGroupsRaftAdministration
Removes a voting member from the Raft cluster.
removeNotificationListener(ReplicatedStateMachine.Notification) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
 
removeQueueSize() - Method in class org.jgroups.protocols.raft.RAFT
 
removeRoleChangeListener(BiConsumer) - Method in interface org.jgroups.raft.JGroupsRaft
Removes a previously registered listener.
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 class 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
 
replicationMeanLatency() - Method in class org.jgroups.protocols.raft.RAFT
 
replicationMetrics() - Method in class org.jgroups.raft.JGroupsRaftMetrics.DisabledJGroupsRaftMetrics
 
replicationMetrics() - Method in interface org.jgroups.raft.JGroupsRaftMetrics
Metrics about the Raft log, including entry counts and replication progress.
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 class org.jgroups.protocols.raft.REDIRECT.RequestType
 
req_id - Variable in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
 
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.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.JGroupsRaftMetrics.DisabledJGroupsRaftMetrics
 
reset() - Method in interface org.jgroups.raft.JGroupsRaftMetrics
Resets all collected metrics to their initial state.
reset() - Method in class org.jgroups.raft.util.CounterStateMachine
 
resetStats() - Method in class org.jgroups.protocols.raft.ELECTION
 
resetStats() - Method in class org.jgroups.protocols.raft.ELECTION2
 
resetStats() - Method in interface org.jgroups.protocols.raft.LogCacheControl
Resets all cache statistics (accesses, hits, trims) to zero.
resetStats() - Method in class org.jgroups.protocols.raft.RAFT
 
resetStats() - Method in class org.jgroups.protocols.raft.REDIRECT
 
resetStats() - Method in class org.jgroups.raft.util.LogCache
 
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
retiredReads() - Element in annotation interface org.jgroups.raft.JGroupsRaftStateMachine
Declares read operations that have been permanently removed from this state machine.
retiredWrites() - Element in annotation interface org.jgroups.raft.JGroupsRaftStateMachine
Declares write operations that have been permanently removed from this state machine.
role() - Method in class org.jgroups.protocols.raft.RAFT
 
role() - Method in interface org.jgroups.raft.JGroupsRaft
The current role of the node in the Raft algorithm.
Role - Enum Class 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
 
Role-Specific Availability - Section in interface org.jgroups.raft.metrics.PerformanceMetrics
 
ROOT_PACKAGE - Static variable in class org.jgroups.raft.util.PropsToAsciidoc
 
rsp - Enum constant in enum class org.jgroups.protocols.raft.CLIENT.RequestType
 
RSP - Enum constant in enum class 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
 
RuntimeProperties - Interface in org.jgroups.raft.configuration
 
RuntimeProperties.Builder - Class in org.jgroups.raft.configuration
 
RuntimeProperties.ConfigurationBuilder<C,B> - Interface in org.jgroups.raft.configuration
 
runVotingThread() - Method in class org.jgroups.protocols.raft.ELECTION
 
runVotingThread() - Method in class org.jgroups.protocols.raft.ELECTION2
 

S

s - Variable in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
 
self() - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Utility to create a fluent use.
send(DataOutput, CLIENT.RequestType, int, byte[], int, int) - Method in class org.jgroups.protocols.raft.CLIENT.RequestHandler
 
send(Message) - Method in class org.jgroups.raft.testfwk.MockRaftCluster
Send a message in the cluster.
send(Message) - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
 
send(Message) - Method in class org.jgroups.raft.testfwk.RaftCluster
 
send(Message, boolean) - Method in class org.jgroups.raft.testfwk.RaftCluster
 
send_commits_immediately - Variable in class org.jgroups.protocols.raft.RAFT
 
send_single_msg - Variable in class org.jgroups.raft.util.CommitTable.Entry
 
sendAppendEntriesMessage(Address, CommitTable.Entry) - Method in class org.jgroups.protocols.raft.RAFT
Runs (on the leader) as part of the queue handling loop: checks if all members (except the leader) in the commit table have received all messages and resends AppendEntries messages to members who haven't.
For each member, a next-index and match-index is maintained: next-index is the index of the next message to send to that member (initialized to last-applied) and match-index is the index of the highest message known to have been received by the member.
Messages are resent to a given member as long as that member's match-index is smaller than its next-index.
sendCommitsImmediately() - Method in class org.jgroups.protocols.raft.RAFT
 
sendCommitsImmediately(boolean) - Method in class org.jgroups.protocols.raft.RAFT
 
sendJoinRejectedMessageTo(Address, String) - Method in class org.jgroups.protocols.raft.NO_DUPES
 
sendLeaderElectedMessage(Address, long) - Method in class org.jgroups.protocols.raft.ELECTION
 
sendLeaderElectedMessage(Address, long) - Method in class org.jgroups.protocols.raft.ELECTION2
 
sendSingleMessage() - Method in class org.jgroups.raft.util.CommitTable.Entry
 
sendSingleMessage(boolean) - Method in class org.jgroups.raft.util.CommitTable.Entry
 
sendSnapshotTo(Address) - Method in class org.jgroups.protocols.raft.RAFT
 
sendVoteRequest(long) - Method in class org.jgroups.protocols.raft.ELECTION
 
sendVoteRequest(long) - Method in class org.jgroups.protocols.raft.ELECTION2
 
sendVoteResponse(Address, long, long, long) - Method in class org.jgroups.protocols.raft.ELECTION
 
sendVoteResponse(Address, long, long, long) - Method in class org.jgroups.protocols.raft.ELECTION2
 
SerializationContextRead - Interface in org.jgroups.raft.serialization
Context for reading objects and primitives during deserialization.
SerializationContextWrite - Interface in org.jgroups.raft.serialization
Context for writing objects and primitives during serialization.
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
 
SERIALIZER - Static variable in class org.jgroups.raft.command.JGroupsRaftReadCommandOptions.ReadImpl
 
SERIALIZER - Static variable in class org.jgroups.raft.command.JGroupsRaftWriteCommandOptions.WriteImpl
 
set - Enum constant in enum class 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 class 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.
setAsync(byte[], int, int, Options) - Method in class org.jgroups.raft.testfwk.RaftNode
 
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) - 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(InputStream) - Method in class org.jgroups.protocols.raft.FileBasedLog
 
setSnapshot(InputStream) - Method in class org.jgroups.protocols.raft.InMemoryLog
 
setSnapshot(InputStream) - Method in interface org.jgroups.protocols.raft.Log
Stores a snapshot of the state machine, replacing any previously stored snapshot.
setSnapshot(InputStream) - Method in class org.jgroups.raft.util.LogCache
 
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 of the state machine, replacing any previously stored snapshot.
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.
shouldBlock(Message) - Method in class org.jgroups.raft.testfwk.BlockingMessageInterceptor
Check if the given message should be blocked.
size() - Method in class org.jgroups.protocols.raft.AppendResult
 
size() - Method in interface org.jgroups.protocols.raft.Log
Returns the number of entries in the log.
size() - Method in class org.jgroups.protocols.raft.LogEntries
 
size() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
Returns the number of elements in the RSM
size() - Method in class org.jgroups.raft.testfwk.MockRaftCluster
The number of member in the cluster.
size() - Method in class org.jgroups.raft.testfwk.PartitionedRaftCluster
 
size() - Method in class org.jgroups.raft.testfwk.RaftCluster
 
size() - Method in class org.jgroups.raft.util.ArrayRingBuffer
 
size() - Method in class org.jgroups.raft.util.RequestTable
number of requests being processed
size(boolean) - Method in class org.jgroups.raft.util.ArrayRingBuffer
 
sizeInBytes() - Method in class org.jgroups.protocols.raft.FileBasedLog
 
sizeInBytes() - Method in class org.jgroups.protocols.raft.InMemoryLog
 
sizeInBytes() - Method in interface org.jgroups.protocols.raft.Log
Returns the approximate size of the log data in bytes.
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 interface org.jgroups.raft.JGroupsRaftAdministration
Triggers a snapshot of the current state machine and truncates the log.
snapshot() - Method in class org.jgroups.raft.RaftHandle
 
snapshot_batch_size - Variable in class org.jgroups.protocols.raft.RAFT
 
snapshot_chunk_size - Variable in class org.jgroups.protocols.raft.RAFT
 
snapshot_reader - Variable in class org.jgroups.raft.util.AnalyzeLog
 
snapshotAsync() - Method in class org.jgroups.protocols.raft.RAFT
 
snapshotBatchSize() - Method in class org.jgroups.protocols.raft.RAFT
 
snapshotChunkSize() - Method in class org.jgroups.protocols.raft.RAFT
 
SnapshotHandle - Interface in org.jgroups.raft
A frozen, point-in-time view of a state machine's contents, ready for serialization.
snapshotIfNeeded(int) - Method in class org.jgroups.protocols.raft.RAFT
 
snapshotReader(String) - Method in class org.jgroups.raft.util.AnalyzeLog
 
snapshotSize() - Method in class org.jgroups.protocols.raft.FileBasedLog
 
snapshotSize() - Method in class org.jgroups.protocols.raft.InMemoryLog
 
snapshotSize() - Method in interface org.jgroups.protocols.raft.Log
Returns the size of the snapshot.
snapshotSize() - Method in class org.jgroups.raft.util.LogCache
 
sock - Variable in class org.jgroups.protocols.raft.CLIENT
 
stackless(String) - Static method in exception class org.jgroups.raft.exceptions.JRaftException
 
stage() - Method in interface org.jgroups.protocols.raft.StagedSnapshotCapability
Creates a new staging area for a snapshot and returns a stream to write into it.
StagedSnapshotCapability - Interface in org.jgroups.protocols.raft
A log capability that allows snapshot creation in two phases: staging and committing.
start() - Method in class org.jgroups.protocols.raft.CLIENT
 
start() - Method in class org.jgroups.protocols.raft.ELECTION
 
start() - Method in class org.jgroups.protocols.raft.ELECTION2
 
start() - Method in class org.jgroups.protocols.raft.RAFT
 
start() - Method in class org.jgroups.protocols.raft.REDIRECT
 
start() - Method in interface org.jgroups.raft.JGroupsRaft
Starts the instance.
start() - Method in class org.jgroups.raft.testfwk.RaftNode
 
startForcedElection(Address) - Method in class org.jgroups.protocols.raft.ELECTION
Starts a forced leader election, excluding the given address from candidacy.
startForcedElection(Address) - Method in class org.jgroups.protocols.raft.ELECTION2
Starts a forced leader election, excluding the given address from candidacy.
startVotingThread() - Method in class org.jgroups.protocols.raft.ELECTION
 
startVotingThread() - Method in class org.jgroups.protocols.raft.ELECTION2
 
state() - Method in interface org.jgroups.raft.JGroupsRaft
Internal state of the Raft algorithm.
State - Section in interface org.jgroups.raft.JGroupsRaft
 
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.
StateMachineField - Annotation Interface in org.jgroups.raft
Marks a field for inclusion in Raft snapshots.
stateMachineLoaded(boolean) - Method in class org.jgroups.protocols.raft.RAFT
 
StateMachineRead - Annotation Interface in org.jgroups.raft
Marks a method as a read-only operation in the Raft state machine.
State Machine Requirements - Section in annotation interface org.jgroups.raft.JGroupsRaftStateMachine
 
StateMachineWrite - Annotation Interface in org.jgroups.raft
Marks a method as a write operation in the Raft state machine.
stop() - Method in class org.jgroups.protocols.raft.CLIENT
 
stop() - Method in class org.jgroups.protocols.raft.ELECTION
 
stop() - Method in class org.jgroups.protocols.raft.ELECTION2
 
stop() - Method in class org.jgroups.protocols.raft.RAFT
 
stop() - Method in interface org.jgroups.raft.JGroupsRaft
Stops the instance.
stop() - Method in class org.jgroups.raft.testfwk.RaftNode
 
stopVotingThread() - Method in class org.jgroups.protocols.raft.ELECTION
 
stopVotingThread() - Method in class org.jgroups.protocols.raft.ELECTION2
 
Strict Determinism - Section in interface org.jgroups.raft.StateMachine
 
Strings - Section in interface org.jgroups.raft.serialization.SerializationContextWrite
 
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
 
Synchronous Execution & Event Loop Blocking - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Synchronous Execution & Event Loop Blocking - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Synchronous Execution & Event Loop Blocking - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Synchronous Execution & Event Loop Blocking - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Synchronous Execution & Event Loop Blocking - Section in org.jgroups.raft.StateMachine.readContentFrom(DataInput)
 
Synchronous Execution & Event Loop Blocking - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Synchronous Execution & Event Loop Blocking - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Synchronous Execution & Event Loop Blocking - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Synchronous Execution & Event Loop Blocking - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 
Synchronous Execution & Event Loop Blocking - Section in org.jgroups.raft.StateMachine.writeContentTo(DataOutput)
 

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() - Method in interface org.jgroups.raft.JGroupsRaftState
Returns the current term number.
term(long) - Method in class org.jgroups.protocols.raft.LogEntry
 
thread_pool - Variable in class org.jgroups.protocols.raft.CLIENT
 
thread_pool - Variable in class org.jgroups.raft.testfwk.MockRaftCluster
 
Thread safety - Section in interface org.jgroups.protocols.raft.Log
 
Thread Safety - Section in interface org.jgroups.raft.JGroupsRaftMetrics
 
Thread Safety - Section in interface org.jgroups.raft.StateMachine
 
Thread Safety - Section in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
timeout() - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
 
timeout(long) - Method in class org.jgroups.raft.blocks.ReplicatedStateMachine
 
timeService() - Method in class org.jgroups.protocols.raft.RAFT
 
timeService(TimeService) - Method in class org.jgroups.protocols.raft.RAFT
 
TimeService - Interface in org.jgroups.raft.util
Abstraction over time sources.
TimeService.DisabledTimeService - Class in org.jgroups.raft.util
No-op implementation that returns null for timestamps and 0 for nanosecond values.
TimeService.SystemTimeService - Class in org.jgroups.raft.util
Live implementation backed by the JVM time.
timeSinceLastElection() - Method in class org.jgroups.protocols.raft.ELECTION
 
timeSinceLastElection() - Method in class org.jgroups.protocols.raft.ELECTION2
 
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
 
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
////////////////////////////////// End of StateMachine callbacks ///////////////////////////////////
toString() - Method in class org.jgroups.raft.Options
 
toString() - Method in class org.jgroups.raft.testfwk.RaftCluster
 
toString() - Method in class org.jgroups.raft.testfwk.RaftNode
 
toString() - Method in class org.jgroups.raft.util.ArrayRingBuffer
 
toString() - Method in class org.jgroups.raft.util.CommitTable.Entry
 
toString() - Method in class org.jgroups.raft.util.CommitTable
 
toString() - Method in class org.jgroups.raft.util.CounterStateMachine
 
toString() - Method in class org.jgroups.raft.util.LogCache
 
toString() - Method in class org.jgroups.raft.util.RequestTable.Entry
 
toString() - Method in class org.jgroups.raft.util.RequestTable
 
toStringDetails() - Method in class org.jgroups.raft.util.LogCache
 
totalLatencyMetrics() - Method in class org.jgroups.protocols.raft.RAFT
 
totalSize() - Method in class org.jgroups.protocols.raft.LogEntries
 
trim() - Method in interface org.jgroups.protocols.raft.LogCacheControl
Evicts the oldest entries until the cache size is within the configured maximum.
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
Removes all entries before the given 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 class org.jgroups.protocols.raft.CLIENT.RequestType
 
type - Variable in class org.jgroups.protocols.raft.InternalCommand
 
type() - Method in class org.jgroups.protocols.raft.InternalCommand
 
type() - Method in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
Returns the unique type ID of the current class.
Type IDs - Section in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 

U

up(Event) - Method in class org.jgroups.protocols.raft.ELECTION
 
up(Event) - Method in class org.jgroups.protocols.raft.ELECTION2
 
up(Event) - Method in class org.jgroups.protocols.raft.RAFT
 
up(Event) - Method in class org.jgroups.protocols.raft.REDIRECT
 
up(Message) - Method in class org.jgroups.protocols.raft.ELECTION
 
up(Message) - Method in class org.jgroups.protocols.raft.ELECTION2
 
up(Message) - Method in class org.jgroups.protocols.raft.NO_DUPES
 
up(Message) - Method in class org.jgroups.protocols.raft.RAFT
 
up(Message) - Method in class org.jgroups.protocols.raft.REDIRECT
 
up(Message) - Method in class org.jgroups.raft.testfwk.RaftNode
 
up(MessageBatch) - Method in class org.jgroups.protocols.raft.CLIENT
 
up(MessageBatch) - Method in class org.jgroups.protocols.raft.ELECTION
 
up(MessageBatch) - Method in class org.jgroups.protocols.raft.ELECTION2
 
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) - Method in class org.jgroups.raft.blocks.AsyncCounterImpl
 
updateFunction - Enum constant in enum class org.jgroups.raft.blocks.CounterService.Command
 
Usage Steps - Section in interface org.jgroups.raft.JGroupsRaft
 
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
Returns whether writes are forced to stable storage before mutating operations return.
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
Controls whether mutating operations force data to stable storage (fsync) before returning.
useFsync(boolean) - Method in class org.jgroups.raft.util.LogCache
 
userOperationMeanLatency() - Method in class org.jgroups.protocols.raft.RAFT
 
Utils - Class in org.jgroups.raft.util
 
Utils() - Constructor for class org.jgroups.raft.util.Utils
 
Utils.Majority - Enum Class in org.jgroups.raft.util
 

V

validate() - Method in class org.jgroups.raft.JGroupsRaft.Builder
 
validate() - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
valueOf(String) - Static method in enum class org.jgroups.protocols.raft.AppendResult.Result
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.jgroups.protocols.raft.CLIENT.RequestType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.jgroups.protocols.raft.InternalCommand.Type
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.jgroups.protocols.raft.REDIRECT.RequestType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.jgroups.protocols.raft.Role
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.jgroups.raft.blocks.CounterService.Command
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.jgroups.raft.JGroupsRaftHealthCheck.ClusterHealth
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.jgroups.raft.JGroupsRaftRole
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.jgroups.raft.util.Utils.Majority
Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.jgroups.protocols.raft.AppendResult.Result
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.jgroups.protocols.raft.CLIENT.RequestType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.jgroups.protocols.raft.InternalCommand.Type
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.jgroups.protocols.raft.REDIRECT.RequestType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.jgroups.protocols.raft.Role
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.jgroups.raft.blocks.CounterService.Command
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.jgroups.raft.JGroupsRaftHealthCheck.ClusterHealth
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.jgroups.raft.JGroupsRaftRole
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.jgroups.raft.util.Utils.Majority
Returns an array containing the constants of this enum class, in the order they are declared.
Values and Units - Section in interface org.jgroups.raft.metrics.LatencyMetrics
 
version() - Method in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
version() - Element in annotation interface org.jgroups.raft.StateMachineRead
Version number for backwards compatibility.
version() - Element in annotation interface org.jgroups.raft.StateMachineWrite
Version number for backwards compatibility.
Versioning and Evolution - Section in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
 
view - Variable in class org.jgroups.protocols.raft.ELECTION
 
view - Variable in class org.jgroups.protocols.raft.ELECTION2
 
view - Variable in class org.jgroups.protocols.raft.NO_DUPES
 
view - Variable in class org.jgroups.protocols.raft.RAFT
 
view - Variable in class org.jgroups.protocols.raft.REDIRECT
 
viewCoordinatorChanged(View, View) - Static method in class org.jgroups.raft.util.Utils
Verify if the coordinator change between two views.
VOTE_REQ - Static variable in class org.jgroups.protocols.raft.ELECTION
 
VOTE_REQ - Static variable in class org.jgroups.protocols.raft.ELECTION2
 
VOTE_RSP - Static variable in class org.jgroups.protocols.raft.ELECTION
 
VOTE_RSP - Static variable in class org.jgroups.protocols.raft.ELECTION2
 
vote_timeout - Variable in class org.jgroups.protocols.raft.ELECTION
 
vote_timeout - Variable in class org.jgroups.protocols.raft.ELECTION2
 
voted_for - Variable in class org.jgroups.protocols.raft.InMemoryLog
 
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 candidate 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
Persists the vote for the given candidate 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
 
voteTimeout() - Method in class org.jgroups.protocols.raft.ELECTION
 
voteTimeout() - Method in class org.jgroups.protocols.raft.ELECTION2
 
voteTimeout(long) - Method in class org.jgroups.protocols.raft.ELECTION
Defines the default timeout in milliseconds to utilize during any election operation.
voteTimeout(long) - Method in class org.jgroups.protocols.raft.ELECTION2
Defines the default timeout in milliseconds to utilize during any election operation.

W

Wall-Clock vs Monotonic Time - Section in interface org.jgroups.raft.util.TimeService
 
with(String, boolean) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Associate the given value with the specified key.
with(String, double) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Associate the given value with the specified key.
with(String, float) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Associate the given value with the specified key.
with(String, int) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Associate the given value with the specified key.
with(String, long) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Associate the given value with the specified key.
with(String, Class) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Associate the given class name value with the specified key.
with(String, Object) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Associate the given value with the specified key.
with(String, String) - Method in class org.jgroups.raft.configuration.RuntimeProperties.Builder
 
with(String, String) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Associate the given value with the specified key.
with(RuntimeProperties) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Add all of the fields in the supplied Configuration object.
withClusterName(String) - Method in class org.jgroups.raft.JGroupsRaft.Builder
Defines the name of the cluster to create with JGroups.
withCommitter(Consumer) - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository.Builder
 
withDefaultValue(Object) - Method in class org.jgroups.raft.configuration.Property.Builder
 
withDefaultValue(Supplier) - Method in class org.jgroups.raft.configuration.Property.Builder
 
withDescription(String) - Method in class org.jgroups.raft.configuration.Property.Builder
 
withDestroyer(Consumer) - Method in class org.jgroups.raft.util.ReadOnlyRequestRepository.Builder
 
withDisplayName(String) - Method in class org.jgroups.raft.configuration.Property.Builder
 
withJChannel(JChannel) - Method in class org.jgroups.raft.JGroupsRaft.Builder
Defines the JGroups channel to be used.
withJChannel(JChannel) - Method in interface org.jgroups.raft.JGroupsRaft.JGroupsBuilderStep
 
withJGroupsConfig(InputStream) - Method in class org.jgroups.raft.JGroupsRaft.Builder
Defines the JGroups configuration file to be used.
withJGroupsConfig(InputStream) - Method in interface org.jgroups.raft.JGroupsRaft.JGroupsBuilderStep
 
withJGroupsConfig(String) - Method in class org.jgroups.raft.JGroupsRaft.Builder
Defines the path to the JGroups configuration file.
withJGroupsConfig(String) - Method in interface org.jgroups.raft.JGroupsRaft.JGroupsBuilderStep
 
withLogArgs(String) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
withLogClass(Class) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
withLogDirectory(String) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
withLogPrefix(String) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
withMaxLogSize(long) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
withMembers(List) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
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
 
without(String) - Method in class org.jgroups.raft.configuration.RuntimeProperties.Builder
 
without(String) - Method in interface org.jgroups.raft.configuration.RuntimeProperties.ConfigurationBuilder
Remove the value associated with the specified key.
withRaftId(String) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
withResendInterval(long) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
withRuntimeProperties(Properties) - Method in class org.jgroups.raft.JGroupsRaft.Builder
Defines configuration properties to be used.
withRuntimeProperties(RuntimeProperties) - Method in class org.jgroups.raft.JGroupsRaft.Builder
Defines configuration properties to be used.
withSendCommitsImmediately(boolean) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
withUseFsync(boolean) - Method in class org.jgroups.raft.configuration.RaftProtocolBuilder
 
write(Function) - Method in interface org.jgroups.raft.JGroupsRaft
Submits a write command to the state machine.
write(Function, JGroupsRaftWriteCommandOptions) - Method in interface org.jgroups.raft.JGroupsRaft
Submits a write command to the state machine.
write(SerializationContextWrite, T) - Method in interface org.jgroups.raft.serialization.JGroupsRaftCustomMarshaller
Writes the object to the output context.
writeBoolean(boolean) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes a boolean (1 byte).
WriteBuilder() - Constructor for class org.jgroups.raft.command.JGroupsRaftCommandOptions.WriteBuilder
 
writeByte(int) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes a single byte.
writeBytes(byte[]) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes all bytes from the array.
writeBytes(byte[], int, int) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes a portion of a byte array.
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
 
writeDouble(double) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes a double (8 bytes).
writeFloat(float) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes a float (4 bytes).
writeInt(int) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes an int (4 bytes).
writeLong(long) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes a long (8 bytes).
writeObject(Object) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes an object with automatic type identification.
writeOptions() - Static method in interface org.jgroups.raft.command.JGroupsRaftCommandOptions
Creates a builder for write command options.
Write Order - Section in interface org.jgroups.raft.serialization.SerializationContextWrite
 
writeShort(int) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes a short (2 bytes).
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
 
writeTo(DataOutput) - Method in interface org.jgroups.raft.SnapshotHandle
Serializes the frozen state to the output stream.
writeUTF(String) - Method in interface org.jgroups.raft.serialization.SerializationContextWrite
Writes a string in UTF-8 encoding with a length prefix.
writeVarToStream(String, Properties, OutputStream) - Static method in class org.jgroups.raft.util.PropsToAsciidoc
 
Writing Nested Objects - Section in interface org.jgroups.raft.serialization.SerializationContextWrite
 
Writing Primitives - Section in interface org.jgroups.raft.serialization.SerializationContextWrite
 

_

_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) - Method in class org.jgroups.raft.blocks.CounterService
 
A B C D E F G H I J K L M N O P R S T U V W _ 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form