summaryrefslogtreecommitdiffstats
path: root/container-core/src/main/java/com/yahoo/container/core/slobrok
diff options
context:
space:
mode:
authorHÃ¥kon Hallingstad <hakon@oath.com>2018-12-01 00:47:29 +0100
committerGitHub <noreply@github.com>2018-12-01 00:47:29 +0100
commit8e4eeb40e46f7b2fde27ac82bf14f27be4de6ecb (patch)
treeb7237df951072a75d3d527b757f11e6b08214c3d /container-core/src/main/java/com/yahoo/container/core/slobrok
parentc0513ac34d2c438e9f97e699659855029e1f06e8 (diff)
Revert "Remove zombie code"
Diffstat (limited to 'container-core/src/main/java/com/yahoo/container/core/slobrok')
-rw-r--r--container-core/src/main/java/com/yahoo/container/core/slobrok/SlobrokConfigurator.java26
1 files changed, 26 insertions, 0 deletions
diff --git a/container-core/src/main/java/com/yahoo/container/core/slobrok/SlobrokConfigurator.java b/container-core/src/main/java/com/yahoo/container/core/slobrok/SlobrokConfigurator.java
new file mode 100644
index 00000000000..9472fa07bb5
--- /dev/null
+++ b/container-core/src/main/java/com/yahoo/container/core/slobrok/SlobrokConfigurator.java
@@ -0,0 +1,26 @@
+// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+package com.yahoo.container.core.slobrok;
+
+import com.yahoo.cloud.config.SlobroksConfig;
+import com.yahoo.cloud.config.SlobroksConfig.Slobrok;
+import com.yahoo.container.Container;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * Configures which slobrok nodes the container should register with.
+ * @author Tony Vaagenes
+ */
+public class SlobrokConfigurator {
+ public SlobrokConfigurator(SlobroksConfig config) {
+ Container.get().getRpcAdaptor().registerInSlobrok(
+ connectionSpecs(config.slobrok()));
+ }
+
+ private static List<String> connectionSpecs(List<Slobrok> slobroks) {
+ return slobroks.stream().
+ map(Slobrok::connectionspec).
+ collect(Collectors.toList());
+ }
+}