Struct JsonEventSink 

pub struct JsonEventSink;

An EventSink that serializes events as one-line JSON to stdout.

Each event is output as a single JSON object on one line, suitable for ingestion by log aggregation systems (ELK, Loki, CloudWatch, etc.).

Fields vary by event type but always include event_type.

Examples

use grafos_observe::json_log::JsonEventSink;
use grafos_observe::{FabricEvent, EventSink};
use grafos_observe::event::OpType;

let event = FabricEvent::OpCompleted {
    op_type: OpType::Write,
    duration_us: 500,
    bytes: 1024,
};

// Format without printing
let json = JsonEventSink::format_event(&event);
assert!(json.contains(r#""event_type":"op_completed""#));
assert!(json.contains(r#""duration_us":500"#));

Implementations

impl JsonEventSink

pub fn format_event(event: &FabricEvent) -> String

Format a FabricEvent as a JSON string.

The output always includes timestamp, layer, and event_type fields, followed by event-specific fields.

Trait Implementations

impl EventSink for JsonEventSink

fn emit(&self, event: &FabricEvent)

Consume an event. Implementations should not block.