Home
last modified time | relevance | path

Searched refs:XdsApi (Results 1 – 15 of 15) sorted by relevance

/third_party/grpc/src/core/ext/xds/
Dxds_api.cc144 std::string XdsApi::Route::Matchers::ToString() const { in ToString()
158 std::string XdsApi::Route::ClusterWeight::ToString() const { in ToString()
162 std::string XdsApi::Route::ToString() const { in ToString()
181 std::string XdsApi::RdsUpdate::ToString() const { in ToString()
190 for (const XdsApi::Route& route : vhost.routes) { in ToString()
258 XdsApi::RdsUpdate::VirtualHost* XdsApi::RdsUpdate::FindVirtualHostForDomain( in FindVirtualHostForDomain()
303 std::string XdsApi::CommonTlsContext::CertificateValidationContext::ToString() in ToString()
313 bool XdsApi::CommonTlsContext::CertificateValidationContext::Empty() const { in Empty()
321 std::string XdsApi::CommonTlsContext::CertificateProviderInstance::ToString() in ToString()
334 bool XdsApi::CommonTlsContext::CertificateProviderInstance::Empty() const { in Empty()
[all …]
Dxds_client.h50 virtual void OnListenerChanged(XdsApi::LdsUpdate listener) = 0;
59 virtual void OnRouteConfigChanged(XdsApi::RdsUpdate route_config) = 0;
68 virtual void OnClusterChanged(XdsApi::CdsUpdate cluster_data) = 0;
77 virtual void OnEndpointChanged(XdsApi::EdsUpdate update) = 0;
250 absl::optional<XdsApi::LdsUpdate> update;
258 absl::optional<XdsApi::RdsUpdate> update;
265 absl::optional<XdsApi::CdsUpdate> update;
273 absl::optional<XdsApi::EdsUpdate> update;
293 XdsApi::ClusterLoadReportMap BuildLoadReportSnapshotLocked(
300 XdsApi api_;
Dxds_client.cc201 if (type_url_ == XdsApi::kLdsTypeUrl) { in OnTimerLocked()
206 } else if (type_url_ == XdsApi::kRdsTypeUrl) { in OnTimerLocked()
212 } else if (type_url_ == XdsApi::kCdsTypeUrl) { in OnTimerLocked()
217 } else if (type_url_ == XdsApi::kEdsTypeUrl) { in OnTimerLocked()
254 void AcceptLdsUpdate(XdsApi::LdsUpdateMap lds_update_map);
255 void AcceptRdsUpdate(XdsApi::RdsUpdateMap rds_update_map);
256 void AcceptCdsUpdate(XdsApi::CdsUpdateMap cds_update_map);
257 void AcceptEdsUpdate(XdsApi::EdsUpdateMap eds_update_map);
720 Subscribe(XdsApi::kLdsTypeUrl, std::string(p.first)); in AdsCallState()
723 Subscribe(XdsApi::kRdsTypeUrl, std::string(p.first)); in AdsCallState()
[all …]
Dxds_server_config_fetcher.cc96 void OnListenerChanged(XdsApi::LdsUpdate listener) override { in OnListenerChanged()
142 bool UpdateXdsCertificateProvider(const XdsApi::LdsUpdate& listener, in UpdateXdsCertificateProvider()
Dxds_api.h50 class XdsApi {
369 XdsApi(XdsClient* client, TraceFlag* tracer, const XdsBootstrap::Node* node);
/third_party/grpc/src/core/ext/filters/client_channel/xds/
Dxds_client.h62 virtual void OnClusterChanged(XdsApi::CdsUpdate cluster_data) = 0;
74 virtual void OnEndpointChanged(XdsApi::EdsUpdate update) = 0;
209 absl::optional<XdsApi::CdsUpdate> update;
217 absl::optional<XdsApi::EdsUpdate> update;
240 const std::vector<XdsApi::RdsUpdate::RdsRoute::ClusterWeight>&
245 void UpdateWeightedClusterIndexMap(const XdsApi::RdsUpdate& rds_update);
248 grpc_error* CreateServiceConfig(const XdsApi::RdsUpdate& rds_update,
251 XdsApi::ClusterLoadReportMap BuildLoadReportSnapshot(
267 XdsApi api_;
276 absl::optional<XdsApi::LdsUpdate> lds_result_;
[all …]
Dxds_client.cc191 if (type_url_ == XdsApi::kLdsTypeUrl || in OnTimerLocked()
192 type_url_ == XdsApi::kRdsTypeUrl) { in OnTimerLocked()
195 } else if (type_url_ == XdsApi::kCdsTypeUrl) { in OnTimerLocked()
201 } else if (type_url_ == XdsApi::kEdsTypeUrl) { in OnTimerLocked()
241 void AcceptLdsUpdate(absl::optional<XdsApi::LdsUpdate> lds_update);
242 void AcceptRdsUpdate(absl::optional<XdsApi::RdsUpdate> rds_update);
243 void AcceptCdsUpdate(XdsApi::CdsUpdateMap cds_update_map);
244 void AcceptEdsUpdate(XdsApi::EdsUpdateMap eds_update_map);
721 Subscribe(XdsApi::kLdsTypeUrl, xds_client()->server_name_); in AdsCallState()
724 Subscribe(XdsApi::kRdsTypeUrl, in AdsCallState()
[all …]
Dxds_api.cc74 bool XdsApi::PriorityListUpdate::operator==( in operator ==()
75 const XdsApi::PriorityListUpdate& other) const { in operator ==()
85 void XdsApi::PriorityListUpdate::Add( in Add()
86 XdsApi::PriorityListUpdate::LocalityMap::Locality locality) { in Add()
94 const XdsApi::PriorityListUpdate::LocalityMap* XdsApi::PriorityListUpdate::Find( in Find()
100 bool XdsApi::PriorityListUpdate::Contains( in Contains()
113 bool XdsApi::DropConfig::ShouldDrop(const std::string** category_name) const { in ShouldDrop()
130 const char* XdsApi::kLdsTypeUrl = "type.googleapis.com/envoy.api.v2.Listener";
131 const char* XdsApi::kRdsTypeUrl =
133 const char* XdsApi::kCdsTypeUrl = "type.googleapis.com/envoy.api.v2.Cluster";
[all …]
Dxds_api.h42 class XdsApi {
297 XdsApi(XdsClient* client, TraceFlag* tracer, const XdsBootstrap::Node* node);
/third_party/grpc/src/core/ext/filters/client_channel/resolver/xds/
Dxds_resolver.cc74 Notifier(RefCountedPtr<XdsResolver> resolver, XdsApi::LdsUpdate update);
75 Notifier(RefCountedPtr<XdsResolver> resolver, XdsApi::RdsUpdate update);
87 XdsApi::LdsUpdate update_;
95 void OnListenerChanged(XdsApi::LdsUpdate listener) override { in OnListenerChanged()
109 void OnRouteConfigChanged(XdsApi::RdsUpdate route_config) override { in OnRouteConfigChanged()
139 const std::vector<XdsApi::Route>& routes,
156 XdsApi::Route route;
169 const XdsApi::Route& route);
176 void OnListenerUpdate(XdsApi::LdsUpdate listener);
177 void OnRouteConfigUpdate(XdsApi::RdsUpdate rds_update);
[all …]
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_routing.cc60 XdsApi::RdsUpdate::RdsRoute::Matchers matchers;
114 const XdsApi::RdsUpdate::RdsRoute::Matchers* matchers;
225 const XdsApi::RdsUpdate::RdsRoute::Matchers::PathMatcher& path_matcher) { in PathMatch()
227 case XdsApi::RdsUpdate::RdsRoute::Matchers::PathMatcher::PathMatcherType:: in PathMatch()
230 case XdsApi::RdsUpdate::RdsRoute::Matchers::PathMatcher::PathMatcherType:: in PathMatch()
233 case XdsApi::RdsUpdate::RdsRoute::Matchers::PathMatcher::PathMatcherType:: in PathMatch()
263 const XdsApi::RdsUpdate::RdsRoute::Matchers::HeaderMatcher& header_matcher, in HeaderMatchHelper()
280 if (header_matcher.type == XdsApi::RdsUpdate::RdsRoute::Matchers:: in HeaderMatchHelper()
290 case XdsApi::RdsUpdate::RdsRoute::Matchers::HeaderMatcher:: in HeaderMatchHelper()
293 case XdsApi::RdsUpdate::RdsRoute::Matchers::HeaderMatcher:: in HeaderMatchHelper()
[all …]
Dcds.cc75 void OnClusterChanged(XdsApi::CdsUpdate cluster_data) override { in OnClusterChanged()
87 XdsApi::CdsUpdate update);
101 XdsApi::CdsUpdate update_;
114 absl::optional<XdsApi::CdsUpdate> update;
141 XdsApi::CdsUpdate cluster_data);
146 const std::string& cluster_name, const XdsApi::CdsUpdate& cluster_data);
183 XdsApi::CdsUpdate update) in Notifier()
382 if (state.update->cluster_type == XdsApi::CdsUpdate::ClusterType::AGGREGATE) { in GenerateDiscoveryMechanismForCluster()
395 case XdsApi::CdsUpdate::ClusterType::EDS: in GenerateDiscoveryMechanismForCluster()
398 case XdsApi::CdsUpdate::ClusterType::LOGICAL_DNS: in GenerateDiscoveryMechanismForCluster()
[all …]
Dxds_cluster_resolver.cc184 void OnEndpointChanged(XdsApi::EdsUpdate update) override { in OnEndpointChanged()
198 XdsApi::EdsUpdate update);
213 XdsApi::EdsUpdate update_;
270 RefCountedPtr<XdsApi::EdsUpdate::DropConfig> drop_config;
273 absl::optional<XdsApi::EdsUpdate::PriorityList> pending_priority_list;
305 void OnEndpointChanged(size_t index, XdsApi::EdsUpdate update);
311 void UpdatePriorityList(XdsApi::EdsUpdate::PriorityList priority_list);
338 XdsApi::EdsUpdate::PriorityList priority_list_;
421 XdsApi::EdsUpdate update) in Notifier()
531 XdsApi::EdsUpdate update; in ReturnResult()
[all …]
Dxds_cluster_impl.cc129 RefCountedPtr<XdsApi::EdsUpdate::DropConfig> drop_config) in XdsClusterImplLbConfig()
149 RefCountedPtr<XdsApi::EdsUpdate::DropConfig> drop_config() const { in drop_config()
159 RefCountedPtr<XdsApi::EdsUpdate::DropConfig> drop_config_;
213 RefCountedPtr<XdsApi::EdsUpdate::DropConfig> drop_config_;
706 auto drop_config = MakeRefCounted<XdsApi::EdsUpdate::DropConfig>(); in ParseLoadBalancingConfig()
732 const Json& json, XdsApi::EdsUpdate::DropConfig* drop_config) { in ParseDropCategories()
756 const Json& json, XdsApi::EdsUpdate::DropConfig* drop_config) { in ParseDropCategory()
Deds.cc122 RefCountedPtr<XdsApi::DropConfig> drop_config_;
154 void UpdatePriorityList(XdsApi::PriorityListUpdate priority_list_update);
206 XdsApi::PriorityListUpdate priority_list_update_;
210 RefCountedPtr<XdsApi::DropConfig> drop_config_;
301 void OnEndpointChanged(XdsApi::EdsUpdate update) override { in OnEndpointChanged()
506 XdsApi::PriorityListUpdate priority_list_update) { in UpdatePriorityList()