summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@yahoo-inc.com>2017-09-29 18:10:50 +0200
committerGitHub <noreply@github.com>2017-09-29 18:10:50 +0200
commit2d5eb7d0976ac0650ab1d2acfcca4984252f8349 (patch)
tree6de815c80844058a9fbf849e32acbd150ca0020b
parentf4f8d93f3be2a2b91ba0db4034db2a1811f438fb (diff)
parent78bfe08c79ba5576bb978fafe0deb69e97aaed3e (diff)
Merge pull request #3591 from vespa-engine/hakon/depend-on-servicemonitor-interface-instead-of-impl
Depend on ServiceMonitor interface instead of impl
-rw-r--r--orchestrator/src/main/java/com/yahoo/vespa/orchestrator/ServiceMonitorInstanceLookupService.java16
1 files changed, 8 insertions, 8 deletions
diff --git a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/ServiceMonitorInstanceLookupService.java b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/ServiceMonitorInstanceLookupService.java
index b7f1ec56541..31f4f1430d3 100644
--- a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/ServiceMonitorInstanceLookupService.java
+++ b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/ServiceMonitorInstanceLookupService.java
@@ -2,11 +2,11 @@
package com.yahoo.vespa.orchestrator;
import com.google.inject.Inject;
-import com.yahoo.vespa.applicationmodel.ApplicationInstanceReference;
import com.yahoo.vespa.applicationmodel.ApplicationInstance;
+import com.yahoo.vespa.applicationmodel.ApplicationInstanceReference;
import com.yahoo.vespa.applicationmodel.HostName;
+import com.yahoo.vespa.service.monitor.ServiceMonitor;
import com.yahoo.vespa.service.monitor.ServiceMonitorStatus;
-import com.yahoo.vespa.service.monitor.SlobrokAndConfigIntersector;
import java.util.List;
import java.util.Map;
@@ -21,24 +21,24 @@ import java.util.stream.Collectors;
*/
public class ServiceMonitorInstanceLookupService implements InstanceLookupService {
- private final SlobrokAndConfigIntersector slobrokAndConfigIntersector;
+ private final ServiceMonitor serviceMonitor;
@Inject
- public ServiceMonitorInstanceLookupService(SlobrokAndConfigIntersector slobrokAndConfigIntersector) {
- this.slobrokAndConfigIntersector = slobrokAndConfigIntersector;
+ public ServiceMonitorInstanceLookupService(ServiceMonitor serviceMonitor) {
+ this.serviceMonitor = serviceMonitor;
}
@Override
public Optional<ApplicationInstance<ServiceMonitorStatus>> findInstanceById(ApplicationInstanceReference applicationInstanceReference) {
Map<ApplicationInstanceReference, ApplicationInstance<ServiceMonitorStatus>> instanceMap
- = slobrokAndConfigIntersector.queryStatusOfAllApplicationInstances();
+ = serviceMonitor.queryStatusOfAllApplicationInstances();
return Optional.ofNullable(instanceMap.get(applicationInstanceReference));
}
@Override
public Optional<ApplicationInstance<ServiceMonitorStatus>> findInstanceByHost(HostName hostName) {
Map<ApplicationInstanceReference, ApplicationInstance<ServiceMonitorStatus>> instanceMap
- = slobrokAndConfigIntersector.queryStatusOfAllApplicationInstances();
+ = serviceMonitor.queryStatusOfAllApplicationInstances();
List<ApplicationInstance<ServiceMonitorStatus>> applicationInstancesUsingHost = instanceMap.entrySet().stream()
.filter(entry -> applicationInstanceUsesHost(entry.getValue(), hostName))
.map(Map.Entry::getValue)
@@ -56,7 +56,7 @@ public class ServiceMonitorInstanceLookupService implements InstanceLookupServic
@Override
public Set<ApplicationInstanceReference> knownInstances() {
- return slobrokAndConfigIntersector.queryStatusOfAllApplicationInstances().keySet();
+ return serviceMonitor.queryStatusOfAllApplicationInstances().keySet();
}
private static boolean applicationInstanceUsesHost(ApplicationInstance<ServiceMonitorStatus> applicationInstance,