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
139
140
141
|
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.hosted.controller.application;
import com.google.common.collect.ImmutableMap;
import com.yahoo.component.Version;
import com.yahoo.config.provision.ClusterSpec.Id;
import com.yahoo.vespa.hosted.controller.api.application.v4.model.ClusterMetrics;
import com.yahoo.vespa.hosted.controller.api.integration.deployment.ApplicationVersion;
import com.yahoo.config.provision.zone.ZoneId;
import java.time.Instant;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
/**
* A deployment of an application in a particular zone.
*
* @author bratseth
* @author smorgrav
*/
public class Deployment {
private final ZoneId zone;
private final ApplicationVersion applicationVersion;
private final Version version;
private final Instant deployTime;
private final Map<Id, ClusterUtilization> clusterUtilization;
private final Map<Id, ClusterInfo> clusterInfo;
private final DeploymentMetrics metrics;
private final DeploymentActivity activity;
private final List<ClusterMetrics> clusterMetrics;
public Deployment(ZoneId zone, ApplicationVersion applicationVersion, Version version, Instant deployTime) {
this(zone, applicationVersion, version, deployTime, Collections.emptyMap(), Collections.emptyMap(),
DeploymentMetrics.none, DeploymentActivity.none, Collections.emptyList());
}
public Deployment(ZoneId zone, ApplicationVersion applicationVersion, Version version, Instant deployTime,
Map<Id, ClusterUtilization> clusterUtilization, Map<Id, ClusterInfo> clusterInfo,
DeploymentMetrics metrics,
DeploymentActivity activity,
List<ClusterMetrics> clusterMetrics) {
this.zone = Objects.requireNonNull(zone, "zone cannot be null");
this.applicationVersion = Objects.requireNonNull(applicationVersion, "applicationVersion cannot be null");
this.version = Objects.requireNonNull(version, "version cannot be null");
this.deployTime = Objects.requireNonNull(deployTime, "deployTime cannot be null");
this.clusterUtilization = ImmutableMap.copyOf(Objects.requireNonNull(clusterUtilization, "clusterUtilization cannot be null"));
this.clusterInfo = ImmutableMap.copyOf(Objects.requireNonNull(clusterInfo, "clusterInfo cannot be null"));
this.metrics = Objects.requireNonNull(metrics, "deploymentMetrics cannot be null");
this.activity = Objects.requireNonNull(activity, "activity cannot be null");
this.clusterMetrics = Objects.requireNonNull(clusterMetrics, "cluster metrics cannot be null");
}
/** Returns the zone this was deployed to */
public ZoneId zone() { return zone; }
/** Returns the deployed application version */
public ApplicationVersion applicationVersion() { return applicationVersion; }
/** Returns the deployed Vespa version */
public Version version() { return version; }
/** Returns the time this was deployed */
public Instant at() { return deployTime; }
/** Returns metrics for this */
public DeploymentMetrics metrics() {
return metrics;
}
/** Returns activity for this */
public DeploymentActivity activity() { return activity; }
/** Returns information about the clusters allocated to this */
public Map<Id, ClusterInfo> clusterInfo() {
return clusterInfo;
}
/** Returns utilization of the clusters allocated to this */
public Map<Id, ClusterUtilization> clusterUtils() {
return clusterUtilization;
}
public List<ClusterMetrics> clusterMetrics() {
return clusterMetrics;
}
public Deployment recordActivityAt(Instant instant) {
return new Deployment(zone, applicationVersion, version, deployTime, clusterUtilization, clusterInfo, metrics,
activity.recordAt(instant, metrics), clusterMetrics);
}
public Deployment withClusterUtils(Map<Id, ClusterUtilization> clusterUtilization) {
return new Deployment(zone, applicationVersion, version, deployTime, clusterUtilization, clusterInfo, metrics,
activity, clusterMetrics);
}
public Deployment withClusterInfo(Map<Id, ClusterInfo> newClusterInfo) {
return new Deployment(zone, applicationVersion, version, deployTime, clusterUtilization, newClusterInfo, metrics,
activity, clusterMetrics);
}
public Deployment withMetrics(DeploymentMetrics metrics) {
return new Deployment(zone, applicationVersion, version, deployTime, clusterUtilization, clusterInfo, metrics,
activity, clusterMetrics);
}
public Deployment withClusterMetrics(List<ClusterMetrics> newClusterMetrics) {
return new Deployment(zone, applicationVersion, version, deployTime, clusterUtilization, clusterInfo, metrics,
activity, newClusterMetrics);
}
/**
* Calculate cost for this deployment.
*
* This is based on cluster utilization and cluster info.
*/
public DeploymentCost calculateCost() {
Map<String, ClusterCost> costClusters = new HashMap<>();
for (Id clusterId : clusterUtilization.keySet()) {
// Only include cluster cost if we have both cluster utilization and cluster info
if (clusterInfo.containsKey(clusterId)) {
costClusters.put(clusterId.value(), new ClusterCost(clusterInfo.get(clusterId),
clusterUtilization.get(clusterId)));
}
}
return new DeploymentCost(costClusters);
}
@Override
public String toString() {
return "deployment to " + zone + " of " + applicationVersion + " on version " + version + " at " + deployTime;
}
}
|
