diff options
author | valerijf <valerijf@yahoo-inc.com> | 2017-05-15 11:52:00 +0200 |
---|---|---|
committer | valerijf <valerijf@yahoo-inc.com> | 2017-05-15 11:52:00 +0200 |
commit | c6b3d03e90f493950f40d9820115b3e83e13d908 (patch) | |
tree | 968b639d5887068c53d566637c6776e5727a8440 /node-admin | |
parent | 5c2685f2794cd7db389aa3798c895536180ea16d (diff) |
Remove docker.containers.running metric
Diffstat (limited to 'node-admin')
4 files changed, 7 insertions, 32 deletions
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/docker/DockerOperationsImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/docker/DockerOperationsImpl.java index fafbf3e2563..23e662600ea 100644 --- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/docker/DockerOperationsImpl.java +++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/docker/DockerOperationsImpl.java @@ -3,7 +3,6 @@ package com.yahoo.vespa.hosted.node.admin.docker; import com.google.common.base.Joiner; import com.google.common.io.CharStreams; -import com.yahoo.net.HostName; import com.yahoo.vespa.defaults.Defaults; import com.yahoo.vespa.hosted.dockerapi.Container; import com.yahoo.vespa.hosted.dockerapi.ContainerName; @@ -12,9 +11,6 @@ import com.yahoo.vespa.hosted.dockerapi.DockerImage; import com.yahoo.vespa.hosted.dockerapi.DockerImpl; import com.yahoo.vespa.hosted.dockerapi.DockerNetworkCreator; import com.yahoo.vespa.hosted.dockerapi.ProcessResult; -import com.yahoo.vespa.hosted.dockerapi.metrics.Dimensions; -import com.yahoo.vespa.hosted.dockerapi.metrics.GaugeWrapper; -import com.yahoo.vespa.hosted.dockerapi.metrics.MetricReceiverWrapper; import com.yahoo.vespa.hosted.node.admin.ContainerNodeSpec; import com.yahoo.vespa.hosted.node.admin.util.Environment; import com.yahoo.vespa.hosted.node.admin.util.PrefixLogger; @@ -94,17 +90,14 @@ public class DockerOperationsImpl implements DockerOperations { private final Docker docker; private final Environment environment; private final Consumer<List<String>> commandExecutor; - private GaugeWrapper numberOfRunningContainersGauge; - public DockerOperationsImpl(Docker docker, Environment environment, MetricReceiverWrapper metricReceiver) { - this(docker, environment, metricReceiver, DockerOperationsImpl::runCommand); + public DockerOperationsImpl(Docker docker, Environment environment) { + this(docker, environment, DockerOperationsImpl::runCommand); } - DockerOperationsImpl(Docker docker, Environment environment, MetricReceiverWrapper metricReceiver, - Consumer<List<String>> commandExecutor) { + DockerOperationsImpl(Docker docker, Environment environment, Consumer<List<String>> commandExecutor) { this.docker = docker; this.environment = environment; - setMetrics(metricReceiver); this.commandExecutor = commandExecutor; } @@ -200,8 +193,6 @@ public class DockerOperationsImpl implements DockerOperations { } catch (IOException e) { throw new RuntimeException("Failed to create container " + containerName.asString(), e); } - - numberOfRunningContainersGauge.sample(getAllManagedContainers().size()); } @Override @@ -215,7 +206,6 @@ public class DockerOperationsImpl implements DockerOperations { logger.info("Deleting container " + containerName.asString()); docker.deleteContainer(containerName); - numberOfRunningContainersGauge.sample(getAllManagedContainers().size()); } // Returns true if scheduling download @@ -352,17 +342,6 @@ public class DockerOperationsImpl implements DockerOperations { docker.deleteUnusedDockerImages(); } - private void setMetrics(MetricReceiverWrapper metricReceiver) { - Dimensions dimensions = new Dimensions.Builder() - .add("host", HostName.getLocalhost()) - .add("role", "docker").build(); - - numberOfRunningContainersGauge = metricReceiver.declareGauge(MetricReceiverWrapper.APPLICATION_DOCKER, dimensions, "containers.running"); - - // Some containers could already be running, count them and initialize to that value - numberOfRunningContainersGauge.sample(getAllManagedContainers().size()); - } - private static void runCommand(List<String> command) { try { final Process process = new ProcessBuilder(command) diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/provider/ComponentsProviderImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/provider/ComponentsProviderImpl.java index 487d1845c62..5892b800cde 100644 --- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/provider/ComponentsProviderImpl.java +++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/provider/ComponentsProviderImpl.java @@ -61,7 +61,7 @@ public class ComponentsProviderImpl implements ComponentsProvider { ConfigServerHttpRequestExecutor requestExecutor = ConfigServerHttpRequestExecutor.create(configServerHosts); Orchestrator orchestrator = new OrchestratorImpl(requestExecutor); NodeRepository nodeRepository = new NodeRepositoryImpl(requestExecutor, WEB_SERVICE_PORT, baseHostName); - DockerOperations dockerOperations = new DockerOperationsImpl(docker, environment, metricReceiver); + DockerOperations dockerOperations = new DockerOperationsImpl(docker, environment); Optional<StorageMaintainer> storageMaintainer = isRunningLocally ? Optional.empty() : Optional.of(new StorageMaintainer(docker, metricReceiver, environment)); diff --git a/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/docker/DockerOperationsImplTest.java b/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/docker/DockerOperationsImplTest.java index 2822926945b..e5f47ee1d0c 100644 --- a/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/docker/DockerOperationsImplTest.java +++ b/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/docker/DockerOperationsImplTest.java @@ -1,13 +1,11 @@ // Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.vespa.hosted.node.admin.docker; -import com.yahoo.metrics.simple.MetricReceiver; import com.yahoo.vespa.hosted.dockerapi.Container; import com.yahoo.vespa.hosted.dockerapi.ContainerName; import com.yahoo.vespa.hosted.dockerapi.Docker; import com.yahoo.vespa.hosted.dockerapi.DockerImage; import com.yahoo.vespa.hosted.dockerapi.ProcessResult; -import com.yahoo.vespa.hosted.dockerapi.metrics.MetricReceiverWrapper; import com.yahoo.vespa.hosted.node.admin.util.Environment; import org.hamcrest.CoreMatchers; import org.junit.Test; @@ -32,8 +30,7 @@ import static org.mockito.Mockito.when; public class DockerOperationsImplTest { private final Environment environment = new Environment.Builder().build(); private final Docker docker = mock(Docker.class); - private final DockerOperationsImpl dockerOperations = new DockerOperationsImpl(docker, environment, - new MetricReceiverWrapper(MetricReceiver.nullImplementation)); + private final DockerOperationsImpl dockerOperations = new DockerOperationsImpl(docker, environment); @Test public void processResultFromNodeProgramWhenSuccess() throws Exception { @@ -108,8 +105,7 @@ public class DockerOperationsImplTest { public void runsCommandInNetworkNamespace() { Container container = makeContainer("container-42", Container.State.RUNNING, 42); List<String> capturedArgs = new ArrayList<>(); - DockerOperationsImpl dockerOperations = new DockerOperationsImpl(docker, environment, - new MetricReceiverWrapper(MetricReceiver.nullImplementation), capturedArgs::addAll); + DockerOperationsImpl dockerOperations = new DockerOperationsImpl(docker, environment, capturedArgs::addAll); dockerOperations.executeCommandInNetworkNamespace(container.name, new String[]{"iptables", "-nvL"}); diff --git a/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/integrationTests/DockerTester.java b/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/integrationTests/DockerTester.java index 223cfd09461..e5176247dac 100644 --- a/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/integrationTests/DockerTester.java +++ b/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/integrationTests/DockerTester.java @@ -61,7 +61,7 @@ public class DockerTester implements AutoCloseable { MetricReceiverWrapper mr = new MetricReceiverWrapper(MetricReceiver.nullImplementation); - final DockerOperations dockerOperations = new DockerOperationsImpl(dockerMock, environment, mr); + final DockerOperations dockerOperations = new DockerOperationsImpl(dockerMock, environment); Function<String, NodeAgent> nodeAgentFactory = (hostName) -> new NodeAgentImpl(hostName, nodeRepositoryMock, orchestratorMock, dockerOperations, Optional.of(storageMaintainer), mr, environment, Clock.systemUTC(), Optional.empty()); nodeAdmin = new NodeAdminImpl(dockerOperations, nodeAgentFactory, Optional.of(storageMaintainer), 100, mr, Optional.empty()); |