Home
last modified time | relevance | path

Searched refs:kCdsTypeUrl (Results 1 – 7 of 7) sorted by relevance

/third_party/grpc/src/core/ext/xds/
Dxds_client.cc212 } else if (type_url_ == XdsApi::kCdsTypeUrl) { in OnTimerLocked()
726 Subscribe(XdsApi::kCdsTypeUrl, std::string(p.first)); in AdsCallState()
808 type_url != XdsApi::kCdsTypeUrl && type_url != XdsApi::kEdsTypeUrl) { in SendMessageLocked()
996 auto& cds_state = state_map_[XdsApi::kCdsTypeUrl]; in AcceptCdsUpdate()
1166 ResourceNamesForRequest(XdsApi::kCdsTypeUrl), in OnResponseReceivedLocked()
1197 } else if (result.type_url == XdsApi::kCdsTypeUrl) { in OnResponseReceivedLocked()
1905 chand_->Subscribe(XdsApi::kCdsTypeUrl, cluster_name_str); in WatchClusterData()
1920 chand_->Unsubscribe(XdsApi::kCdsTypeUrl, cluster_name_str, in CancelClusterDataWatch()
Dxds_api.h54 static const char* kCdsTypeUrl; variable
Dxds_api.cc527 const char* XdsApi::kCdsTypeUrl = member in grpc_core::XdsApi
550 return type_url == XdsApi::kCdsTypeUrl || type_url == kCdsV2TypeUrl; in IsCds()
751 if (type_url == XdsApi::kCdsTypeUrl) { in TypeUrlExternalToInternal()
2198 return XdsApi::kCdsTypeUrl; in TypeUrlInternalToExternal()
/third_party/grpc/src/core/ext/filters/client_channel/xds/
Dxds_client.cc195 } else if (type_url_ == XdsApi::kCdsTypeUrl) { in OnTimerLocked()
729 Subscribe(XdsApi::kCdsTypeUrl, std::string(p.first)); in AdsCallState()
810 type_url != XdsApi::kCdsTypeUrl && type_url != XdsApi::kEdsTypeUrl) { in SendMessageLocked()
991 auto& cds_state = state_map_[XdsApi::kCdsTypeUrl]; in AcceptCdsUpdate()
1219 ResourceNamesForRequest(XdsApi::kCdsTypeUrl), in OnResponseReceivedLocked()
1251 } else if (type_url == XdsApi::kCdsTypeUrl) { in OnResponseReceivedLocked()
1854 chand_->Subscribe(XdsApi::kCdsTypeUrl, cluster_name_str); in WatchClusterData()
1868 chand_->Unsubscribe(XdsApi::kCdsTypeUrl, cluster_name_str, in CancelClusterDataWatch()
Dxds_api.h46 static const char* kCdsTypeUrl; variable
Dxds_api.cc133 const char* XdsApi::kCdsTypeUrl = "type.googleapis.com/envoy.api.v2.Cluster"; member in grpc_core::XdsApi
1503 if (!upb_strview_eql(type_url, upb_strview_makez(XdsApi::kCdsTypeUrl))) { in CdsResponseParse()
1798 } else if (*type_url == kCdsTypeUrl) { in ParseAdsResponse()
/third_party/grpc/test/cpp/end2end/
Dxds_end2end_test.cc114 constexpr char kCdsTypeUrl[] = "type.googleapis.com/envoy.api.v2.Cluster"; variable
650 return resource_type_response_state_[kCdsTypeUrl]; in cds_response_state()
703 SetResource(std::move(resource), kCdsTypeUrl, cluster.name()); in SetCdsResource()
933 if (resource_type == kLdsTypeUrl || resource_type == kCdsTypeUrl) { in CompleteBuildingDiscoveryResponse()
1940 balancers_[0]->ads_service()->UnsetResource(kCdsTypeUrl, in TEST_P()
3808 balancers_[0]->ads_service()->SetResourceIgnore(kCdsTypeUrl); in TEST_P()