blob: 57cec06e27bf897c09b15c7b8431c06e90378df9 (
plain) (
blame)
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 2018 gRPC authors.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
#ifndef GRPC_SRC_CORE_EXT_XDS_XDS_CLUSTER_H
#define GRPC_SRC_CORE_EXT_XDS_XDS_CLUSTER_H
#include <grpc/support/port_platform.h>
#include <stdint.h>
#include <algorithm>
#include <memory>
#include <set>
#include <util/generic/string.h>
#include <util/string/cast.h>
#include <vector>
#include "y_absl/strings/string_view.h"
#include "y_absl/types/optional.h"
#include "y_absl/types/variant.h"
#include "envoy/config/cluster/v3/cluster.upbdefs.h"
#include "envoy/extensions/clusters/aggregate/v3/cluster.upbdefs.h"
#include "envoy/extensions/transport_sockets/tls/v3/tls.upbdefs.h"
#include "upb/def.h"
#include "src/core/ext/filters/client_channel/lb_policy/outlier_detection/outlier_detection.h"
#include "src/core/ext/xds/xds_bootstrap.h"
#include "src/core/ext/xds/xds_bootstrap_grpc.h"
#include "src/core/ext/xds/xds_client.h"
#include "src/core/ext/xds/xds_common_types.h"
#include "src/core/ext/xds/xds_health_status.h"
#include "src/core/ext/xds/xds_resource_type.h"
#include "src/core/ext/xds/xds_resource_type_impl.h"
#include "src/core/lib/json/json.h"
namespace grpc_core {
bool XdsCustomLbPolicyEnabled();
bool XdsOverrideHostEnabled();
struct XdsClusterResource : public XdsResourceType::ResourceData {
struct Eds {
// If empty, defaults to the cluster name.
TString eds_service_name;
bool operator==(const Eds& other) const {
return eds_service_name == other.eds_service_name;
}
};
struct LogicalDns {
// The hostname to lookup in DNS.
TString hostname;
bool operator==(const LogicalDns& other) const {
return hostname == other.hostname;
}
};
struct Aggregate {
// Prioritized list of cluster names.
std::vector<TString> prioritized_cluster_names;
bool operator==(const Aggregate& other) const {
return prioritized_cluster_names == other.prioritized_cluster_names;
}
};
y_absl::variant<Eds, LogicalDns, Aggregate> type;
// The LB policy to use for locality and endpoint picking.
Json::Array lb_policy_config;
// Note: Remaining fields are not used for aggregate clusters.
// The LRS server to use for load reporting.
// If not set, load reporting will be disabled.
y_absl::optional<GrpcXdsBootstrap::GrpcXdsServer> lrs_load_reporting_server;
// Tls Context used by clients
CommonTlsContext common_tls_context;
// Maximum number of outstanding requests can be made to the upstream
// cluster.
uint32_t max_concurrent_requests = 1024;
y_absl::optional<OutlierDetectionConfig> outlier_detection;
std::set<XdsHealthStatus> override_host_statuses;
bool operator==(const XdsClusterResource& other) const {
return type == other.type && lb_policy_config == other.lb_policy_config &&
lrs_load_reporting_server == other.lrs_load_reporting_server &&
common_tls_context == other.common_tls_context &&
max_concurrent_requests == other.max_concurrent_requests &&
outlier_detection == other.outlier_detection &&
override_host_statuses == other.override_host_statuses;
}
TString ToString() const;
};
class XdsClusterResourceType
: public XdsResourceTypeImpl<XdsClusterResourceType, XdsClusterResource> {
public:
y_absl::string_view type_url() const override {
return "envoy.config.cluster.v3.Cluster";
}
DecodeResult Decode(const XdsResourceType::DecodeContext& context,
y_absl::string_view serialized_resource) const override;
bool AllResourcesRequiredInSotW() const override { return true; }
void InitUpbSymtab(XdsClient*, upb_DefPool* symtab) const override {
envoy_config_cluster_v3_Cluster_getmsgdef(symtab);
envoy_extensions_clusters_aggregate_v3_ClusterConfig_getmsgdef(symtab);
envoy_extensions_transport_sockets_tls_v3_UpstreamTlsContext_getmsgdef(
symtab);
}
};
} // namespace grpc_core
#endif // GRPC_SRC_CORE_EXT_XDS_XDS_CLUSTER_H
|
