Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- accept(byte[], Throwable) - Method in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
- 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
RaftAsyncCounterinstance of the counter. - AsyncCounterImpl - Class in org.jgroups.raft.blocks
-
RAFT Implementation of
AsyncCounter. - AsyncCounterImpl(CounterService, String) - Constructor for class org.jgroups.raft.blocks.AsyncCounterImpl
- asyncGet(AsciiString) - Method in class org.jgroups.raft.blocks.CounterService
- asyncSet(AsciiString, long) - Method in class org.jgroups.raft.blocks.CounterService
- 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
JGroupsRaftinstance. - 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
JGroupsRaftinstance. - 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
RAFTprotocol. - 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 builderthat 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
TimeServiceinstance. - 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
Executorto 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
RAFTinstance. - 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
headSequencetoindexExclusive.
At the end of this operationheadSequenceis equals toindexExclusive. - dropped_members - Variable in class org.jgroups.raft.testfwk.RaftCluster
- dropTailTo(long) - Method in class org.jgroups.raft.util.ArrayRingBuffer
-
Remove all elements from
tailSequenceback toindexInclusive.
At the end of this operationtailSequenceis equals toindexInclusive. - dropTailToHead() - Method in class org.jgroups.raft.util.ArrayRingBuffer
- 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
BaseElectionprotocol from the providedJChannel. - 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)istrue. - 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
Logimplementation 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
Logimplementation without any persistence. - InMemoryLog() - Constructor for class org.jgroups.protocols.raft.InMemoryLog
- input - Variable in class org.jgroups.protocols.raft.CLIENT.RequestHandler.CompletionHandler
- INSTALL_SNAPSHOT_REQ - Static variable in class org.jgroups.protocols.raft.RAFT
- InstallSnapshotRequest - Class in org.jgroups.protocols.raft
- InstallSnapshotRequest() - Constructor for class org.jgroups.protocols.raft.InstallSnapshotRequest
- InstallSnapshotRequest(long) - Constructor for class org.jgroups.protocols.raft.InstallSnapshotRequest
- InstallSnapshotRequest(long, Address, long, long) - Constructor for class org.jgroups.protocols.raft.InstallSnapshotRequest
- 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
RAFTleader. - 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
Logfacade. - 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
Logimplementation 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
LogEntryelements, provides efficient serialization. - LogEntries() - Constructor for class org.jgroups.protocols.raft.LogEntries
- LogEntry - Class in org.jgroups.protocols.raft
-
An element in a log.
- LogEntry() - Constructor for class org.jgroups.protocols.raft.LogEntry
- LogEntry(long, byte[]) - Constructor for class org.jgroups.protocols.raft.LogEntry
- LogEntry(long, byte[], int, int) - Constructor for class org.jgroups.protocols.raft.LogEntry
- LogEntry(long, byte[], int, int, boolean) - Constructor for class org.jgroups.protocols.raft.LogEntry
- 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
RAFTprotocol from the providedJChannel. - 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
RaftNodeobjects, 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
RaftLogAdapterafter 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
- 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
AppendEntriesRequestmessages and responses. - RequestTable() - Constructor for class org.jgroups.raft.util.RequestTable
- RequestTable.Entry<T> - Class in org.jgroups.raft.util
- requestTableSize() - Method in class org.jgroups.protocols.raft.RAFT
- resend(Address, long) - Method in class org.jgroups.protocols.raft.RAFT
- resend(Address, long, long) - Method in class org.jgroups.protocols.raft.RAFT
-
Resends all entries in range [from .. to] to target
- resend_interval - Variable in class org.jgroups.protocols.raft.RAFT
- resendInterval() - Method in class org.jgroups.protocols.raft.RAFT
- resendInterval(long) - Method in class org.jgroups.protocols.raft.RAFT
- reset() - Method in class org.jgroups.raft.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
nullfor timestamps and0for 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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form