Struct Atof Exporter

View as Markdown

Generated from cargo doc --no-deps -p nemo-relay -p nemo-relay-adaptive -p nemo-relay-ffi.

1pub struct AtofExporter { /* private fields */ }

Filesystem-backed Agent Trajectory Observability Format (ATOF) JSONL event exporter.

Implementations

impl AtofExporter

impl AtofExporter

new

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

Create a new exporter from config and open its output file.

path

pub fn path(&self) -> &Path

Return the output JSONL path.

subscriber

pub fn subscriber(&self) -> EventSubscriberFn

Return an event subscriber that writes one JSONL record per observed event.

register

pub fn register(&self, name: &str) -> Result<()>

Register this exporter globally under the given subscriber name.

deregister

pub fn deregister(&self, name: &str) -> Result<bool>

Deregister a global subscriber by name.

force_flush

pub fn force_flush(&self) -> Result<()>

Flush the underlying file and drain queued endpoint events.

shutdown

pub fn shutdown(&self) -> Result<()>

Shut down the exporter by flushing buffered data and closing endpoints.