Struct DynamicStorageOptionsCredentialProvider 

pub struct DynamicStorageOptionsCredentialProvider { /* private fields */ }

AWS Credential Provider that delegates to StorageOptionsAccessor

This adapter converts storage options from a StorageOptionsAccessor into AWS-specific credentials that can be used with S3. All caching and refresh logic is handled by the accessor.

Future Work

TODO: Support AWS/GCP/Azure together in a unified credential provider. Currently this is AWS-specific. Needs investigation of how GCP and Azure credential refresh mechanisms work and whether they can be unified with AWS’s approach.

See: https://github.com/lance-format/lance/pull/4905#discussion_r2474605265

Implementations

impl DynamicStorageOptionsCredentialProvider

pub fn new(accessor: Arc<StorageOptionsAccessor>) -> Self

Create a new credential provider from a storage options accessor

pub fn from_provider(provider: Arc<dyn StorageOptionsProvider>) -> Self

Create a new credential provider from a storage options provider

This is a convenience constructor for backward compatibility. The refresh offset will be extracted from storage options using the refresh_offset_millis key, defaulting to 60 seconds.

Arguments

• provider - The storage options provider

pub fn from_provider_with_initial( provider: Arc<dyn StorageOptionsProvider>, initial_options: HashMap<String, String>, ) -> Self

Create a new credential provider with initial credentials

This is a convenience constructor for backward compatibility. The refresh offset will be extracted from initial_options using the refresh_offset_millis key, defaulting to 60 seconds.

Arguments

• provider - The storage options provider
• initial_options - Initial storage options to cache

Trait Implementations

impl CredentialProvider for DynamicStorageOptionsCredentialProvider

type Credential = AwsCredential

The type of credential returned by this provider

fn get_credential<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ObjectStoreResult<Arc<Self::Credential>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return a credential

impl Debug for DynamicStorageOptionsCredentialProvider

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

Formats the value using the given formatter.