Struct ObjectStoreConfig 

pub struct ObjectStoreConfig {
    pub set_atomic_write_dir: bool,
    pub retry: ObjectStoreRetryConfig,
    pub s3: S3ObjectStoreConfig,
    pub req_concurrency_limit: usize,
    pub http_concurrent_limit: usize,
    pub opendal_upload_concurrency: usize,
    pub opendal_writer_abort_on_err: bool,
    pub upload_part_size: usize,
}

The subsections [storage.object_store].

Fields

set_atomic_write_dir: bool

retry: ObjectStoreRetryConfig

Retry and timeout configuration Description retry strategy driven by exponential back-off Exposes the timeout and retries of each Object store interface. Therefore, the total timeout for each interface is determined based on the interface’s timeout/retry configuration and the exponential back-off policy.

s3: S3ObjectStoreConfig

Some special configuration of S3 Backend

req_concurrency_limit: usize

Maximum number of concurrent object store requests (read, streaming_read, metadata, etc.). 0 means unlimited. When set to a positive value, a semaphore will be used to limit the number of in-flight requests to the object store, preventing HTTP connection pool contention under high concurrency.

http_concurrent_limit: usize

Maximum number of concurrent HTTP requests used by the OpenDAL GCS backend. 0 means unlimited.

opendal_upload_concurrency: usize

opendal_writer_abort_on_err: bool

upload_part_size: usize

Implementations

impl ObjectStoreConfig

pub fn set_atomic_write_dir(&mut self)

Trait Implementations

impl Clone for ObjectStoreConfig

fn clone(&self) -> ObjectStoreConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObjectStoreConfig

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

Formats the value using the given formatter.

impl Default for ObjectStoreConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ObjectStoreConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ObjectStoreConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.