Struct WriterConnectConfig 

pub struct WriterConnectConfig {
    pub uri: String,
    pub storage_options: Option<AHashMap<String, String>>,
    pub rotation_config: RotationConfig,
    pub flush_interval_ms: Option<u64>,
    pub record_filter: Option<WriterRecordFilter>,
    pub params: Option<Params>,
}

Connection settings handed to writer factories.

Fields

uri: String

Run-session storage URI the writer stages into.

storage_options: Option<AHashMap<String, String>>

Backend-specific storage options (credentials, endpoints).

rotation_config: RotationConfig

Rotation settings used by built-in streaming writer backends.

flush_interval_ms: Option<u64>

Optional automatic flush interval in milliseconds.

record_filter: Option<WriterRecordFilter>

Optional record-family and identifier filter.

params: Option<Params>

Backend-specific writer parameters.

Implementations

impl WriterConnectConfig

pub fn new( uri: impl Into<String>, storage_options: Option<AHashMap<String, String>>, ) -> Self

Creates a connect config for the given URI.

Trait Implementations

impl Clone for WriterConnectConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WriterConnectConfig

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

Formats the value using the given formatter.