Struct MonitoredObjectStore

pub struct MonitoredObjectStore<OS: ObjectStore> {
    inner: OS,
    object_store_metrics: Arc<ObjectStoreMetrics>,
    config: Arc<ObjectStoreConfig>,
}

Fields

inner: OS

object_store_metrics: Arc<ObjectStoreMetrics>

config: Arc<ObjectStoreConfig>

Implementations

impl<OS: ObjectStore> MonitoredObjectStore<OS>

Manually dispatch trait methods.

The metrics are updated in the following order:

• Write operations
  • write_bytes
  • operation_size
  • start operation_latency timer
  • failure_count
• Read operations
  • start operation_latency timer
  • failure-count
  • read_bytes
  • operation_size
• Other
  • start operation_latency timer
  • failure-count

pub fn new( store: OS, object_store_metrics: Arc<ObjectStoreMetrics>, config: Arc<ObjectStoreConfig>, ) -> Self

fn media_type(&self) -> &'static str

pub fn inner(&self) -> &OS

pub fn mut_inner(&mut self) -> &mut OS

pub async fn upload(&self, path: &str, obj: Bytes) -> ObjectResult<()>

pub async fn streaming_upload( &self, path: &str, ) -> ObjectResult<MonitoredStreamingUploader<OS::StreamingUploader>>

pub async fn read( &self, path: &str, range: impl ObjectRangeBounds, ) -> ObjectResult<Bytes>

async fn streaming_read( &self, path: &str, range: Range<usize>, ) -> ObjectResult<MonitoredStreamingReader>

Returns a stream reading the object specified in path. If given, the stream starts at the byte with index start_pos (0-based). As far as possible, the stream only loads the amount of data into memory that is read from the stream.

pub async fn metadata(&self, path: &str) -> ObjectResult<ObjectMetadata>

pub async fn delete(&self, path: &str) -> ObjectResult<()>

async fn delete_objects(&self, paths: &[String]) -> ObjectResult<()>

pub async fn list( &self, prefix: &str, start_after: Option<String>, limit: Option<usize>, ) -> ObjectResult<ObjectMetadataIter>