Skip to main content

MooncakeJsonlWriter

Struct MooncakeJsonlWriter 

Source
pub struct MooncakeJsonlWriter { /* private fields */ }
Expand description

JSONL writer for Mooncake rows plus an optional sidecar stream.

The sidecar stream is configured at construction time. Producers that do not emit sidecar metadata pass None for sidecar_path and never call Self::write_sidecar. When a sidecar path is configured, callers are responsible for choosing the path – this writer does not enforce a naming convention.

Implementations§

Source§

impl MooncakeJsonlWriter

Source

pub fn create(output_path: &Path, sidecar_path: Option<&Path>) -> Result<Self>

Create a writer at output_path, optionally with a paired sidecar JSONL file at sidecar_path. Parent directories are created as needed.

Source

pub fn write_row(&mut self, row: &MooncakeRow) -> Result<()>

Append one Mooncake row.

Source

pub fn write_agentic_row(&mut self, row: &AgenticMooncakeRow) -> Result<()>

Append one agentic Mooncake row.

Source

pub fn write_sidecar<S: Serialize>(&mut self, sidecar: &S) -> Result<()>

Append one sidecar entry. Errors if no sidecar was configured.

Source

pub fn has_sidecar(&self) -> bool

True if a sidecar stream is configured.

Source

pub fn stats(&self) -> WriterStats

Snapshot of how many rows and sidecar entries have been written so far.

Source

pub fn finish(self) -> Result<WriterStats>

Flush both streams and return the final stats.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.