Enum CoordinationMessage

pub enum CoordinationMessage {
    CoordinationRequest {
        workflow_id: WorkflowId,
        requester: String,
        participants: Vec<String>,
        timeout: Duration,
    },
    CoordinationAccept {
        workflow_id: WorkflowId,
        participant: String,
        capabilities: NodeCapabilities,
    },
    CoordinationReject {
        workflow_id: WorkflowId,
        participant: String,
        reason: String,
    },
    WorkflowStart {
        workflow_id: WorkflowId,
        stage_assignments: HashMap<StageId, String>,
    },
    StageAssignment {
        workflow_id: WorkflowId,
        stage_id: StageId,
        assigned_to: String,
    },
    StageStatusUpdate {
        workflow_id: WorkflowId,
        stage_id: StageId,
        status: StageStatus,
        metrics: StageMetrics,
    },
    SyncBarrier {
        workflow_id: WorkflowId,
        barrier_id: String,
        participants: Vec<String>,
    },
    BarrierReady {
        workflow_id: WorkflowId,
        barrier_id: String,
        participant: String,
    },
    WorkflowComplete {
        workflow_id: WorkflowId,
        result: WorkflowCoordinationResult,
    },
    Heartbeat {
        workflow_id: WorkflowId,
        participant: String,
        timestamp_ms: u64,
    },
    ErrorNotification {
        workflow_id: WorkflowId,
        participant: String,
        error: String,
    },
}

Coordination message types

Variants

CoordinationRequest

Request to coordinate a workflow

Fields

workflow_id: WorkflowId

requester: String

participants: Vec<String>

timeout: Duration

CoordinationAccept

Accept coordination request

Fields

workflow_id: WorkflowId

participant: String

capabilities: NodeCapabilities

CoordinationReject

Reject coordination request

Fields

workflow_id: WorkflowId

participant: String

reason: String

WorkflowStart

Start workflow execution

Fields

workflow_id: WorkflowId

stage_assignments: HashMap<StageId, String>

StageAssignment

Stage assignment

Fields

workflow_id: WorkflowId

stage_id: StageId

assigned_to: String

StageStatusUpdate

Stage status update

Fields

workflow_id: WorkflowId

stage_id: StageId

status: StageStatus

metrics: StageMetrics

SyncBarrier

Synchronization barrier

Fields

workflow_id: WorkflowId

barrier_id: String

participants: Vec<String>

BarrierReady

Barrier ready signal

Fields

workflow_id: WorkflowId

barrier_id: String

participant: String

WorkflowComplete

Workflow completion notification

Fields

workflow_id: WorkflowId

result: WorkflowCoordinationResult

Heartbeat

Heartbeat message

Fields

workflow_id: WorkflowId

participant: String

timestamp_ms: u64

ErrorNotification

Error notification

Fields

workflow_id: WorkflowId

participant: String

error: String

Trait Implementations

impl Clone for CoordinationMessage

fn clone(&self) -> CoordinationMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CoordinationMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CoordinationMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CoordinationMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.