feat(workers/base): announce to several peers

suisei-cn · Jul 26, 2022 · d9e9e87 · d9e9e87
1 parent b25c36c
commit d9e9e87
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/workers/base/src/config.rs b/workers/base/src/config.rs
@@ -6,11 +6,10 @@ use crate::{Certificates, ID};
 
 /// Configuration for worker nodes.
 pub struct NodeConfig<A> {
-    // TODO this can be a list.
     /// A peer URL to announce to the rest of the cluster.
     ///
     /// This is optional. If not set, the worker will be started at idle state.
-    pub announce: Option<Uri>,
+    pub announce: Vec<Uri>,
     /// Socket address to bind to for gossip protocol.
     pub bind: A,
     /// URI of this node to announce to the rest of the cluster.

diff --git a/workers/base/src/worker.rs b/workers/base/src/worker.rs
@@ -41,8 +41,8 @@ pub async fn start_worker<A: ToSocketAddrs + Send>(
     // Start the Foca runtime.
     let kind = config.ident.kind().to_string();
     let foca = start_foca(config.ident, stream, sink, None);
-    if let Some(announce) = config.announce {
-        foca.announce(ID::new(announce, kind));
+    for announce_peer in config.announce {
+        foca.announce(ID::new(announce_peer, kind.clone()));
     }
 
     // Prepare change stream.