Skip to main content

read_stdin_feed

Function read_stdin_feed 

Source
pub fn read_stdin_feed(
    feed_tx: Sender<CliMessage>,
    worker_map: BiHashMap<u32, String>,
    origins: FeedOrigins,
    is_trace: bool,
    is_sessions: bool,
)
Expand description

Read target lines from stdin and forward them to the live feed.

Each line is a JSON object (e.g., {"dst":"1.1.1.1","worker":"ams01","origin":2}), or a bare address (e.g., 1.1.1.1). The optional worker field selects the probing worker(s): a worker ID, a hostname, a glob (e.g. us-* — probes the target from every matched worker, spaced by the worker interval), "all" (probe from all workers), or "any" (round-robin, default). The optional origin field selects the origin to send from: an origin ID, or "all" (all configured origins). Defaults to the first configured origin of the target’s IP version. The optional nprobes field sets how many measurement probes are sent to the target (default 1), spaced by the measurement’s probe interval. The optional ttl field (feed-trace only) sets the probe TTL (default 255) The optional session field (--sessions only) tags the target with a session; replies carry it back for attribution (ICMP/DNS-A only). Blocks when the feed channel is full (rate-limiting set by Orchestrator). Runs on a dedicated thread; dropping the sender (at EOF) signals the end of the feed.