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
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.flags.custom;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.Objects;
import java.util.Optional;
import static com.yahoo.vespa.flags.custom.Validation.requirePositive;
import static com.yahoo.vespa.flags.custom.Validation.validArchitectures;
import static com.yahoo.vespa.flags.custom.Validation.validClusterTypes;
import static com.yahoo.vespa.flags.custom.Validation.validDiskSpeeds;
import static com.yahoo.vespa.flags.custom.Validation.validStorageTypes;
import static com.yahoo.vespa.flags.custom.Validation.validateEnum;
/**
* The advertised node resources of a host, similar to config-provision's NodeResources,
* but with additional host-specific resources like the number of containers.
*
* @author freva
*/
@JsonIgnoreProperties(ignoreUnknown = true)
public class HostResources {
private final double vcpu;
private final double memoryGb;
private final double diskGb;
private final double bandwidthGbps;
private final String diskSpeed;
private final String storageType;
private final Optional<String> clusterType;
private final int containers;
private final String architecture;
@JsonCreator
public HostResources(@JsonProperty("vcpu") Double vcpu,
@JsonProperty("memoryGb") Double memoryGb,
@JsonProperty("diskGb") Double diskGb,
@JsonProperty("bandwidthGbps") Double bandwidthGbps,
@JsonProperty("diskSpeed") String diskSpeed,
@JsonProperty("storageType") String storageType,
@JsonProperty("clusterType") String clusterType,
@JsonProperty("containers") Integer containers,
@JsonProperty("architecture") String architecture) {
this.vcpu = requirePositive("vcpu", vcpu);
this.memoryGb = requirePositive("memoryGb", memoryGb);
this.diskGb = requirePositive("diskGb", diskGb);
this.bandwidthGbps = requirePositive("bandwidthGbps", bandwidthGbps);
this.diskSpeed = validateEnum("diskSpeed", validDiskSpeeds, diskSpeed);
this.storageType = validateEnum("storageType", validStorageTypes, storageType);
this.clusterType = Optional.ofNullable(clusterType).map(cType -> validateEnum("clusterType", validClusterTypes, cType));
this.containers = requirePositive("containers", containers);
this.architecture = validateEnum("architecture", validArchitectures, architecture);
}
@JsonProperty("vcpu")
public double vcpu() { return vcpu; }
@JsonProperty("memoryGb")
public double memoryGb() { return memoryGb; }
@JsonProperty("diskGb")
public double diskGb() { return diskGb; }
@JsonProperty("bandwidthGbps")
public double bandwidthGbps() { return bandwidthGbps; }
@JsonProperty("diskSpeed")
public String diskSpeed() { return diskSpeed; }
@JsonProperty("storageType")
public String storageType() { return storageType; }
@JsonProperty("clusterType")
public String clusterTypeOrNull() { return clusterType.orElse(null); }
@JsonIgnore
public Optional<String> clusterType() { return clusterType; }
@JsonProperty("containers")
public int containers() { return containers; }
@JsonProperty("architecture")
public String architecture() { return architecture; }
public boolean satisfiesClusterType(String clusterType) {
return this.clusterType.map(clusterType::equalsIgnoreCase).orElse(true);
}
@Override
public String toString() {
return "HostResources{" +
"vcpu=" + vcpu +
", memoryGb=" + memoryGb +
", diskGb=" + diskGb +
", bandwidthGbps=" + bandwidthGbps +
", diskSpeed='" + diskSpeed + '\'' +
", storageType='" + storageType + '\'' +
", clusterType='" + clusterType + '\'' +
", containers=" + containers +
", architecture=" + architecture +
'}';
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
HostResources resources = (HostResources) o;
return Double.compare(resources.vcpu, vcpu) == 0 &&
Double.compare(resources.memoryGb, memoryGb) == 0 &&
Double.compare(resources.diskGb, diskGb) == 0 &&
Double.compare(resources.bandwidthGbps, bandwidthGbps) == 0 &&
diskSpeed.equals(resources.diskSpeed) &&
storageType.equals(resources.storageType) &&
clusterType.equals(resources.clusterType) &&
containers == resources.containers &&
architecture.equals(resources.architecture);
}
@Override
public int hashCode() {
return Objects.hash(vcpu, memoryGb, diskGb, bandwidthGbps, diskSpeed, storageType, clusterType, containers, architecture);
}
}
|
