Struct lance_core::io::object_store::ObjectStoreParams

pub struct ObjectStoreParams {
    pub block_size: Option<usize>,
    pub object_store: Option<(Arc<DynObjectStore>, Url)>,
    pub commit_handler: Option<Arc<dyn CommitHandler>>,
    pub s3_credentials_refresh_offset: Duration,
    pub aws_credentials: Option<AwsCredentialProvider>,
    pub object_store_wrapper: Option<Arc<dyn WrappingObjectStore>>,
    pub storage_options: Option<HashMap<String, String>>,
}

Parameters to create an ObjectStore

Fields

block_size: Option<usize>

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

commit_handler: Option<Arc<dyn CommitHandler>>

s3_credentials_refresh_offset: Duration

aws_credentials: Option<AwsCredentialProvider>

object_store_wrapper: Option<Arc<dyn WrappingObjectStore>>

storage_options: Option<HashMap<String, String>>

Implementations

impl ObjectStoreParams

pub fn set_commit_lock<T: CommitLock + Send + Sync + 'static>( &mut self, lock: Arc<T> )

Set a commit lock for the object store.

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

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

Trait Implementations

impl Clone for ObjectStoreParams

fn clone(&self) -> ObjectStoreParams

Returns a copy 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.