Struct mz_storage::client::connections::ConnectionContext

pub struct ConnectionContext {
    pub librdkafka_log_level: Level,
    pub aws_external_id_prefix: Option<AwsExternalIdPrefix>,
    pub secrets_reader: Arc<dyn SecretsReader>,
}

Extra context to pass through when instantiating a connection for a source or sink.

Should be kept cheaply cloneable.

Fields

librdkafka_log_level: Level

The level for librdkafka’s logs.

aws_external_id_prefix: Option<AwsExternalIdPrefix>

A prefix for an external ID to use for all AWS AssumeRole operations.

secrets_reader: Arc<dyn SecretsReader>

A secrets reader.

Implementations

impl ConnectionContext

pub fn from_cli_args(
    filter: &Targets,
    aws_external_id_prefix: Option<String>,
    secrets_reader: Arc<dyn SecretsReader>
) -> ConnectionContext

Constructs a new connection context from command line arguments.

WARNING: it is critical for security that the aws_external_id be provided by the operator of the Materialize service (i.e., via a CLI argument or environment variable) and not the end user of Materialize (e.g., via a configuration option in a SQL statement). See AwsExternalIdPrefix for details.

pub fn for_tests(secrets_reader: Arc<dyn SecretsReader>) -> ConnectionContext

Constructs a new connection context for usage in tests.

Trait Implementations

impl Clone for ConnectionContext

fn clone(&self) -> ConnectionContext

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionContext

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

Formats the value using the given formatter.