lance_io::object_store

Trait ObjectStoreExt

Source 
pub trait ObjectStoreExt {
    // Required methods
    fn exists<'life0, 'life1, 'async_trait>(
        &'life0 self,
        path: &'life1 Path,
    ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn read_dir_all<'a, 'life0, 'async_trait>(
        &'a self,
        dir_path: impl 'async_trait + Into<&'life0 Path> + Send,
        unmodified_since: Option<DateTime<Utc>>,
    ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'a, Result<ObjectMeta>>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'a: 'async_trait,
             'life0: 'async_trait;
}

Required Methods§

Source

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 Path, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Returns true if the file exists.

Source

fn read_dir_all<'a, 'life0, 'async_trait>( &'a self, dir_path: impl 'async_trait + Into<&'life0 Path> + Send, unmodified_since: Option<DateTime<Utc>>, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'a, Result<ObjectMeta>>>> + Send + 'async_trait>>
where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

Read all files (start from base directory) recursively

unmodified_since can be specified to only return files that have not been modified since the given time.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§