Struct JsonlFileSink 

pub struct JsonlFileSink { /* private fields */ }

Implementations

impl JsonlFileSink

pub async fn open(path: impl AsRef<Path>) -> Result<Self, SinkError>

Open or create JSONL sink file in append mode. Side effects: filesystem open/create. Complexity: O(1).

pub async fn open_with_policy( path: impl AsRef<Path>, flush_policy: JsonlFlushPolicy, ) -> Result<Self, SinkError>

Open JSONL sink with explicit flush policy. Side effects: filesystem open/create. Complexity: O(1).

Trait Implementations

impl Debug for JsonlFileSink

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

Formats the value using the given formatter.

impl EventSink for JsonlFileSink

fn on_envelope<'a>(&'a self, envelope: &'a Envelope) -> EventSinkFuture<'a>

Serialize one envelope and append a trailing newline. Allocation: one JSON byte vector. Complexity: O(n), n = serialized envelope bytes.