Struct StepLogSender 

pub struct StepLogSender { /* private fields */ }

Step-scoped log sender with pre-filled metadata.

Wraps a LogSender with the run ID, step ID, and step name so that executors can emit lines without repeating metadata on every call.

Examples

use ironflow_engine::log_sender::{self, StepLogSender};
use ironflow_engine::notify::LogStream;
use uuid::Uuid;

let (sender, _rx) = log_sender::channel();
let step_sender = StepLogSender::new(
    sender,
    Uuid::now_v7(),
    Uuid::now_v7(),
    "deploy".to_string(),
);

step_sender.emit(LogStream::Stderr, "warning: deprecated API");

Implementations

impl StepLogSender

pub fn new( inner: LogSender, run_id: Uuid, step_id: Uuid, step_name: String, ) -> Self

Create a new step-scoped sender.

pub fn emit(&self, stream: LogStream, line: &str)

Emit a log line on the given stream.

Silently drops the line if the receiver has been closed.

Trait Implementations

impl Clone for StepLogSender

fn clone(&self) -> StepLogSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.