Struct FileAndSocketSink 

pub struct FileAndSocketSink { /* private fields */ }

An EventSink that writes JSON-lines to a log file and a Unix socket.

The log file is opened in append mode. A background thread accepts connections on a Unix domain socket; at most one client is served at a time. If no client is connected, socket writes are silently skipped.

Examples

use grafos_observe::file_socket_sink::FileAndSocketSink;
use std::path::Path;

let sink = FileAndSocketSink::new(
    Path::new("/tmp/fabric-events.jsonl"),
    Path::new("/tmp/fabric-events.sock"),
).expect("failed to create sink");

Implementations

impl FileAndSocketSink

pub fn new(log_path: &Path, socket_path: &Path) -> Result<Self>

Create a new sink writing to log_path (append-only) and listening on socket_path for a single Unix stream client at a time.

The socket file is removed if it already exists before binding.

Trait Implementations

impl EventSink for FileAndSocketSink

fn emit(&self, event: &FabricEvent)

Consume an event. Implementations should not block.