From 4cebe77b6fcc8260ccccece61799a11f4898a0b9 Mon Sep 17 00:00:00 2001
From: Quentin Dufour <quentin@deuxfleurs.fr>
Date: Fri, 22 May 2020 12:29:55 +0200
Subject: Consul Actor basic logic works

---
 src/consul_actor.rs | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

(limited to 'src/consul_actor.rs')

diff --git a/src/consul_actor.rs b/src/consul_actor.rs
index c87874d..b26c2dd 100644
--- a/src/consul_actor.rs
+++ b/src/consul_actor.rs
@@ -23,7 +23,7 @@ fn retry_to_time(retries: u32, max_time: Duration) -> Duration {
 }
 
 impl ConsulActor {
-  fn new(url: &str, node: &str) -> Self {
+  pub fn new(url: &str, node: &str) -> Self {
     let (tx, rx) = watch::channel(messages::OpenPorts{ports: Vec::new() });
     return Self {
       consul: Consul::new(url),
@@ -34,7 +34,7 @@ impl ConsulActor {
     };
   }
 
-  async fn listen(&mut self) -> Result<()> {
+  pub async fn listen(&mut self) -> Result<()> {
     loop {
       let catalog = match self.consul.watch_node(&self.node).await {
         Ok(c) => c,
@@ -46,6 +46,8 @@ impl ConsulActor {
           continue;
         }
       };
+
+      info!("{:#?}", catalog);
     }
   }
 }
-- 
cgit v1.2.3