Struct RedshiftSinkConfig 

pub struct RedshiftSinkConfig {
    pub connection: RedshiftConnection,
    pub table_name: String,
    pub schema: Option<String>,
    pub write_strategy: RedshiftWriteStrategy,
    pub copy_format: RedshiftCopyFormat,
    pub staging_bucket: Option<String>,
    pub staging_prefix: String,
    pub iam_role: Option<String>,
    pub region: Option<String>,
    pub endpoint_url: Option<String>,
    pub batch_size: usize,
    pub max_connections: u32,
}

Available on crate feature sink-redshift only.

Configuration for the Amazon Redshift sink.

Fields

connection: RedshiftConnection

Connection block (host / port / database / user / credentials / tls), flattened to the config top level.

table_name: String

Target table name.

schema: Option<String>

Optional schema (namespace) qualifying table_name.

write_strategy: RedshiftWriteStrategy

How rows are loaded. Defaults to RedshiftWriteStrategy::Copy.

copy_format: RedshiftCopyFormat

Staged-file format for the COPY path. Defaults to RedshiftCopyFormat::Jsonl. Ignored by the insert strategy.

staging_bucket: Option<String>

S3 bucket used to stage COPY files. Required when write_strategy: copy.

staging_prefix: String

Key prefix for staged objects (e.g. redshift-staging/). Defaults to empty.

iam_role: Option<String>

IAM role ARN Redshift assumes to read the staged file (COPY … IAM_ROLE '<arn>'). Required when write_strategy: copy.

region: Option<String>

AWS region of the staging bucket (used for both the S3 client and the COPY … REGION '<region>' clause). None uses the SDK default.

endpoint_url: Option<String>

Custom endpoint URL for S3-compatible services (e.g. MinIO) — testing aid; production loads use real S3.

batch_size: usize

Rows per load unit. For insert, the per-statement multi-row chunk size; for copy, the number of rows per staged S3 object. Defaults to DEFAULT_BATCH_SIZE. 0 = one unit for the whole page.

max_connections: u32

Maximum number of connections in the pool. Defaults to 5.

Implementations

impl RedshiftSinkConfig

pub fn validate(&self) -> Result<(), FaucetError>

Validate the config. Enforces that the copy strategy has a staging bucket and IAM role.

Trait Implementations

impl Clone for RedshiftSinkConfig

fn clone(&self) -> RedshiftSinkConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedshiftSinkConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RedshiftSinkConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for RedshiftSinkConfig

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 RedshiftSinkConfig

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.