Struct AzureConnection 

pub struct AzureConnection {
    pub container: String,
    pub account: Option<String>,
    pub auth: AzureCredentials,
    pub endpoint: Option<String>,
    pub allow_http: bool,
    pub use_emulator: bool,
}

Available on crate features source-azure-blob and source-rest only.

Connection parameters shared by the Azure source and sink.

Flattened into each connector’s config via #[serde(flatten)], so container, account, auth, … appear at the top level of the source / sink config.

Fields

container: String

Blob container / ADLS Gen2 filesystem name. Required.

account: Option<String>

Storage-account name. Optional when a connection string or the emulator supplies it, otherwise required.

auth: AzureCredentials

Credential source. Defaults to the environment / managed-identity credential chain.

endpoint: Option<String>

Custom blob endpoint (e.g. an Azurite emulator or a sovereign cloud).

allow_http: bool

Permit plaintext HTTP (required for a local Azurite emulator).

use_emulator: bool

Target the Azurite storage emulator with its well-known devstoreaccount1 credentials.

Implementations

impl AzureConnection

pub fn new(container: impl Into<String>) -> AzureConnection

New connection targeting container with default credentials.

pub fn account(self, account: impl Into<String>) -> AzureConnection

Set the storage-account name.

pub fn auth(self, auth: AzureCredentials) -> AzureConnection

Set the credential source.

pub fn endpoint(self, endpoint: impl Into<String>) -> AzureConnection

Set a custom blob endpoint (emulator / sovereign cloud).

pub fn allow_http(self, allow: bool) -> AzureConnection

Permit plaintext HTTP.

pub fn use_emulator(self, use_emulator: bool) -> AzureConnection

Target the Azurite emulator.

Trait Implementations

impl Clone for AzureConnection

fn clone(&self) -> AzureConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AzureConnection

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AzureConnection

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for AzureConnection

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 AzureConnection

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.