From cb823b72c1c64646db4cbc4d4631b9d3885efb3c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Marcel=20M=C3=BCller?= <m.mueller@ifm.com>
Date: Wed, 13 Apr 2022 09:53:55 +0200
Subject: Adapt names with documentation to be more fitting
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: Marcel Müller <m.mueller@ifm.com>
---
 crates/core/tedge_api/examples/heartbeat.rs | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

(limited to 'crates/core/tedge_api/examples')

diff --git a/crates/core/tedge_api/examples/heartbeat.rs b/crates/core/tedge_api/examples/heartbeat.rs
index cb05b4b1..35ac183d 100644
--- a/crates/core/tedge_api/examples/heartbeat.rs
+++ b/crates/core/tedge_api/examples/heartbeat.rs
@@ -9,7 +9,7 @@ use futures::FutureExt;
 use tedge_api::{
     address::ReplySender,
     message::NoReply,
-    plugin::{BuiltPlugin, Handle, HandleTypes, Message, PluginDeclaration, PluginExt},
+    plugin::{BuiltPlugin, Handle, Message, PluginDeclaration, PluginExt},
     Address, CancellationToken, Plugin, PluginBuilder, PluginConfiguration, PluginDirectory,
     PluginError,
 };
@@ -45,7 +45,7 @@ impl<PD: PluginDirectory> PluginBuilder<PD> for HeartbeatServiceBuilder {
     where
         Self: Sized,
     {
-        HandleTypes::empty()
+        HeartbeatService::get_handled_types()
     }
 
     async fn verify_configuration(
@@ -79,7 +79,7 @@ impl<PD: PluginDirectory> PluginBuilder<PD> for HeartbeatServiceBuilder {
             monitored_services,
             cancellation_token,
         )
-        .into_untyped())
+        .finish())
     }
 }
 
@@ -109,7 +109,7 @@ impl Plugin for HeartbeatService {
     ///
     /// Because this example is _simple_, we do not spawn a background task that periodically sends
     /// the heartbeat. In a real world scenario, that background task would be started here.
-    async fn setup(&mut self) -> Result<(), PluginError> {
+    async fn start(&mut self) -> Result<(), PluginError> {
         println!(
             "HeartbeatService: Setting up heartbeat service with interval: {:?}!",
             self.interval_duration
@@ -230,7 +230,7 @@ impl<PD: PluginDirectory> PluginBuilder<PD> for CriticalServiceBuilder {
         Ok(CriticalService {
             status: tokio::sync::Mutex::new(true),
         }
-        .into_untyped())
+        .finish())
     }
 }
 
@@ -271,7 +271,7 @@ impl PluginDeclaration for CriticalService {
 /// Because the CriticalService is of course a Plugin, it needs an implementation for that as well.
 #[async_trait]
 impl Plugin for CriticalService {
-    async fn setup(&mut self) -> Result<(), PluginError> {
+    async fn start(&mut self) -> Result<(), PluginError> {
         println!("CriticalService: Setting up critical service!");
         Ok(())
     }
@@ -420,8 +420,8 @@ async fn main() {
     let mut heartbeat = build_heartbeat_plugin(&mut comms, cancel_token.child_token()).await;
     let mut critical_service = build_critical_plugin(&mut comms, cancel_token.child_token()).await;
 
-    heartbeat.plugin_mut().setup().await.unwrap();
-    critical_service.plugin_mut().setup().await.unwrap();
+    heartbeat.plugin_mut().start().await.unwrap();
+    critical_service.plugin_mut().start().await.unwrap();
 
     let mut recv = comms
         .plugins
-- 
cgit v1.2.3