aboutsummaryrefslogtreecommitdiff
path: root/src/proxy_config.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/proxy_config.rs')
-rw-r--r--src/proxy_config.rs8
1 files changed, 2 insertions, 6 deletions
diff --git a/src/proxy_config.rs b/src/proxy_config.rs
index 8c2444a..ba58484 100644
--- a/src/proxy_config.rs
+++ b/src/proxy_config.rs
@@ -82,18 +82,14 @@ fn parse_consul_catalog(catalog: &ConsulNodeCatalog) -> ProxyConfig {
ProxyConfig { entries }
}
-pub fn spawn_proxy_config_task(
- mut consul: Consul,
- node: &str,
-) -> watch::Receiver<Arc<ProxyConfig>> {
+pub fn spawn_proxy_config_task(mut consul: Consul) -> watch::Receiver<Arc<ProxyConfig>> {
let (tx, rx) = watch::channel(Arc::new(ProxyConfig {
entries: Vec::new(),
}));
- let node = node.to_string();
-
tokio::spawn(async move {
let mut retries = 0;
+ let node = consul.local_node.clone();
loop {
let catalog = match consul.watch_node(&node).await {