Struct OpenDalResolvingStorageFactory 

pub struct OpenDalResolvingStorageFactory { /* private fields */ }

A resolving storage factory that creates OpenDalResolvingStorage instances.

This factory accepts paths from any supported storage system and dynamically delegates operations to the appropriate OpenDalStorage variant based on the path scheme.

Example

use std::sync::Arc;
use iceberg::io::FileIOBuilder;
use iceberg_storage_opendal::OpenDalResolvingStorageFactory;

let factory = OpenDalResolvingStorageFactory::new();
let file_io = FileIOBuilder::new(Arc::new(factory))
    .with_prop("s3.region", "us-east-1")
    .build();

Implementations

impl OpenDalResolvingStorageFactory

pub fn new() -> Self

Create a new resolving storage factory.

pub fn with_s3_credential_loader( self, loader: CustomAwsCredentialLoader, ) -> Self

Set a custom AWS credential loader for S3 storage.

Trait Implementations

impl Clone for OpenDalResolvingStorageFactory

fn clone(&self) -> OpenDalResolvingStorageFactory

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OpenDalResolvingStorageFactory

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

Formats the value using the given formatter.

impl Default for OpenDalResolvingStorageFactory

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for OpenDalResolvingStorageFactory

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OpenDalResolvingStorageFactory

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StorageFactory for OpenDalResolvingStorageFactory

fn build(&self, config: &StorageConfig) -> Result<Arc<dyn Storage>>

Build a new Storage instance from the given configuration.