diff options
author | Marcel Müller <m.mueller@ifm.com> | 2022-05-31 11:24:51 +0200 |
---|---|---|
committer | Marcel Müller <m.mueller@ifm.com> | 2022-05-31 11:24:51 +0200 |
commit | 3dc51be974294fafa60c9b73280b9be241277765 (patch) | |
tree | 5aa990ac60e6117d18659132991f6341c8fe1ecb /crates/core/tedge_api/examples | |
parent | 031832c6f22156694f0822265c5dd7b3b9683b9d (diff) | |
parent | 519ec731579a226aac53cec65c6b20cacfd3f586 (diff) |
Merge branch 'feature/add_type_uuids_to_messages' into feature/add_tedge_api_only
Diffstat (limited to 'crates/core/tedge_api/examples')
-rw-r--r-- | crates/core/tedge_api/examples/heartbeat.rs | 11 | ||||
-rw-r--r-- | crates/core/tedge_api/examples/print_config.rs | 1 | ||||
-rw-r--r-- | crates/core/tedge_api/examples/universal_log.rs | 11 |
3 files changed, 15 insertions, 8 deletions
diff --git a/crates/core/tedge_api/examples/heartbeat.rs b/crates/core/tedge_api/examples/heartbeat.rs index 654c4311..8d64232a 100644 --- a/crates/core/tedge_api/examples/heartbeat.rs +++ b/crates/core/tedge_api/examples/heartbeat.rs @@ -4,23 +4,26 @@ use async_trait::async_trait; use futures::FutureExt; use tedge_api::{ address::ReplySenderFor, - message::MessageType, - plugin::{AcceptsReplies, BuiltPlugin, Handle, Message, PluginDeclaration, PluginExt}, + message::{AcceptsReplies, Message, MessageType}, + plugin::{BuiltPlugin, Handle, PluginDeclaration, PluginExt}, Address, CancellationToken, Plugin, PluginBuilder, PluginConfiguration, PluginDirectory, PluginError, }; use tokio::sync::RwLock; +use type_uuid::TypeUuid; +#[derive(Debug, TypeUuid)] +#[uuid = "94916be9-17ba-4bca-a3a0-408d33136fed"] /// A message that represents a heartbeat that gets sent to plugins -#[derive(Debug)] struct Heartbeat; impl Message for Heartbeat {} impl AcceptsReplies for Heartbeat { type Reply = HeartbeatStatus; } +#[derive(Debug, TypeUuid)] +#[uuid = "a6d03c65-51bf-4f89-b383-c67c9ed8533b"] /// The reply for a heartbeat -#[derive(Debug)] enum HeartbeatStatus { Alive, Degraded, diff --git a/crates/core/tedge_api/examples/print_config.rs b/crates/core/tedge_api/examples/print_config.rs index ba6e7a6b..8be855e0 100644 --- a/crates/core/tedge_api/examples/print_config.rs +++ b/crates/core/tedge_api/examples/print_config.rs @@ -1,3 +1,4 @@ +#![allow(dead_code, unused)] use std::collections::HashMap; use nu_ansi_term::Color; diff --git a/crates/core/tedge_api/examples/universal_log.rs b/crates/core/tedge_api/examples/universal_log.rs index 82ff3130..064ffa22 100644 --- a/crates/core/tedge_api/examples/universal_log.rs +++ b/crates/core/tedge_api/examples/universal_log.rs @@ -4,19 +4,22 @@ use async_trait::async_trait; use futures::FutureExt; use tedge_api::{ address::ReplySenderFor, - message::{AnyMessage, MessageType}, - plugin::{AnyMessages, BuiltPlugin, Handle, Message, PluginDeclaration, PluginExt}, + message::{AnyMessage, Message, MessageType}, + plugin::{AnyMessages, BuiltPlugin, Handle, PluginDeclaration, PluginExt}, Address, CancellationToken, Plugin, PluginBuilder, PluginConfiguration, PluginDirectory, PluginError, }; use tokio::sync::RwLock; +use type_uuid::TypeUuid; /// A message that represents a heartbeat that gets sent to plugins -#[derive(Debug)] +#[derive(Debug, TypeUuid)] +#[uuid = "1f807f7b-888f-4881-a1b5-16380e32f8c2"] struct Heartbeat; impl Message for Heartbeat {} -#[derive(Debug)] +#[derive(Debug, TypeUuid)] +#[uuid = "346e233f-c24a-47e0-a15b-3ec0d1e19019"] struct RandomData; impl Message for RandomData {} |