Expand description
Wire protocol for coordinator ↔ worker communication.
Defines message types for plan assignment, results, heartbeats, Python job management, and worker capabilities.
Structs§
- Capabilities
- Hardware and software capabilities of a worker.
- GpuInfo
- GPU hardware info.
- Load
Metrics - Current load metrics reported by a worker.
- Pipeline
File - A source file in a pipeline job.
- Python
Pipeline Job - A Python pipeline job: source files + requirements for isolated execution.
- Serialized
Filter - A serialized filter: cloudpickle bytes to reconstruct on the worker.
- Serialized
Plan - A serialized plan ready for remote execution.
Enums§
- Coordinator
ToWorker - Messages from Coordinator → Worker.
- Execution
Mode - Execution mode: fit (training) or forward (inference).
- Input
Source - How input data is provided to a worker.
- Output
Delivery - How output is delivered in PlanResult.
- Plan
Result - Result of a plan execution.
- Stream
Message - Streaming protocol: chunked data transfer over WebSocket Binary frames.
- Worker
ToCoordinator - Messages from Worker → Coordinator.