Struct AssignmentDrainTransition 

pub struct AssignmentDrainTransition {
    pub predecessor: CheckpointAssignmentFence,
    pub target: CheckpointAssignmentFence,
    pub leader: LeaderProof,
}

Exact predecessor-to-target transition at which every predecessor source must stop input.

Required drain participants always come from predecessor. A process that only joins the target has no predecessor input authority and therefore cannot block the drain quorum.

Fields

predecessor: CheckpointAssignmentFence

Assignment that remains authoritative through the pre-rotation checkpoint.

target: CheckpointAssignmentFence

Exact successor assignment to install after that checkpoint is durable.

leader: LeaderProof

Leader term that created the durable draining transition.

Implementations

impl AssignmentDrainTransition

pub fn new( predecessor: CheckpointAssignmentFence, target: CheckpointAssignmentFence, leader: LeaderProof, ) -> Result<Self, String>

Construct and validate one exact successor transition.

Errors

Returns an error when either certificate, the version relation, vnode count, or captured leader term is not canonical for the predecessor roster.

pub fn is_canonical(&self) -> bool

Whether the transition is an exact, authority-bound successor of the predecessor.

pub fn id(&self) -> AssignmentDrainId

Compact identity carried by source commands and receipts.

pub fn required_participants(&self) -> &[CheckpointParticipant]

Exact processes that must publish drain acknowledgements.

pub fn digest(&self) -> [u8; 32]

Stable SHA-256 binding both assignment maps, both process rosters, and the leader term.

Trait Implementations

impl Clone for AssignmentDrainTransition

fn clone(&self) -> AssignmentDrainTransition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AssignmentDrainTransition

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AssignmentDrainTransition

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for AssignmentDrainTransition

impl PartialEq for AssignmentDrainTransition

fn eq(&self, other: &AssignmentDrainTransition) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for AssignmentDrainTransition

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for AssignmentDrainTransition