diff options
author | Harald Musum <musum@yahoo-inc.com> | 2017-09-29 18:10:50 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-09-29 18:10:50 +0200 |
commit | 2d5eb7d0976ac0650ab1d2acfcca4984252f8349 (patch) | |
tree | 6de815c80844058a9fbf849e32acbd150ca0020b | |
parent | f4f8d93f3be2a2b91ba0db4034db2a1811f438fb (diff) | |
parent | 78bfe08c79ba5576bb978fafe0deb69e97aaed3e (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.java | 16 |
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, |