Struct NdjsonFileSink 

pub struct NdjsonFileSink { /* private fields */ }

File sink that writes envelopes as JSON lines to the underlying MakeWriter. Buffers a Mutex<ErasedWriter> per batch to avoid re-opening files for every event.

Implementations

impl NdjsonFileSink

pub fn new(rolling: RollingFileWriter) -> NdjsonFileSink

Build atop RollingFileWriter, the canonical file destination.

pub fn with_make_writer<M>(mw: M) -> NdjsonFileSink

where M: MakeWriter,

Build atop any MakeWriter (test harness, custom destinations).

pub fn written_total(&self) -> u64

Total events written successfully.

Trait Implementations

impl Debug for NdjsonFileSink

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

Formats the value using the given formatter.

impl Sink for NdjsonFileSink

fn deliver(&self, env: ScrubbedEnvelope<'_>)

Hand the envelope to the sink. Must not block; long IO is queued internally. Spec 11 § 4 / spec 14 § 5.

fn flush(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Flush in-flight batches; awaits IO if needed.

fn shutdown(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Shut down (drain + close). Idempotent.