Package | Description |
---|---|
org.opendaylight.controller.cluster.raft | |
org.opendaylight.controller.cluster.raft.base.messages | |
org.opendaylight.controller.cluster.raft.persisted |
Modifier and Type | Method and Description |
---|---|
@Nullable ReplicatedLogEntry |
ReplicatedLog.get(long index)
Return the replicated log entry at the specified index.
|
ReplicatedLogEntry |
AbstractReplicatedLogImpl.get(long logEntryIndex) |
@Nullable ReplicatedLogEntry |
ReplicatedLog.last()
Return the last replicated log entry in the log or null of not found.
|
ReplicatedLogEntry |
AbstractReplicatedLogImpl.last() |
Modifier and Type | Method and Description |
---|---|
List<ReplicatedLogEntry> |
AbstractReplicatedLogImpl.getFrom(long logEntryIndex) |
List<ReplicatedLogEntry> |
AbstractReplicatedLogImpl.getFrom(long logEntryIndex,
int maxEntries,
long maxDataSize) |
Modifier and Type | Method and Description |
---|---|
boolean |
ReplicatedLog.append(ReplicatedLogEntry replicatedLogEntry)
Appends an entry to the log.
|
boolean |
AbstractReplicatedLogImpl.append(ReplicatedLogEntry replicatedLogEntry) |
boolean |
ReplicatedLog.appendAndPersist(@NonNull ReplicatedLogEntry replicatedLogEntry,
@Nullable Consumer<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.
|
Constructor and Description |
---|
AbstractReplicatedLogImpl(long snapshotIndex,
long snapshotTerm,
List<ReplicatedLogEntry> unAppliedEntries,
String logContext) |
Modifier and Type | Method and Description |
---|---|
ReplicatedLogEntry |
Replicate.getReplicatedLogEntry() |
ReplicatedLogEntry |
ApplyState.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 | 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.