Modifier and Type | Method and Description |
---|---|
ReplicatedLogEntry |
AbstractReplicatedLogImpl.get(long logEntryIndex) |
ReplicatedLogEntry |
ReplicatedLog.get(long index)
Return the replicated log entry at the specified index.
|
ReplicatedLogEntry |
AbstractReplicatedLogImpl.last() |
ReplicatedLogEntry |
ReplicatedLog.last()
Return the last replicated log entry in the log or null of not found.
|
Modifier and Type | Method and Description |
---|---|
List<ReplicatedLogEntry> |
AbstractReplicatedLogImpl.getFrom(long logEntryIndex) |
List<ReplicatedLogEntry> |
ReplicatedLog.getFrom(long index)
Returns a list of log entries starting from the given index to the end of the log.
|
List<ReplicatedLogEntry> |
AbstractReplicatedLogImpl.getFrom(long logEntryIndex,
int maxEntries,
long maxDataSize) |
List<ReplicatedLogEntry> |
ReplicatedLog.getFrom(long index,
int maxEntries,
long maxDataSize)
Returns a list of log entries starting from the given index up to the given maximum of entries or
the given maximum accumulated size, whichever comes first.
|
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractReplicatedLogImpl.append(ReplicatedLogEntry replicatedLogEntry) |
boolean |
ReplicatedLog.append(ReplicatedLogEntry replicatedLogEntry)
Appends an entry to the log.
|
boolean |
ReplicatedLog.appendAndPersist(ReplicatedLogEntry replicatedLogEntry,
akka.japi.Procedure<ReplicatedLogEntry> callback,
boolean doAsync)
Appends an entry to the in-memory log and persists it as well.
|
boolean |
SnapshotState.capture(ReplicatedLogEntry lastLogEntry,
long replicatedToAllIndex)
Initiates a capture snapshot.
|
boolean |
SnapshotManager.capture(ReplicatedLogEntry lastLogEntry,
long replicatedToAllIndex) |
void |
ReplicatedLog.captureSnapshotIfReady(ReplicatedLogEntry replicatedLogEntry)
Determines if a snapshot needs to be captured based on the count/memory consumed and initiates the capture.
|
boolean |
SnapshotState.captureToInstall(ReplicatedLogEntry lastLogEntry,
long replicatedToAllIndex,
String targetFollower)
Initiates a capture snapshot for the purposing of installing the snapshot on a follower.
|
boolean |
SnapshotManager.captureToInstall(ReplicatedLogEntry lastLogEntry,
long replicatedToAllIndex,
String targetFollower) |
CaptureSnapshot |
SnapshotManager.newCaptureSnapshot(ReplicatedLogEntry lastLogEntry,
long replicatedToAllIndex)
Constructs a CaptureSnapshot instance.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ReplicatedLog.appendAndPersist(ReplicatedLogEntry replicatedLogEntry,
akka.japi.Procedure<ReplicatedLogEntry> callback,
boolean doAsync)
Appends an entry to the in-memory log and persists it as well.
|
Constructor and Description |
---|
AbstractReplicatedLogImpl(long snapshotIndex,
long snapshotTerm,
List<ReplicatedLogEntry> unAppliedEntries,
String logContext) |
Modifier and Type | Method and Description |
---|---|
ReplicatedLogEntry |
ApplyState.getReplicatedLogEntry() |
ReplicatedLogEntry |
Replicate.getReplicatedLogEntry() |
Modifier and Type | Method and Description |
---|---|
List<ReplicatedLogEntry> |
CaptureSnapshot.getUnAppliedEntries() |
Constructor and Description |
---|
ApplyState(akka.actor.ActorRef clientActor,
org.opendaylight.yangtools.concepts.Identifier identifier,
ReplicatedLogEntry replicatedLogEntry) |
Replicate(akka.actor.ActorRef clientActor,
org.opendaylight.yangtools.concepts.Identifier identifier,
ReplicatedLogEntry replicatedLogEntry,
boolean sendImmediate) |
Constructor and Description |
---|
CaptureSnapshot(long lastIndex,
long lastTerm,
long lastAppliedIndex,
long lastAppliedTerm,
long replicatedToAllIndex,
long replicatedToAllTerm,
List<ReplicatedLogEntry> unAppliedEntries) |
Modifier and Type | Method and Description |
---|---|
List<ReplicatedLogEntry> |
AppendEntries.getEntries() |
Constructor and Description |
---|
AppendEntries(long term,
String leaderId,
long prevLogIndex,
long prevLogTerm,
List<ReplicatedLogEntry> entries,
long leaderCommit,
long replicatedToAllIndex,
short payloadVersion) |
AppendEntries(long term,
String leaderId,
long prevLogIndex,
long prevLogTerm,
List<ReplicatedLogEntry> entries,
long leaderCommit,
long replicatedToAllIndex,
short payloadVersion,
short recipientRaftVersion,
String leaderAddress) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleReplicatedLogEntry
A
ReplicatedLogEntry implementation. |
Modifier and Type | Method and Description |
---|---|
List<ReplicatedLogEntry> |
Snapshot.getUnAppliedEntries() |
Modifier and Type | Method and Description |
---|---|
static Snapshot |
Snapshot.create(Snapshot.State state,
List<ReplicatedLogEntry> entries,
long lastIndex,
long lastTerm,
long lastAppliedIndex,
long lastAppliedTerm,
long electionTerm,
String electionVotedFor,
ServerConfigurationPayload serverConfig) |
Copyright © 2019 OpenDaylight. All rights reserved.