summaryrefslogtreecommitdiffstats
path: root/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentContextImplTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentContextImplTest.java')
-rw-r--r--node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentContextImplTest.java22
1 files changed, 22 insertions, 0 deletions
diff --git a/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentContextImplTest.java b/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentContextImplTest.java
index 9bcbce849af..b7e0a2a1d97 100644
--- a/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentContextImplTest.java
+++ b/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentContextImplTest.java
@@ -2,14 +2,19 @@
package com.yahoo.vespa.hosted.node.admin.nodeagent;
import com.yahoo.config.provision.DockerImage;
+import com.yahoo.vespa.flags.Flags;
+import com.yahoo.vespa.flags.InMemoryFlagSource;
import com.yahoo.vespa.test.file.TestFileSystem;
import org.junit.Test;
import java.nio.file.FileSystem;
import java.nio.file.Path;
import java.nio.file.Paths;
+import java.util.List;
import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
/**
* @author freva
@@ -84,6 +89,23 @@ public class NodeAgentContextImplTest {
assertRewrite("docker.tld/vespa/hosted:1.2.3", "/opt/vespa/log", "/opt/vespa/log");
}
+ @Test
+ public void disabledTasksTest() {
+ NodeAgentContext context1 = createContextWithDisabledTasks();
+ assertFalse(context1.isDisabled(NodeAgentTask.DiskCleanup));
+ assertFalse(context1.isDisabled(NodeAgentTask.CoreDumps));
+
+ NodeAgentContext context2 = createContextWithDisabledTasks("root>UpgradeTask", "DiskCleanup", "node>CoreDumps");
+ assertFalse(context2.isDisabled(NodeAgentTask.DiskCleanup));
+ assertTrue(context2.isDisabled(NodeAgentTask.CoreDumps));
+ }
+
+ private static NodeAgentContext createContextWithDisabledTasks(String... tasks) {
+ InMemoryFlagSource flagSource = new InMemoryFlagSource();
+ flagSource.withListFlag(Flags.DISABLED_HOST_ADMIN_TASKS.id(), List.of(tasks), String.class);
+ return new NodeAgentContextImpl.Builder("node123").flagSource(flagSource).build();
+ }
+
private static void assertRewrite(String dockerImage, String path, String expected) {
NodeAgentContext context = new NodeAgentContextImpl.Builder("node123")
.nodeSpecBuilder(ns -> ns.wantedDockerImage(DockerImage.fromString(dockerImage)))