Enum WorkerToCoordinator 

pub enum WorkerToCoordinator {
    Register {
        worker_id: WorkerId,
        capabilities: Capabilities,
    },
    Heartbeat {
        worker_id: WorkerId,
        load: LoadMetrics,
    },
    Event {
        worker_id: WorkerId,
        plan_id: PlanId,
        event: Event,
    },
    PlanResult {
        worker_id: WorkerId,
        plan_id: PlanId,
        result: PlanResult,
    },
    JobProgress {
        worker_id: WorkerId,
        job_id: String,
        phase: String,
        step: u32,
        total: u32,
        metrics: Value,
    },
    JobResult {
        worker_id: WorkerId,
        job_id: String,
        success: bool,
        metrics: Value,
        output: String,
        duration_ms: u64,
    },
    StateResult {
        worker_id: WorkerId,
        plan_id: PlanId,
        states: HashMap<String, Value>,
    },
    Error {
        message: String,
    },
    Ack {
        worker_id: WorkerId,
    },
    GradientsResult {
        worker_id: WorkerId,
        plan_id: PlanId,
        gradients: HashMap<String, Value>,
    },
}

Messages from Worker → Coordinator.

Variants

Register

Worker announces itself.

Fields

worker_id: WorkerId

The identity this worker will report in every later message.

capabilities: Capabilities

What the worker can run — the coordinator places plans by these.

Heartbeat

Periodic health check.

Fields

worker_id: WorkerId

Sender.

load: LoadMetrics

A load snapshot the coordinator reads for placement decisions.

Event

Execution event streamed back in real-time.

Fields

worker_id: WorkerId

Sender.

plan_id: PlanId

Which execution the event belongs to.

event: Event

The runtime event, forwarded verbatim.

PlanResult

Plan execution completed.

Fields

worker_id: WorkerId

Sender.

plan_id: PlanId

Which execution finished.

result: PlanResult

Success with its output, or failure with the error.

JobProgress

Python job progress update.

Fields

worker_id: WorkerId

Sender.

job_id: String

Which Python job is reporting.

phase: String

Coarse stage label (“environment”, “execute”, …).

step: u32

Which phase the job is in, 1-based.

total: u32

How many phases there are in total.

metrics: Value

Job-defined metrics at this point; {} when it has none yet.

JobResult

Python job result.

Fields

worker_id: WorkerId

Sender.

job_id: String

Which Python job finished.

success: bool

Whether the job’s process exited cleanly.

metrics: Value

The last JSON line the job printed to stdout — the job’s way of reporting final metrics; {} when it printed none.

output: String

Captured stdout on success; stderr followed by stdout on failure, so the traceback comes first.

duration_ms: u64

Wall-clock execution time in milliseconds.

StateResult

Response to GetState: trained filter states.

Fields

worker_id: WorkerId

Sender.

plan_id: PlanId

Which execution the states came from.

states: HashMap<String, Value>

Trained state per requested node id.

Error

A command failed, and the client can read why.

Without this variant an error was sent as a bare {"error": …}, which is not a WorkerToCoordinator at all — and the client skips what it cannot parse, so it waited for a reply that had already been sent, until the socket closed. Every failure the worker reported over WebSocket hung its caller.

Fields

message: String

What went wrong, as the worker saw it.

Ack

A command that produces no data succeeded.

SetState and ApplyGradients need a reply: the client blocks until it can parse one, so an unknown {"type":"Ack"} would leave it waiting until the socket closed.

Fields

worker_id: WorkerId

Sender.

GradientsResult

Response to GetGradients: gradient data.

Fields

worker_id: WorkerId

Sender.

plan_id: PlanId

Which execution produced the gradients.

gradients: HashMap<String, Value>

Gradient payload per requested node id, opaque bytes for the aggregator to combine.

Trait Implementations

impl Clone for WorkerToCoordinator

fn clone(&self) -> WorkerToCoordinator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerToCoordinator

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkerToCoordinator

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkerToCoordinator

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

where __S: Serializer,

Serialize this value into the given Serde serializer.