summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2021-03-26 13:14:04 +0100
committerHarald Musum <musum@verizonmedia.com>2021-03-26 13:14:04 +0100
commitb13f85dc26cfed8159776099dfa20d11a00f694c (patch)
tree1fa121115d98429f6fb32351380ea4149d7d6b8b /configserver
parentdb53ec4fdedaa64b2b034bb6b14c476746a2d782 (diff)
Extract method
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java15
1 files changed, 9 insertions, 6 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java
index 13d8908d197..9fd20453bcd 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java
@@ -122,7 +122,6 @@ public class TenantRepository {
/**
* Creates a new tenant repository
- *
*/
@Inject
public TenantRepository(HostRegistry hostRegistry,
@@ -198,11 +197,8 @@ public class TenantRepository {
curator.framework().getConnectionStateListenable().addListener(this::stateChanged);
- curator.create(tenantsPath);
- curator.create(locksPath);
- curator.create(barriersPath);
+ createPaths();
createSystemTenants(configserverConfig);
- curator.create(vespaPath);
this.directoryCache = Optional.of(curator.createDirectoryCache(tenantsPath.getAbsolute(), false, false, zkCacheExecutor));
this.directoryCache.get().addListener(this::childEvent);
@@ -256,10 +252,17 @@ public class TenantRepository {
return metaData.orElse(new TenantMetaData(tenant.getName(), tenant.getCreatedTime(), tenant.getCreatedTime()));
}
- private static Set<TenantName> readTenantsFromZooKeeper(Curator curator) {
+ private static Set<TenantName> readTenantsFromZooKeeper(Curator curator) {
return curator.getChildren(tenantsPath).stream().map(TenantName::from).collect(Collectors.toSet());
}
+ private void createPaths() {
+ curator.create(tenantsPath);
+ curator.create(locksPath);
+ curator.create(barriersPath);
+ curator.create(vespaPath);
+ }
+
private void bootstrapTenants() {
// Keep track of tenants created
Map<TenantName, Future<?>> futures = new HashMap<>();