Struct CsvEchoSink 

pub struct CsvEchoSink { /* private fields */ }

A sink plugin that formats records as CSV-like lines into a String buffer.

Configuration

Accepts a JSON object with an optional delimiter field (single character, defaults to ,).

{ "delimiter": ";" }

Implementations

impl CsvEchoSink

pub fn new() -> Self

Create a new CsvEchoSink with default settings.

pub fn lines(&self) -> &[String]

Return a reference to the accumulated output lines.

pub fn record_count(&self) -> usize

Return the total number of records written.

Trait Implementations

impl Default for CsvEchoSink

fn default() -> Self

Returns the “default value” for a type.

impl SinkPlugin for CsvEchoSink

fn name(&self) -> &str

Unique name identifying this sink.

fn initialize(&mut self, config: &Value) -> Result<(), SynthError>

Initialize the sink with configuration.

fn write_records( &mut self, records: &[GeneratedRecord], ) -> Result<usize, SynthError>

Write a batch of records. Returns number of records written.

fn finalize(&mut self) -> Result<SinkSummary, SynthError>

Finalize the sink and return a summary.