Struct LoggingEngine 

pub struct LoggingEngine { /* private fields */ }

The non-blocking logging engine.

Internally holds a sender to a tokio mpsc channel. All heavy I/O happens in a background task on a dedicated tokio runtime thread.

Implementations

impl LoggingEngine

pub fn new(config: ExperimentConfig) -> Result<Self>

Create a new LoggingEngine for the given config.

This initializes the run directory, writes initial metadata, and spawns the background I/O task.

pub fn log_metrics( &self, values: HashMap<String, MetricValue>, step: Option<u64>, )

Log a row of metrics. Non-blocking — channel send only.

pub fn log_params(&self, params: HashMap<String, Value>)

Log/update experiment parameters (config). Non-blocking.

pub fn save_artifact(&self, path: PathBuf)

Save an artifact file asynchronously. Non-blocking. The path is relative to the current working directory for the source, and will be preserved as a relative path within the run’s artifacts directory.

pub fn log_message(&self, level: LogLevel, message: String)

Log a message to the run log. Non-blocking.

pub async fn flush(&self) -> Result<()>

Force flush the metric buffer to disk. Async — awaits completion.

pub fn close(&self, status: RunStatus)

Gracefully shut down: flush all pending metrics, write final metadata. Blocks until complete. Should be called at experiment end.

pub fn config(&self) -> &ExperimentConfig

Trait Implementations

impl Drop for LoggingEngine

fn drop(&mut self)

Executes the destructor for this type.