Struct ObjectStoreParams 

pub struct ObjectStoreParams {
    pub block_size: Option<usize>,
    pub object_store: Option<(Arc<DynObjectStore>, Url)>,
    pub s3_credentials_refresh_offset: Duration,
    pub aws_credentials: Option<AwsCredentialProvider>,
    pub object_store_wrapper: Option<Arc<dyn WrappingObjectStore>>,
    pub storage_options_accessor: Option<Arc<StorageOptionsAccessor>>,
    pub use_constant_size_upload_parts: bool,
    pub list_is_lexically_ordered: Option<bool>,
}

Parameters to create an ObjectStore

Fields

block_size: Option<usize>

object_store: Option<(Arc<DynObjectStore>, Url)>

👎Deprecated: Implement an ObjectStoreProvider instead

s3_credentials_refresh_offset: Duration

Refresh offset for AWS credentials when using the legacy AWS credentials path. For StorageOptionsAccessor, use refresh_offset_millis storage option instead.

aws_credentials: Option<AwsCredentialProvider>

object_store_wrapper: Option<Arc<dyn WrappingObjectStore>>

storage_options_accessor: Option<Arc<StorageOptionsAccessor>>

Unified storage options accessor with caching and automatic refresh

Provides storage options and optionally a dynamic provider for automatic credential refresh. Use StorageOptionsAccessor::with_static_options() for static options or StorageOptionsAccessor::with_initial_and_provider() for dynamic refresh.

use_constant_size_upload_parts: bool

Use constant size upload parts for multipart uploads. Only necessary for Cloudflare R2, which doesn’t support variable size parts. When this is false, max upload size is 2.5TB. When this is true, the max size is 50GB.

list_is_lexically_ordered: Option<bool>

Implementations

impl ObjectStoreParams

pub fn with_aws_credentials( aws_credentials: Option<AwsCredentialProvider>, region: Option<String>, ) -> Self

Create a new instance of ObjectStoreParams based on the AWS credentials.

impl ObjectStoreParams

pub fn get_accessor(&self) -> Option<Arc<StorageOptionsAccessor>>

Get the StorageOptionsAccessor from the params

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

Get storage options from the accessor, if any

Returns the initial storage options from the accessor without triggering refresh.

Trait Implementations

impl Clone for ObjectStoreParams

fn clone(&self) -> ObjectStoreParams

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObjectStoreParams

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

Formats the value using the given formatter.

impl Default for ObjectStoreParams

fn default() -> Self

Returns the “default value” for a type.

impl Hash for ObjectStoreParams

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for ObjectStoreParams

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ObjectStoreParams