Enum ObjectStore 

pub enum ObjectStore {
    S3Bucket(S3Bucket),
    LocalFsBucket(LocalFsBucket),
}

Variants

S3Bucket(S3Bucket)

LocalFsBucket(LocalFsBucket)

Implementations

impl ObjectStore

pub fn new(name: &str, config: Config) -> Result<ObjectStore, String>

pub fn name(&self) -> &str

pub fn config(&self) -> &Config

pub fn println_path(&self) -> String

pub async fn list_files( &self, prefix: Option<&str>, recursive: bool, max_keys: Option<u32>, filter: &Option<FileObjectFilter>, ) -> Result<Vec<FileObject>, LakestreamError>

pub async fn list_files_with_callback( &self, prefix: Option<&str>, recursive: bool, max_files: Option<u32>, filter: &Option<FileObjectFilter>, callback: CallbackWrapper<FileObject>, ) -> Result<(), LakestreamError>

pub async fn get_object( &self, key: &str, data: &mut Vec<u8>, ) -> Result<(), LakestreamError>

Trait Implementations

impl CallbackItem for ObjectStore

fn println_path(&self) -> String

impl Clone for ObjectStore

fn clone(&self) -> ObjectStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.