diff options
author | Harald Musum <musum@verizonmedia.com> | 2021-03-26 13:14:04 +0100 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2021-03-26 13:14:04 +0100 |
commit | b13f85dc26cfed8159776099dfa20d11a00f694c (patch) | |
tree | 1fa121115d98429f6fb32351380ea4149d7d6b8b /configserver | |
parent | db53ec4fdedaa64b2b034bb6b14c476746a2d782 (diff) |
Extract method
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java | 15 |
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<>(); |