Package | Description |
---|---|
org.opendaylight.controller.cluster.datastore.persisted |
Persisted backend structures.
|
org.opendaylight.controller.cluster.example | |
org.opendaylight.controller.cluster.raft | |
org.opendaylight.controller.cluster.raft.base.messages | |
org.opendaylight.controller.cluster.raft.persisted |
Modifier and Type | Class and Description |
---|---|
class |
ShardSnapshotState
Encapsulates the snapshot State for a Shard.
|
Modifier and Type | Method and Description |
---|---|
Snapshot.State |
ExampleActor.deserializeSnapshot(com.google.common.io.ByteSource snapshotBytes) |
Modifier and Type | Method and Description |
---|---|
void |
ExampleActor.applyRecoverySnapshot(Snapshot.State snapshotState) |
void |
ExampleActor.applySnapshot(Snapshot.State snapshotState) |
Modifier and Type | Method and Description |
---|---|
Snapshot.State |
SnapshotManager.convertSnapshot(com.google.common.io.ByteSource snapshotBytes) |
Snapshot.State |
NoopRaftActorSnapshotCohort.deserializeSnapshot(com.google.common.io.ByteSource snapshotBytes) |
Snapshot.State |
RaftActorSnapshotCohort.deserializeSnapshot(com.google.common.io.ByteSource snapshotBytes)
This method is called to de-serialize snapshot data that was previously serialized via
RaftActorSnapshotCohort.createSnapshot(akka.actor.ActorRef, java.util.Optional<java.io.OutputStream>)
to a State instance. |
Modifier and Type | Method and Description |
---|---|
void |
RaftActorRecoveryCohort.applyRecoverySnapshot(Snapshot.State snapshotState)
This method is called during recovery to reconstruct the state of the actor.
|
void |
NoopRaftActorSnapshotCohort.applySnapshot(Snapshot.State snapshotState) |
void |
RaftActorSnapshotCohort.applySnapshot(Snapshot.State snapshotState)
This method is called to apply a snapshot installed by the leader.
|
void |
SnapshotState.persist(Snapshot.State snapshotState,
Optional<OutputStream> installSnapshotStream,
long totalMemory)
Persists a snapshot.
|
void |
SnapshotManager.persist(Snapshot.State state,
Optional<OutputStream> installSnapshotStream,
long totalMemory) |
Modifier and Type | Method and Description |
---|---|
Snapshot.State |
CaptureSnapshotReply.getSnapshotState() |
Constructor and Description |
---|
CaptureSnapshotReply(Snapshot.State snapshotState,
Optional<OutputStream> installSnapshotStream) |
Modifier and Type | Class and Description |
---|---|
class |
EmptyState
Empty Snapshot State implementation.
|
Modifier and Type | Method and Description |
---|---|
Snapshot.State |
Snapshot.getState() |
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.