Trait ObjectStoreClient 

pub trait ObjectStoreClient:
    Debug
    + Send
    + Sync {
    // Required methods
    fn put(
        &self,
        object_key: &str,
        bytes: &[u8],
        content_type: Option<&str>,
    ) -> Result<PathBuf, StorageExecutionError>;
    fn get(
        &self,
        object_key: &str,
    ) -> Result<(PathBuf, Vec<u8>), StorageExecutionError>;
    fn signed_get_url(
        &self,
        object_key: &str,
    ) -> Result<SignedObjectUrl, StorageExecutionError>;
}

Required Methods

fn put( &self, object_key: &str, bytes: &[u8], content_type: Option<&str>, ) -> Result<PathBuf, StorageExecutionError>

fn get( &self, object_key: &str, ) -> Result<(PathBuf, Vec<u8>), StorageExecutionError>

fn signed_get_url( &self, object_key: &str, ) -> Result<SignedObjectUrl, StorageExecutionError>

Implementors

impl ObjectStoreClient for S3CompatibleObjectStoreClient