| 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.