summaryrefslogtreecommitdiffstats
path: root/configserver-flags
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2023-11-27 09:33:06 +0100
committerjonmv <venstad@gmail.com>2023-11-27 09:33:06 +0100
commit25bbeda88066a8041b336166086594ac07700adb (patch)
tree8f4b176d3c3d3f76a221bcf3c68c4b486ab9d584 /configserver-flags
parent96541d16dc07a0eff4d005604dd42bfc83330910 (diff)
Shut down curator cache on shutdown
Diffstat (limited to 'configserver-flags')
-rw-r--r--configserver-flags/src/main/java/com/yahoo/vespa/configserver/flags/db/FlagsDbImpl.java9
1 files changed, 8 insertions, 1 deletions
diff --git a/configserver-flags/src/main/java/com/yahoo/vespa/configserver/flags/db/FlagsDbImpl.java b/configserver-flags/src/main/java/com/yahoo/vespa/configserver/flags/db/FlagsDbImpl.java
index 09f5fcb7db9..f91dd2b9049 100644
--- a/configserver-flags/src/main/java/com/yahoo/vespa/configserver/flags/db/FlagsDbImpl.java
+++ b/configserver-flags/src/main/java/com/yahoo/vespa/configserver/flags/db/FlagsDbImpl.java
@@ -1,6 +1,7 @@
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.configserver.flags.db;
+import com.yahoo.component.AbstractComponent;
import com.yahoo.component.annotation.Inject;
import com.yahoo.path.Path;
import com.yahoo.vespa.configserver.flags.FlagsDb;
@@ -20,7 +21,7 @@ import java.util.stream.Collectors;
/**
* @author hakonhall
*/
-public class FlagsDbImpl implements FlagsDb {
+public class FlagsDbImpl extends AbstractComponent implements FlagsDb {
private static final Path ROOT_PATH = Path.fromString("/flags/v1");
private final Curator curator;
@@ -64,4 +65,10 @@ public class FlagsDbImpl implements FlagsDb {
private static Path getZkPathFor(FlagId flagId) {
return ROOT_PATH.append(flagId.toString());
}
+
+ @Override
+ public void deconstruct() {
+ cache.close(); // Also shuts down the executor service
+ }
+
}