Struct NdjsonWriter 

pub struct NdjsonWriter { /* private fields */ }

Channel-based async NDJSON writer that decouples the hot path from disk I/O.

Broadcast sites call write_record() which serializes to Vec<u8> and does a non-blocking mpsc::send() — no lock, no disk I/O on the hot path. A dedicated tokio task owns the BufWriter and flushes on a timer.

Implementations

impl NdjsonWriter

pub fn new<W: Write + Send + 'static>(writer: W) -> Self

Spawn a dedicated writer task that owns writer exclusively.

Accepts W: Write + Send + 'static so callers can pass File, BufWriter<File>, or a future rotation-aware writer without changing any broadcast site code.

pub fn write_record<T: Serialize>(&self, msg: &T)

Serialize msg to NDJSON and enqueue for writing. Non-blocking. If the writer task has died (channel closed), the record is silently dropped.