Struct RateLimitReportingClient 

pub struct RateLimitReportingClient { /* private fields */ }

A storage client wrapper that reports healthy and rate-limited operations to autoscaling.

Implementations

impl RateLimitReportingClient

pub fn new( inner: Arc<dyn StorageClient>, handle: ClientLoadSignalHandle, ) -> Arc<dyn StorageClient>

Wraps inner with rate-limit reporting and returns it as a storage client.

Trait Implementations

impl StorageClient for RateLimitReportingClient

fn open_dataset<'life0, 'life1, 'async_trait>( &'life0 self, name: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = StorageResult<Arc<dyn Dataset>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Opens a dataset, using the default dataset when name is None.

fn open_key_value_store<'life0, 'life1, 'async_trait>( &'life0 self, name: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = StorageResult<Arc<dyn KeyValueStore>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Opens a key-value store, using the default store when name is None.

fn open_request_queue<'life0, 'life1, 'async_trait>( &'life0 self, name: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = StorageResult<Arc<dyn RequestQueue>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Opens a request queue, using the default queue when name is None.

fn purge<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Removes all storage data managed by this client.