Modules§
- cli 🔒
- config 🔒
- result_
handler 🔒 - service 🔒
- task_
distributor 🔒 - trace 🔒
- worker 🔒
Structs§
- Controller
Service - The main orchestrator service struct.
- Live
State - State for a live (feed-based) measurement.
- Measurement
State - All state associated with a single active measurement.
- Participant
- A worker participating in the active measurement. Participants can re-join after disconnect.
- Pending
Target - A live target awaiting a discovery reply before it is probed (or given up on timeout).
- Traceroute
Config - Traceroute configuration
Enums§
- Access
- Which client(s) this Orchestrator service accepts.
- Worker
Sel - Worker selection of a live-feed target (parsed from
LiveTarget.worker_ids).
Constants§
- LIVE_
DISCOVERY_ TIMEOUT_ SECS - Timeout for live-feed discovery probes
Functions§
- serve 🔒
- Serve the controller on
[::]:port, optionally with TLS. - start
- Starts the orchestrator on the specified port.
- wire_
nprobes - Encode nprobes 1 as 0 for gRPC compression
Type Aliases§
- CliHandle 🔒
- CliSender 🔒
- Measurement
Handle - Shared handle to the active measurement state.
Nonewhen no measurement is running. - Result
Message 🔒 - Task
Message 🔒 - Worker
Registry 🔒 - Shared registry of connected worker senders. Updated when a worker reconnects.