Enum ToLeader 

pub enum ToLeader {
    Acked {
        epoch: u64,
        contribution: Manifest,
    },
    Finished,
}

A worker’s report back to the leader. Acked = every local task reported epoch e, this worker’s objects/files are durable, and here is its manifest slice (source offsets, objects and files for the tasks it owns — keyed by global task id, so the leader merges every worker’s slice into the one manifest it writes). Finished = this worker’s whole graph drained. The leader waits for every worker before it commits an epoch or completes shutdown.

Variants

Acked

Fields

epoch: u64

contribution: Manifest

Finished

Trait Implementations

impl Clone for ToLeader

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ToLeader

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ToLeader

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ToLeader

impl PartialEq for ToLeader

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ToLeader

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 ToLeader