Struct AsyncNdjsonWriter 

pub struct AsyncNdjsonWriter { /* private fields */ }

Available on crate feature io only.

Async wrapper around NdjsonWriter that runs the sync rotate-and-write on tokio::task::spawn_blocking to keep the tokio runtime unblocked.

Use this from async fn bodies. For sync code paths, call NdjsonWriter directly.

Holds an Arc<NdjsonWriter> so multiple async tasks can share one writer without cloning the underlying parking_lot::Mutex<FileRotate>.

Implementations

impl AsyncNdjsonWriter

pub fn new(writer: NdjsonWriter) -> Self

Wrap an NdjsonWriter. Use this when no other task needs the underlying writer.

pub fn from_arc(writer: Arc<NdjsonWriter>) -> Self

Wrap a shared Arc<NdjsonWriter>. Use this when sync code paths also need access to the same writer.

pub async fn write_line(&self, line: Vec<u8>) -> Result<(), Error>

Write a single line off-runtime. The closure runs on a blocking thread; the tokio runtime is free to schedule other tasks.

Errors

Returns the underlying std::io::Error from the sync writer, or an io::Error::other(JoinError) if the blocking thread panicked.

pub async fn write_buf(&self, buf: Vec<u8>, count: u64) -> Result<(), Error>

Write a pre-coalesced buffer of count lines off-runtime.

Errors

As Self::write_line.

pub async fn flush(&self) -> Result<(), Error>

Flush buffered bytes through the rotating writer off-runtime.

See NdjsonWriter::flush for durability semantics – currently flushes to kernel page cache only (the file-rotate crate doesn’t expose the inner File for fsync).

Errors

As Self::write_line.

pub fn lines_written(&self) -> u64

Number of lines successfully written.

pub fn write_errors(&self) -> u64

Number of write errors.

pub fn label(&self) -> &str

Human label.

pub fn output_path(&self) -> &Path

Output directory path.

pub fn shared(&self) -> Arc<NdjsonWriter>

Shared Arc<NdjsonWriter> for code paths that need sync access.

Trait Implementations

impl Clone for AsyncNdjsonWriter

fn clone(&self) -> AsyncNdjsonWriter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AsyncNdjsonWriter

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

Formats the value using the given formatter.