summaryrefslogtreecommitdiffstats
path: root/container-core/src/main/java/com/yahoo/container/core/slobrok/SlobrokConfigurator.java
diff options
context:
space:
mode:
Diffstat (limited to 'container-core/src/main/java/com/yahoo/container/core/slobrok/SlobrokConfigurator.java')
-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());
+ }
+}