Enum MigrationMessage 

pub enum MigrationMessage {
    TakeSnapshot {
        daemon_origin: u64,
        target_node: u64,
    },
    SnapshotReady {
        daemon_origin: u64,
        snapshot_bytes: Vec<u8>,
        seq_through: u64,
        chunk_index: u32,
        total_chunks: u32,
    },
    RestoreComplete {
        daemon_origin: u64,
        restored_seq: u64,
    },
    ReplayComplete {
        daemon_origin: u64,
        replayed_seq: u64,
        target_head: CausalLink,
    },
    CutoverNotify {
        daemon_origin: u64,
        target_node: u64,
    },
    CleanupComplete {
        daemon_origin: u64,
    },
    MigrationFailed {
        daemon_origin: u64,
        reason: MigrationFailureReason,
    },
    BufferedEvents {
        daemon_origin: u64,
        events: Vec<CausalEvent>,
    },
    ActivateTarget {
        daemon_origin: u64,
    },
    ActivateAck {
        daemon_origin: u64,
        replayed_seq: u64,
    },
}

Wire message types for the migration subprotocol (0x0500).

Variants

TakeSnapshot

Phase 0→1: Request snapshot on source.

Fields

daemon_origin: u64

Origin hash of daemon to migrate.

target_node: u64

Destination node ID.

SnapshotReady

Phase 1→2: Snapshot taken, payload included.

Large snapshots are chunked across multiple SnapshotReady messages. The receiver must reassemble all chunks (0..total_chunks) before deserializing the snapshot. Single-chunk snapshots have chunk_index = 0, total_chunks = 1.

Fields

daemon_origin: u64

Origin hash of daemon being migrated.

snapshot_bytes: Vec<u8>

Serialized StateSnapshot bytes (or chunk thereof).

seq_through: u64

Sequence number the snapshot covers through.

chunk_index: u32

Zero-based index of this chunk.

total_chunks: u32

Total number of chunks for this snapshot.

RestoreComplete

Phase 2→3: Target restored daemon from snapshot.

Fields

daemon_origin: u64

Origin hash of daemon being migrated.

restored_seq: u64

Sequence number restored through.

ReplayComplete

Phase 3→4: Target finished replaying buffered events.

Fields

daemon_origin: u64

Origin hash of daemon being migrated.

replayed_seq: u64

Sequence number replayed through.

target_head: CausalLink

Target’s chain head after replay. The orchestrator stamps this into its SuperpositionState so continuity proofs carry the real cryptographic anchor even when the orchestrator lives on a third node and has no local daemon registry entry to read from.

CutoverNotify

Phase 4: Source stops accepting writes, routing switches.

Fields

daemon_origin: u64

Origin hash of daemon being migrated.

target_node: u64

Target node that is now authoritative.

CleanupComplete

Phase 5: Source cleaned up.

Fields

daemon_origin: u64

Origin hash of daemon whose migration is complete.

MigrationFailed

Any phase: Abort migration.

Fields

daemon_origin: u64

Origin hash of daemon whose migration failed.

reason: MigrationFailureReason

Structured reason code — source dispatches on this to decide whether the migration is retriable. See MigrationFailureReason.

BufferedEvents

Buffered events from source for replay on target.

Fields

daemon_origin: u64

Origin hash of daemon being migrated.

events: Vec<CausalEvent>

Events to replay, in causal order.

ActivateTarget

Phase 5→6: Source has cleaned up; target should now go live.

Emitted by the orchestrator once it observes CleanupComplete. The target calls MigrationTargetHandler::activate in response and replies with ActivateAck.

Fields

daemon_origin: u64

Origin hash of daemon whose target should activate.

ActivateAck

Phase 6: Target has activated and is now authoritative.

Fields

daemon_origin: u64

Origin hash of daemon whose migration is complete.

replayed_seq: u64

Sequence number the target is authoritative through.

Trait Implementations

impl Clone for MigrationMessage

fn clone(&self) -> MigrationMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MigrationMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.