Struct ObjectStoreStorageHandler 

pub struct ObjectStoreStorageHandler<E>
where
    E: TaskExecutor,
{ /* private fields */ }

Implementations

impl<E> ObjectStoreStorageHandler<E>

where E: TaskExecutor,

pub fn new( store: Arc<dyn ObjectStore>, task_executor: Arc<E>, ) -> ObjectStoreStorageHandler<E>

pub fn with_readahead(self, readahead: usize) -> ObjectStoreStorageHandler<E>

Set the maximum number of files to read in parallel.

Trait Implementations

impl<E> Debug for ObjectStoreStorageHandler<E>

where E: Debug + TaskExecutor,

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

Formats the value using the given formatter.

impl<E> StorageHandler for ObjectStoreStorageHandler<E>

where E: TaskExecutor,

fn read_files( &self, files: Vec<(Url, Option<Range<u64>>)>, ) -> Result<Box<dyn Iterator<Item = Result<Bytes, Error>>>, Error>

Read data specified by the start and end offset from the file.

This will return the data in the same order as the provided file slices.

Multiple reads may occur in parallel, depending on the configured readahead. See Self::with_readahead.

fn list_from( &self, path: &Url, ) -> Result<Box<dyn Iterator<Item = Result<FileMeta, Error>>>, Error>

Recursively list files whose full path is lexicographically greater than (UTF-8 sorting) the given path, restricted to descendants of path’s parent directory. The result must be sorted by the full path (UTF-8 byte order).

fn put(&self, path: &Url, data: Bytes, overwrite: bool) -> Result<(), Error>

Write data to the specified path.

fn copy_atomic(&self, src: &Url, dest: &Url) -> Result<(), Error>

Copy a file atomically from source to destination. If the destination file already exists, it must return Err(Error::FileAlreadyExists).

fn head(&self, path: &Url) -> Result<FileMeta, Error>

Perform a HEAD request for the given file at a Url, returning the file metadata.