Struct object_store::throttle::ThrottledStore

pub struct ThrottledStore<T: ObjectStore> { /* private fields */ }

Store wrapper that wraps an inner store with some sleep calls.

This can be used for performance testing.

Note that the behavior of the wrapper is deterministic and might not reflect real-world conditions!

Implementations

impl<T: ObjectStore> ThrottledStore<T>

pub fn new(inner: T, config: ThrottleConfig) -> Self

Create new wrapper with zero waiting times.

pub fn config_mut<F>(&self, f: F)where
    F: Fn(&mut ThrottleConfig),

Mutate config.

pub fn config(&self) -> ThrottleConfig

Return copy of current config.

Trait Implementations

impl<T: Debug + ObjectStore> Debug for ThrottledStore<T>

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

Formats the value using the given formatter.

impl<T: ObjectStore> Display for ThrottledStore<T>

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

Formats the value using the given formatter.

impl<T: ObjectStore> ObjectStore for ThrottledStore<T>

fn put<'life0, 'life1, 'async_trait>(
    &'life0 self,
    location: &'life1 Path,
    bytes: Bytes
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Save the provided bytes to the specified location.

fn put_multipart<'life0, 'life1, 'async_trait>(
    &'life0 self,
    _location: &'life1 Path
) -> Pin<Box<dyn Future<Output = Result<(MultipartId, Box<dyn AsyncWrite + Unpin + Send>)>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Get a multi-part upload that allows writing data in chunks

fn abort_multipart<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    _location: &'life1 Path,
    _multipart_id: &'life2 MultipartId
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,

Cleanup an aborted upload.

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

Return the bytes that are stored at the specified location.

fn get_range<'life0, 'life1, 'async_trait>(
    &'life0 self,
    location: &'life1 Path,
    range: Range<usize>
) -> Pin<Box<dyn Future<Output = Result<Bytes>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

Return the bytes that are stored at the specified location in the given byte range

fn get_ranges<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    location: &'life1 Path,
    ranges: &'life2 [Range<usize>]
) -> Pin<Box<dyn Future<Output = Result<Vec<Bytes>>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,

Return the bytes that are stored at the specified location in the given byte ranges

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

Return the metadata for the specified location

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

Delete the object at the specified location.

fn list<'life0, 'life1, 'async_trait>(
    &'life0 self,
    prefix: Option<&'life1 Path>
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'_, Result<ObjectMeta>>>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

List all the objects with the given prefix.

fn list_with_delimiter<'life0, 'life1, 'async_trait>(
    &'life0 self,
    prefix: Option<&'life1 Path>
) -> Pin<Box<dyn Future<Output = Result<ListResult>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,

List objects with the given prefix and an implementation specific delimiter. Returns common prefixes (directories) in addition to object metadata.

fn copy<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    from: &'life1 Path,
    to: &'life2 Path
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,

Copy an object from one path to another in the same object store.

fn rename<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    from: &'life1 Path,
    to: &'life2 Path
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,

Move an object from one path to another in the same object store.

fn copy_if_not_exists<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    from: &'life1 Path,
    to: &'life2 Path
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,

Copy an object from one path to another, only if destination is empty.

fn rename_if_not_exists<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    from: &'life1 Path,
    to: &'life2 Path
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,

Move an object from one path to another in the same object store.