Struct zenoh_backend_influxdb2::InfluxDbVolume

pub struct InfluxDbVolume { /* private fields */ }

Trait Implementations

impl Volume for InfluxDbVolume

fn get_admin_status(&self) -> Value

Returns the status that will be sent as a reply to a query on the administration space for this backend.

fn get_capability(&self) -> Capability

Returns the capability of this backend

fn create_storage<'life0, 'async_trait>( &'life0 self, config: StorageConfig ) -> Pin<Box<dyn Future<Output = ZResult<Box<dyn Storage>>> + Send + 'async_trait>>

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

Creates a storage configured with some properties.

fn incoming_data_interceptor( &self ) -> Option<Arc<dyn Fn(Sample) -> Sample + Send + Sync>>

Returns an interceptor that will be called before pushing any data into a storage created by this backend. None can be returned for no interception point.

fn outgoing_data_interceptor( &self ) -> Option<Arc<dyn Fn(Sample) -> Sample + Send + Sync>>

Returns an interceptor that will be called before sending any reply to a query from a storage created by this backend. None can be returned for no interception point.