Struct StorageOptionsAccessor 

pub struct StorageOptionsAccessor { /* private fields */ }

Unified access to storage options with automatic caching and refresh

This struct bundles static storage options with an optional dynamic provider, handling all caching and refresh logic internally. It provides a single entry point for accessing storage options regardless of whether they’re static or dynamic.

Behavior

• If only static options are provided, returns those options
• If a provider is configured, fetches from provider and caches results
• Automatically refreshes cached options before expiration (based on refresh_offset)
• Uses expires_at_millis key to track expiration

Thread Safety

The accessor is thread-safe and can be shared across multiple tasks. Concurrent refresh attempts are deduplicated using a try-lock mechanism.

Implementations

impl StorageOptionsAccessor

pub fn with_static_options(options: HashMap<String, String>) -> Self

Create an accessor with only static options (no refresh capability)

The returned accessor will always return the provided options. This is useful when credentials don’t expire or are managed externally.

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

Create an accessor with a dynamic provider (no initial options)

The accessor will fetch from the provider on first access and cache the results. Refresh happens automatically before expiration. Uses the default refresh offset (60 seconds) until options are fetched.

Arguments

• provider - The storage options provider for fetching fresh options

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

Create an accessor with initial options and a dynamic provider

Initial options are used until they expire, then the provider is called. This avoids an immediate fetch when initial credentials are still valid. The refresh_offset_millis key in initial_options controls refresh timing.

Arguments

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

pub async fn get_storage_options(&self) -> Result<StorageOptions>

Get current valid storage options

• Returns cached options if not expired
• Fetches from provider if expired or not cached
• Falls back to initial_options if provider returns None

Errors

Returns an error if:

• The provider fails to fetch options
• No options are available (no cache, no provider, no initial options)

pub fn initial_storage_options(&self) -> Option<&HashMap<String, String>>

Get the initial storage options without refresh

Returns the initial options that were provided when creating the accessor. This does not trigger any refresh, even if the options have expired.

pub fn accessor_id(&self) -> String

Get the accessor ID for equality/hashing

Returns the provider_id if a provider exists, otherwise generates a stable ID from the initial options hash.

pub fn has_provider(&self) -> bool

Check if this accessor has a dynamic provider

pub fn refresh_offset(&self) -> Duration

Get the refresh offset duration

pub fn provider(&self) -> Option<&Arc<dyn StorageOptionsProvider>>

Get the storage options provider, if any

Trait Implementations

impl Debug for StorageOptionsAccessor

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

Formats the value using the given formatter.