Struct DeviceHandle

pub struct DeviceHandle { /* private fields */ }

A handle for interacting with an Edge Device

Implementations

impl DeviceHandle

pub async fn enable(&self)

Enabled the device

Will attempt to birth the device. If the node is not online, the device will be birthed when it is next online.

pub async fn rebirth(&self)

Rebirth the device

Manually trigger a rebirth for the device.

pub async fn disable(&self)

Disable the device

Will produce a death message for the device. The node will no longer attempt to birth the device when it comes online.

Trait Implementations

impl Clone for DeviceHandle

fn clone(&self) -> DeviceHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl MetricPublisher for DeviceHandle

async fn try_publish_metrics_unsorted( &self, metrics: Vec<PublishMetric>, ) -> Result<(), PublishError>

Attempts to publish a batch of metrics without modifying their order.

async fn publish_metrics_unsorted( &self, metrics: Vec<PublishMetric>, ) -> Result<(), PublishError>

Publish a batch of metrics without modifying their order.

fn try_publish_metric( &self, metric: PublishMetric, ) -> impl Future<Output = Result<(), PublishError>> + Send

Attempts to publish a single metric.

fn try_publish_metrics( &self, metrics: Vec<PublishMetric>, ) -> impl Future<Output = Result<(), PublishError>> + Send

Attempts to publish a batch of metrics after sorting by timestamp.

fn publish_metric( &self, metric: PublishMetric, ) -> impl Future<Output = Result<(), PublishError>> + Send

Publish a single metric.

fn publish_metrics( &self, metrics: Vec<PublishMetric>, ) -> impl Future<Output = Result<(), PublishError>> + Send

Publish a batch of metrics after sorting by timestamp.