Enum StateProviderEvent 

pub enum StateProviderEvent {
    UpdateEpoch {
        epoch: Epoch,
        previous_epoch_last_lsn: Lsn,
        reply: Sender<Result<()>>,
    },
    GetLastCommittedLsn {
        reply: Sender<Result<Lsn>>,
    },
    GetCopyContext {
        reply: Sender<Result<OperationStream>>,
    },
    GetCopyState {
        up_to_lsn: Lsn,
        copy_context: OperationStream,
        reply: Sender<Result<OperationStream>>,
    },
    OnDataLoss {
        reply: Sender<Result<bool>>,
    },
}

State provider callbacks delivered on the state_provider channel. Role-specific.

Variants

UpdateEpoch

Epoch changed (secondaries only). Primary gets epoch via ChangeRole, not UpdateEpoch. Operations with LSN above previous_epoch_last_lsn from the old epoch may be stale (uncommitted zombie primary writes).

Fields

epoch: Epoch

previous_epoch_last_lsn: Lsn

reply: Sender<Result<()>>

GetLastCommittedLsn

“What’s your last applied LSN?” (secondary, during build/catchup)

Fields

reply: Sender<Result<Lsn>>

GetCopyContext

“What state do you already have?” (new idle secondary, during build)

Fields

reply: Sender<Result<OperationStream>>

GetCopyState

“Produce state for this secondary” (primary, during build_replica)

Fields

up_to_lsn: Lsn

copy_context: OperationStream

reply: Sender<Result<OperationStream>>

OnDataLoss

“Quorum was lost, data loss possible” (new primary after quorum loss)

Fields

reply: Sender<Result<bool>>