Struct OutputWriter 

pub struct OutputWriter<W: Write> { /* private fields */ }

Sink that streams each committed run to runs.csv and series.csv, and counts the rows by status.

A run’s series is written and flushed before its row in runs.csv, so every run in runs.csv has its whole series written.

Implementations

impl<W: Write> OutputWriter<W>

pub fn new( plan: Arc<Plan>, runs: RunsWriter<W>, series: SeriesWriter<W>, ) -> Self

Returns a writer for the runs of plan over writers whose headers are written.

pub fn write_run(&mut self, outcome: &RunOutcome) -> Result<()>

Writes the series of outcome, then its row, and flushes after each write.

Errors

Returns the error of a write or a flush.

Panics

Panics when the run’s config is not in the plan.

pub fn write_config_run( &mut self, outcome: &RunOutcome, config: &Config, ) -> Result<()>

Writes the series of outcome, a run of config, then its row, and flushes after each write.

A search writes its runs this way. Its configs are in no plan.

Errors

Returns the error of a write or a flush.

pub fn counts(&self) -> ResultCounts

Counts of the rows written so far.

pub fn finish(self) -> Result<(W, W)>

Flushes both writers, and returns them as the writers of runs.csv and series.csv.

Errors

Returns the error of a flush.

Trait Implementations

impl<W: Debug + Write> Debug for OutputWriter<W>

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

Formats the value using the given formatter.

impl<W: Write> RunSink for OutputWriter<W>

fn commit(&mut self, outcome: RunOutcome) -> Result<()>

Receives a finished run. Runs arrive on the calling thread in request order.

fn finished(&mut self, _outcome: &RunOutcome)

Sees a run as it finishes, before Self::commit receives it. Runs arrive on the calling thread in the order they finish.