aboutsummaryrefslogtreecommitdiff
path: root/src/consul_actor.rs
diff options
context:
space:
mode:
authorQuentin Dufour <quentin@deuxfleurs.fr>2020-05-22 18:41:13 +0200
committerQuentin Dufour <quentin@deuxfleurs.fr>2020-05-22 18:41:13 +0200
commite1d0eadb9dc5e2e3bea8bc48f7b33ad9ef632554 (patch)
treed1e891b87684c7907ff1245ebd5ad403804f6fd9 /src/consul_actor.rs
parentdeeecd93e1fc5545e6e0280d1799436638e84a38 (diff)
downloaddiplonat-e1d0eadb9dc5e2e3bea8bc48f7b33ad9ef632554.tar.gz
diplonat-e1d0eadb9dc5e2e3bea8bc48f7b33ad9ef632554.zip
WIP software
Diffstat (limited to 'src/consul_actor.rs')
-rw-r--r--src/consul_actor.rs7
1 files changed, 5 insertions, 2 deletions
diff --git a/src/consul_actor.rs b/src/consul_actor.rs
index de5e216..877ea10 100644
--- a/src/consul_actor.rs
+++ b/src/consul_actor.rs
@@ -5,7 +5,7 @@ use tokio::sync::watch;
use tokio::time::delay_for;
use anyhow::Result;
use serde::{Serialize, Deserialize};
-use serde_lexpr::{from_str,to_string,error};
+use serde_lexpr::{from_str,error};
use crate::messages;
use crate::consul;
@@ -100,7 +100,10 @@ impl ConsulActor {
}
};
self.retries = 0;
- info!("{:#?}", to_open_ports(&to_parameters(&catalog)));
+ let msg = to_open_ports(&to_parameters(&catalog));
+ debug!("Extracted configuration: {:#?}", msg);
+
+ self.tx_open_ports.broadcast(msg)?;
}
}
}