Struct FileOutput 

pub struct FileOutput { /* private fields */ }

Available on crate feature output-file only.

File output sink for raw NDJSON events.

Wraps NdjsonWriter with output-specific configuration and logging. Cheap to Clone – the inner writer is shared via Arc.

Implementations

impl FileOutput

pub fn new( config: &FileOutputConfig, service_name: &str, ) -> Result<Self, OutputError>

Create a new file output sink.

Creates the output directory if it doesn’t exist.

Arguments

• config – File output configuration
• service_name – Used as subdirectory name (e.g. “loader”, “receiver”)

Errors

Returns an error if the output directory cannot be created or the sink is disabled.

pub fn write(&self, data: &[u8]) -> Result<(), OutputError>

Write a single raw JSON bytes line (sync). Blocks the calling thread on disk I/O. Safe from sync code; never call from an async fn body – use Self::write_async instead.

pub fn write_batch(&self, data: &[&[u8]]) -> Result<(), OutputError>

Write a batch of raw JSON bytes lines (sync). Same caveats as Self::write – use Self::write_batch_async from async fn.

pub async fn write_async(&self, data: Vec<u8>) -> Result<(), OutputError>

Async write – runs the rotate-and-write on a blocking thread via tokio::task::spawn_blocking. Hot-path safe for async callers.

Errors

Returns the underlying OutputError from the sync writer, or an OutputError::Io if the blocking thread panicked.

pub async fn write_batch_async( &self, data: Vec<Vec<u8>>, ) -> Result<(), OutputError>

Async batch write – coalesces lines into a single buffer and runs the rotate-and-write on a blocking thread.

Errors

As Self::write_async.

pub fn lines_written(&self) -> u64

Number of lines successfully written.

pub fn write_errors(&self) -> u64

Number of write errors encountered.

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

Shared Arc<NdjsonWriter> for callers that need both sync and async access to the same underlying writer (e.g. building an crate::io::AsyncNdjsonWriter view).

Trait Implementations

impl Clone for FileOutput

fn clone(&self) -> FileOutput

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileOutput

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

Formats the value using the given formatter.