Struct NodeHandle 

pub struct NodeHandle { /* private fields */ }

A handle for interacting with the Edge Node.

NodeHandle provides an interface for interacting with an edge node, including device management, node lifecycle operations, and metric publishing.

Implementations

impl NodeHandle

pub async fn cancel(&self)

Stop all operations, sending a death certificate and disconnect from the broker.

This will cancel EoN::run()

pub fn rebirth(&self)

Manually trigger a rebirth for the node

pub fn register_device<S, M>( &self, name: S, dev_impl: M, ) -> Result<DeviceHandle, DeviceRegistrationError>

where S: Into<String>, M: DeviceMetricManager + Send + Sync + 'static,

Registers a new device with the node.

Returns an error if:

• A device with the same name is already registered
• The device name is invalid

pub async fn unregister_device(&self, handle: DeviceHandle)

Unregister a device using it’s handle.

pub async fn unregister_device_named(&self, name: &String)

Unregister a device using it’s name.

Trait Implementations

impl Clone for NodeHandle

fn clone(&self) -> NodeHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl MetricPublisher for NodeHandle

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.