summaryrefslogtreecommitdiffstats
path: root/node-admin
diff options
context:
space:
mode:
authorvalerijf <valerijf@yahoo-inc.com>2017-05-15 11:52:00 +0200
committervalerijf <valerijf@yahoo-inc.com>2017-05-15 11:52:00 +0200
commitc6b3d03e90f493950f40d9820115b3e83e13d908 (patch)
tree968b639d5887068c53d566637c6776e5727a8440 /node-admin
parent5c2685f2794cd7db389aa3798c895536180ea16d (diff)
Remove docker.containers.running metric
Diffstat (limited to 'node-admin')
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/docker/DockerOperationsImpl.java27
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/provider/ComponentsProviderImpl.java2
-rw-r--r--node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/docker/DockerOperationsImplTest.java8
-rw-r--r--node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/integrationTests/DockerTester.java2
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());