Struct EventEmitter 

pub struct EventEmitter { /* private fields */ }

Appends structured events to a JSONL file. Cheap to clone (just a path); the emitter holds no long-lived file descriptor, so rotation cannot strand a stale fd (Concurrency invariant: “open with O_APPEND per emission”).

Implementations

impl EventEmitter

pub fn new(path: impl Into<PathBuf>, source: impl Into<String>) -> Self

Construct an emitter writing to path, tagging every line with source (e.g. "daemon", "worker:wkA") so consumers can filter by emitter when cross-emitter ordering matters.

pub fn emit<P: Serialize>( &self, kind: &str, payload: &P, ) -> Result<(), EmitError>

Emit kind with a structured payload. The payload must serialize to a JSON object; the emitter frames it as {ts, type: kind, source, data} (wall-clock RFC3339 ts), so payload keys live under data and never collide with the envelope fields.

Returns Ok(()) on a successful append. An oversized payload is NOT an error to the caller: the meta-event is written and Ok(()) returned, so callers cannot accidentally treat “too large” as “not emitted”.

pub fn emit_fields( &self, kind: &str, fields: Map<String, Value>, ) -> Result<(), EmitError>

Emit an event whose payload is built ad-hoc as a JSON object. Convenience for call sites that assemble fields inline rather than via a struct.

pub fn path(&self) -> &Path

Path this emitter writes to (test/inspection helper).

Trait Implementations

impl Clone for EventEmitter

fn clone(&self) -> EventEmitter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventEmitter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.