Struct StdoutSinkConfig 

pub struct StdoutSinkConfig {
    pub destination: StdStream,
    pub format: StdoutFormat,
    pub flush_per_record: bool,
    pub max_records: Option<usize>,
    pub batch_size: usize,
}

Available on crate feature sink-stdout only.

Configuration for the stdout/stderr sink.

Fields

destination: StdStream

Which standard stream to write to.

format: StdoutFormat

Output format.

flush_per_record: bool

Flush the underlying writer after every record instead of at batch boundaries. Tradeoff: lower latency for live preview, slightly lower throughput.

max_records: Option<usize>

Stop writing after this many records have been emitted. Subsequent write_batch calls become no-ops. None means unlimited.

batch_size: usize

Records per upstream StreamPage. The stdout sink writes records to the chosen standard stream one at a time through a buffered writer, so this field has no behavioural impact at the sink — it is exposed purely for config parity across every sink in the workspace. Defaults to DEFAULT_BATCH_SIZE.

batch_size = 0 (the “no batching” sentinel) and any positive value produce byte-for-byte identical output for this sink: each record is serialised and written individually regardless of how upstream chunked the page.

Implementations

impl StdoutSinkConfig

pub fn new() -> StdoutSinkConfig

Create a new config with all defaults (stdout, JSON Lines, no limit).

pub fn destination(self, destination: StdStream) -> StdoutSinkConfig

Send records to the given standard stream.

pub fn format(self, format: StdoutFormat) -> StdoutSinkConfig

Choose the output format.

pub fn flush_per_record(self, flush_per_record: bool) -> StdoutSinkConfig

Flush after every record.

pub fn max_records(self, max_records: usize) -> StdoutSinkConfig

Stop after writing n records total.

pub fn with_batch_size(self, batch_size: usize) -> StdoutSinkConfig

Set the per-page record count hint reported alongside other sink configs.

This sink writes per-record through a buffered writer, so the value is observably a no-op: 0 (the “no batching” sentinel) and any positive value produce the same stdout/stderr output. Present for symmetry with sinks whose batch_size does drive I/O sizing (e.g. SQL multi-row inserts, BigQuery streaming inserts).

Trait Implementations

impl Clone for StdoutSinkConfig

fn clone(&self) -> StdoutSinkConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StdoutSinkConfig

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

Formats the value using the given formatter.

impl Default for StdoutSinkConfig

fn default() -> StdoutSinkConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StdoutSinkConfig

fn deserialize<__D>( __deserializer: __D, ) -> Result<StdoutSinkConfig, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for StdoutSinkConfig

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for StdoutSinkConfig

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.