Enum CoordinatorToWorker 

pub enum CoordinatorToWorker {
    Registered {
        worker_id: WorkerId,
    },
    AssignPlan {
        plan: SerializedPlan,
    },
    AssignPythonJob {
        job: PythonPipelineJob,
    },
    CancelPlan {
        plan_id: PlanId,
    },
    StatusRequest,
    Ping,
}

Messages from Coordinator → Worker.

Variants

Registered

Accept worker registration.

Fields

worker_id: WorkerId

AssignPlan

Assign a native Soma plan for execution.

Fields

plan: SerializedPlan

AssignPythonJob

Assign a Python pipeline job (with environment isolation).

Fields

job: PythonPipelineJob

CancelPlan

Cancel a running plan/job.

Fields

plan_id: PlanId

StatusRequest

Request current status.

Ping

Ping for keepalive.

Trait Implementations

impl Clone for CoordinatorToWorker

fn clone(&self) -> CoordinatorToWorker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CoordinatorToWorker

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CoordinatorToWorker

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CoordinatorToWorker

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

where __S: Serializer,

Serialize this value into the given Serde serializer.