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
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.config.model.api;
import java.util.List;
import java.util.Objects;
/**
* Represents one endpoint for an application cluster
*
* @author mortent
*/
public class ApplicationClusterEndpoint {
private final DnsName dnsName;
private final Scope scope;
private final RoutingMethod routingMethod;
private final int weight;
private final List<String> hostNames;
private final String clusterId;
private final AuthMethod authMethod;
private ApplicationClusterEndpoint(DnsName dnsName, Scope scope, RoutingMethod routingMethod, int weight, List<String> hostNames, String clusterId, AuthMethod authMethod) {
this.dnsName = Objects.requireNonNull(dnsName);
this.scope = Objects.requireNonNull(scope);
this.routingMethod = Objects.requireNonNull(routingMethod);
this.weight = weight;
this.hostNames = List.copyOf(Objects.requireNonNull(hostNames));
this.clusterId = Objects.requireNonNull(clusterId);
this.authMethod = Objects.requireNonNull(authMethod);
}
public DnsName dnsName() {
return dnsName;
}
public Scope scope() {
return scope;
}
public RoutingMethod routingMethod() {
return routingMethod;
}
public int weight() {
return weight;
}
public List<String> hostNames() {
return hostNames;
}
public String clusterId() {
return clusterId;
}
public AuthMethod authMethod() {
return authMethod;
}
@Override
public String toString() {
return "ApplicationClusterEndpoint{" +
"dnsName=" + dnsName +
", scope=" + scope +
", routingMethod=" + routingMethod +
", weight=" + weight +
", hostNames=" + hostNames +
", clusterId='" + clusterId + '\'' +
", authMethod=" + authMethod +
'}';
}
public static Builder builder() {
return new Builder();
}
public enum Scope { application, global, zone }
public enum RoutingMethod { shared, sharedLayer4, exclusive }
public enum AuthMethod { mtls, token }
public static class Builder {
private DnsName dnsName;
private Scope scope;
private RoutingMethod routingMethod;
private int weight = 1;
private List<String> hosts;
private String clusterId;
private AuthMethod authMethod = AuthMethod.mtls; // TODO(mpolden): For compatibility with older config-models. Remove when < 8.221 is gone
public Builder dnsName(DnsName name) {
this.dnsName = name;
return this;
}
public Builder zoneScope() {
this.scope = Scope.zone;
return this;
}
public Builder scope(Scope scope) {
this.scope = scope;
return this;
}
public Builder sharedRouting() {
this.routingMethod = RoutingMethod.shared;
return this;
}
public Builder sharedL4Routing() {
this.routingMethod = RoutingMethod.sharedLayer4;
return this;
}
public Builder routingMethod(RoutingMethod routingMethod) {
this.routingMethod = routingMethod;
return this;
}
public Builder weight(int weigth) {
this.weight = weigth;
return this;
}
public Builder hosts(List<String> hosts) {
this.hosts = List.copyOf(hosts);
return this;
}
public Builder clusterId(String clusterId) {
this.clusterId = clusterId;
return this;
}
public Builder authMethod(AuthMethod authMethod) {
this.authMethod = authMethod;
return this;
}
public ApplicationClusterEndpoint build() {
return new ApplicationClusterEndpoint(dnsName, scope, routingMethod, weight, hosts, clusterId, authMethod);
}
}
public record DnsName(String name) implements Comparable<DnsName> {
public String value() {
return name;
}
public static DnsName from(String name) {
return new DnsName(name);
}
@Override
public int compareTo(DnsName o) {
return name.compareTo(o.name);
}
}
}
|
