Struct OutputSink 

pub struct OutputSink { /* private fields */ }

Sink for one task-run attempt.

Created by OutputRegistry when a runner starts an attempt; the runner pushes lines into it, subscribers (obtained via the registry) receive OutputEvents on the other end.

Implementations

impl OutputSink

pub fn new(sender: Sender<OutputEvent>, attempt: u32) -> Self

Build a sink wrapping the given broadcast Sender.

pub fn stdout_line(&self, line: Bytes)

Push one stdout line. No-op if no subscribers are attached.

line is bytes::Bytes (UTF-8): cloning is a refcount bump, so the same buffer is shared across every subscriber and all the way through to the gRPC bytes line wire field without an extra byte-copy.

pub fn stderr_line(&self, line: Bytes)

Push one stderr line. No-op if no subscribers are attached.

pub fn attempt(&self) -> u32

Which run attempt this sink belongs to.

Trait Implementations

impl Clone for OutputSink

fn clone(&self) -> OutputSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.