summaryrefslogtreecommitdiffstats
path: root/node-admin
diff options
context:
space:
mode:
authorvalerijf <valerijf@yahoo-inc.com>2017-05-30 11:45:37 +0200
committervalerijf <valerijf@yahoo-inc.com>2017-05-30 11:50:46 +0200
commitefb7bccc10495dbb980bcabe75fabf9658382f6c (patch)
treee5b47745271f7ee4a17cbf121bc158019069c84a /node-admin
parenteafee523715af6137523fb084977c8d51fafe51d (diff)
Write configs on container start as well
Diffstat (limited to 'node-admin')
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java14
1 files changed, 10 insertions, 4 deletions
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java
index 4efa74dbd8e..b160b4ac364 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java
@@ -239,6 +239,8 @@ public class NodeAgentImpl implements NodeAgent {
dockerOperations.startContainer(containerName, nodeSpec);
lastCpuMetric = new CpuUsageReporter(clock.instant());
+ writeConfigs(nodeSpec);
+
addDebugMessage("startContainerIfNeeded: containerState " + containerState + " -> " +
RUNNING_HOWEVER_RESUME_SCRIPT_NOT_RUN);
containerState = RUNNING_HOWEVER_RESUME_SCRIPT_NOT_RUN;
@@ -410,10 +412,7 @@ public class NodeAgentImpl implements NodeAgent {
// TODO: Should be retried if writing fails
metricReceiver.unsetMetricsForContainer(hostname);
if (container.isPresent()) {
- storageMaintainer.ifPresent(maintainer -> {
- maintainer.writeMetricsConfig(containerName, nodeSpec);
- maintainer.writeFilebeatConfig(containerName, nodeSpec);
- });
+ writeConfigs(nodeSpec);
}
}
@@ -606,6 +605,13 @@ public class NodeAgentImpl implements NodeAgent {
}
}
+ private void writeConfigs(ContainerNodeSpec nodeSpec) {
+ storageMaintainer.ifPresent(maintainer -> {
+ maintainer.writeMetricsConfig(containerName, nodeSpec);
+ maintainer.writeFilebeatConfig(containerName, nodeSpec);
+ });
+ }
+
private Optional<Container> getContainer() {
if (containerState == ABSENT) return Optional.empty();
return dockerOperations.getContainer(containerName);