aboutsummaryrefslogtreecommitdiffstats
path: root/node-repository/src/main/java
diff options
context:
space:
mode:
authorHåkon Hallingstad <hakon@yahooinc.com>2024-05-19 16:56:56 +0200
committerHåkon Hallingstad <hakon@yahooinc.com>2024-05-19 16:56:56 +0200
commit41bf2ad54d8896188dd3c766e2e901af5f08e1c3 (patch)
tree7389d80435bfa6e8037fc434939939a35d08acd3 /node-repository/src/main/java
parentcbb09179e61b54c568ed9976194402e935977946 (diff)
Avoid injecting Exclusivity
Diffstat (limited to 'node-repository/src/main/java')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/NodeRepository.java9
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java1
2 files changed, 2 insertions, 8 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/NodeRepository.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/NodeRepository.java
index cc46fc381f0..0778e21fcd8 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/NodeRepository.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/NodeRepository.java
@@ -57,7 +57,6 @@ public class NodeRepository extends AbstractComponent implements HealthCheckerPr
private final CuratorDb db;
private final Clock clock;
private final Zone zone;
- private final Exclusivity exclusivity;
private final Nodes nodes;
private final NodeFlavors flavors;
private final HostResourcesCalculator resourcesCalculator;
@@ -87,7 +86,6 @@ public class NodeRepository extends AbstractComponent implements HealthCheckerPr
ProvisionServiceProvider provisionServiceProvider,
Curator curator,
Zone zone,
- Exclusivity exclusivity,
FlagSource flagSource,
MetricsDb metricsDb,
Orchestrator orchestrator) {
@@ -96,7 +94,6 @@ public class NodeRepository extends AbstractComponent implements HealthCheckerPr
curator,
Clock.systemUTC(),
zone,
- exclusivity,
new DnsNameResolver(),
DockerImage.fromString(config.containerImage()),
optionalImage(config.tenantContainerImage()),
@@ -117,7 +114,6 @@ public class NodeRepository extends AbstractComponent implements HealthCheckerPr
Curator curator,
Clock clock,
Zone zone,
- Exclusivity exclusivity,
NameResolver nameResolver,
DockerImage containerImage,
Optional<DockerImage> tenantContainerImage,
@@ -136,7 +132,6 @@ public class NodeRepository extends AbstractComponent implements HealthCheckerPr
this.db = new CuratorDb(flavors, curator, clock, useCuratorClientCache);
this.clock = clock;
this.zone = zone;
- this.exclusivity = exclusivity;
this.applications = new Applications(db);
this.nodes = new Nodes(db, zone, clock, orchestrator, applications);
this.flavors = flavors;
@@ -213,14 +208,14 @@ public class NodeRepository extends AbstractComponent implements HealthCheckerPr
/** The number of nodes we should ensure has free capacity for node failures whenever possible */
public int spareCount() { return spareCount; }
- public Exclusivity exclusivity() { return exclusivity; }
+ public Exclusivity exclusivity() { return new Exclusivity(zone, PermanentFlags.SHARED_HOST.bindTo(flagSource).value()); }
public CapacityPolicies capacityPoliciesFor(ApplicationId applicationId) {
String adminClusterNodeArchitecture = PermanentFlags.ADMIN_CLUSTER_NODE_ARCHITECTURE
.bindTo(flagSource)
.with(INSTANCE_ID, applicationId.serializedForm())
.value();
- return new CapacityPolicies(zone, exclusivity, applicationId, Architecture.valueOf(adminClusterNodeArchitecture));
+ return new CapacityPolicies(zone, exclusivity(), applicationId, Architecture.valueOf(adminClusterNodeArchitecture));
}
/**
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java
index c085a3ed27c..b55b961fea3 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java
@@ -92,7 +92,6 @@ public class MockNodeRepository extends NodeRepository {
curator,
Clock.fixed(Instant.ofEpochMilli(123), ZoneId.of("Z")),
zone,
- new Exclusivity(zone, SharedHosts.empty()),
new MockNameResolver().mockAnyLookup(),
DockerImage.fromString("docker-registry.domain.tld:8080/dist/vespa"),
Optional.empty(),