1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.config.provision;
import com.yahoo.component.Version;
import java.util.List;
import java.util.Objects;
import java.util.Optional;
/**
* A specification of a host and its role.
* Equality and order is determined by the host name.
*
* @author hmusum
*/
public class HostSpec implements Comparable<HostSpec> {
/** The name of this host */
private final String hostname;
private final NodeResources realResources;
private final NodeResources advertisedResources;
private final NodeResources requestedResources;
/** The current membership role of this host in the cluster it belongs to */
private final Optional<ClusterMembership> membership;
private final Optional<Version> version;
private final Optional<DockerImage> dockerImageRepo;
private final Optional<NetworkPorts> networkPorts;
/** Create a host in a non-cloud system, where hosts are specified in config */
public HostSpec(String hostname, Optional<NetworkPorts> networkPorts) {
this(hostname,
NodeResources.unspecified(), NodeResources.unspecified(), NodeResources.unspecified(),
Optional.empty(), Optional.empty(), networkPorts, Optional.empty());
}
// TODO: Remove when oldest model in use is 8.124
@Deprecated
public HostSpec(String hostname, List<String> ignored, Optional<NetworkPorts> networkPorts) {
this(hostname,
NodeResources.unspecified(), NodeResources.unspecified(), NodeResources.unspecified(),
Optional.empty(), Optional.empty(), networkPorts, Optional.empty());
}
/** Create a host in a hosted system */
public HostSpec(String hostname,
NodeResources realResources,
NodeResources advertisedResources,
NodeResources requestedResources,
ClusterMembership membership,
Optional<Version> version,
Optional<NetworkPorts> networkPorts,
Optional<DockerImage> dockerImageRepo) {
this(hostname,
realResources,
advertisedResources,
requestedResources,
Optional.of(membership),
version,
networkPorts,
dockerImageRepo);
}
private HostSpec(String hostname,
NodeResources realResources,
NodeResources advertisedResurces,
NodeResources requestedResources,
Optional<ClusterMembership> membership,
Optional<Version> version,
Optional<NetworkPorts> networkPorts,
Optional<DockerImage> dockerImageRepo) {
if (hostname == null || hostname.isEmpty()) throw new IllegalArgumentException("Hostname must be specified");
this.hostname = hostname;
this.realResources = Objects.requireNonNull(realResources);
this.advertisedResources = Objects.requireNonNull(advertisedResurces);
this.requestedResources = Objects.requireNonNull(requestedResources, "RequestedResources cannot be null");
this.membership = Objects.requireNonNull(membership);
this.version = Objects.requireNonNull(version, "Version cannot be null but can be empty");
this.networkPorts = Objects.requireNonNull(networkPorts, "Network ports cannot be null but can be empty");
this.dockerImageRepo = Objects.requireNonNull(dockerImageRepo, "Docker image repo cannot be null but can be empty");
}
/** Returns the name identifying this host */
public String hostname() { return hostname; }
/** The real resources available for Vespa processes on this node, after subtracting infrastructure overhead. */
public NodeResources realResources() { return realResources; }
/** The total advertised resources of this node, typically matching what's requested. */
public NodeResources advertisedResources() { return advertisedResources; }
/** Returns the current version of Vespa running on this node, or empty if not known */
public Optional<com.yahoo.component.Version> version() { return version; }
/** Returns the membership of this host, or an empty value if not present */
public Optional<ClusterMembership> membership() { return membership; }
/** Returns the network port allocations on this host, or empty if not present */
public Optional<NetworkPorts> networkPorts() { return networkPorts; }
/** Returns the requested resources leading to this host being provisioned, or empty if unspecified */
public Optional<NodeResources> requestedResources() { return requestedResources.asOptional(); }
public Optional<DockerImage> dockerImageRepo() { return dockerImageRepo; }
public HostSpec withPorts(Optional<NetworkPorts> ports) {
return new HostSpec(hostname, realResources, advertisedResources, requestedResources, membership, version, ports, dockerImageRepo);
}
@Override
public String toString() {
return hostname +
(membership.isPresent() ? " (membership: " + membership.get() + ")" : " (no membership)");
}
@Override
public boolean equals(Object other) {
if (other == this) return true;
if ( ! (other instanceof HostSpec)) return false;
return ((HostSpec)other).hostname.equals(this.hostname);
}
@Override
public int hashCode() {
return hostname.hashCode();
}
@Override
public int compareTo(HostSpec other) {
return hostname.compareTo(other.hostname);
}
}
|
