Crate smelter_worker 

Common code used for communicating between the job manager and worker tasks.

Modules

stats

Worker statistics collection

Structs

SubtaskId

The ID for a subtask, which uniquely identifies it within a [Job].

WorkerError

A serializable error returned from a worker

WorkerInput

The input payload that a worker will read when starting

WorkerInputPayload

The input payload that a worker will read when starting

WorkerOutput

The output payload that the worker writes when a task finishes.

Enums

WorkerResult

The result of a worker task

WrapperError

An error that the worker wrapper framework may encounter

Functions

get_trace_context

Encode the current trace context so that it can be passed across process lines.

propagate_tracing_context

If tracing is enabled, propagate the trace context from the spawner into the current span.

run_worker

Run the worker and return its output, ready for writing back to the output payload location. Usually you will want to call the equivalent run_worker function in the platform-specific module instead.

trace_result

Trace the result of an operation.