Struct Provider 

pub struct Provider {
    pub name: String,
    pub config: StorageProvider,
    pub(crate) provider: Box<DynObjectStore>,
    pub(crate) base_path: Option<Path>,
    startup_check: bool,
    services: Arc<OnceServices>,
}

Fields

name: String

config: StorageProvider

provider: Box<DynObjectStore>

base_path: Option<Path>

startup_check: bool

services: Arc<OnceServices>

Implementations

impl Provider

pub(super) async fn start(self: &Arc<Self>) -> Result

impl Provider

async fn startup_check(self: &Arc<Self>) -> Result

impl Provider

pub async fn put<S, T>( &self, path: &str, size: Option<usize>, input: S, ) -> Result<PutResult>

where S: Stream<Item = Result<T>> + Send, PutPayload: From<T> + From<PutPayload>,

Put object into store from streaming input.

Recommended to know the total size of the object. If size is None, multi-part upload may be selected even for small uploads below the configured threshold.

impl Provider

pub async fn put_one<T>(&self, path: &str, input: T) -> Result<PutResult>

where PutPayload: From<T> + From<PutPayload>,

Put object into the store from contiguous input.

The size of input will be determined and multipart upload will be chosen as necessary internally.

impl Provider

async fn put_multi<S, T>(&self, path: &str, input: S) -> Result<PutResult>

where S: Stream<Item = Result<T>> + Send, PutPayload: From<T> + From<PutPayload>,

Put object into the store from streaming input using multipart upload.

impl Provider

async fn put_single(&self, path: &str, input: PutPayload) -> Result<PutResult>

Put object into the store from contiguous input non-multipart upload.

impl Provider

pub fn fetch_with_metadata( &self, path: &str, ) -> impl Stream<Item = Result<FetchMetaItem>> + Send

impl Provider

pub fn fetch(&self, path: &str) -> impl Stream<Item = Result<FetchItem>> + Send

impl Provider

pub async fn get(&self, path: &str) -> Result<Bytes>

impl Provider

pub async fn load(&self, path: &str) -> Result<GetResult>

impl Provider

pub async fn delete_one(self: &Arc<Self>, path: &str) -> Result

impl Provider

pub fn delete<S>( self: &Arc<Self>, paths: S, ) -> impl Stream<Item = Result<Path>> + Send

where S: Stream<Item = String> + Send + 'static,

impl Provider

pub async fn rename(&self, src: &str, dst: &str, overwrite: CopyMode) -> Result

impl Provider

pub async fn copy(&self, src: &str, dst: &str, overwrite: CopyMode) -> Result

impl Provider

pub fn list( &self, prefix: Option<&str>, ) -> impl Stream<Item = Result<ObjectMeta>> + Send

impl Provider

pub async fn head(&self, path: &str) -> Result<ObjectMeta>

impl Provider

pub async fn ping(&self) -> Result

impl Provider

fn to_abs_path(&self, location: &str) -> Result<Path>

impl Provider

fn prepend_base_path(&self, location: Path) -> Path

impl Provider

fn strip_base_path(&self, location: Path) -> Path

impl Provider

fn multipart_threshold(&self) -> usize

impl Provider

fn multipart_part_size(&self) -> usize

Trait Implementations

impl Debug for Provider

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

Formats the value using the given formatter.