diff options
| author | Alex Auvolat <alex@adnab.me> | 2021-12-07 17:05:25 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2021-12-07 17:05:25 +0100 |
| commit | bb77e7c459a624bb2b4ea043145fd6ea75771105 (patch) | |
| tree | 70d31e76a9eb2d6b925627c775804cd4ad42e4b7 /src/proxy_config.rs | |
| parent | ccb4e87658f622edbd57cc2b5a058c969643bfe2 (diff) | |
| download | tricot-bb77e7c459a624bb2b4ea043145fd6ea75771105.tar.gz tricot-bb77e7c459a624bb2b4ea043145fd6ea75771105.zip | |
Locking to avoid flooding Let's encrypt
Diffstat (limited to 'src/proxy_config.rs')
| -rw-r--r-- | src/proxy_config.rs | 8 |
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 { |