Struct Atof Exporter
Generated from cargo doc --no-deps -p nemo-relay -p nemo-relay-adaptive -p nemo-relay-ffi.
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.