Home
last modified time | relevance | path

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

/third_party/grpc/src/core/ext/xds/
Dxds_client.cc217 } else if (type_url_ == XdsApi::kEdsTypeUrl) { in OnTimerLocked()
729 Subscribe(XdsApi::kEdsTypeUrl, std::string(p.first)); in AdsCallState()
808 type_url != XdsApi::kCdsTypeUrl && type_url != XdsApi::kEdsTypeUrl) { in SendMessageLocked()
1051 auto& eds_state = state_map_[XdsApi::kEdsTypeUrl]; in AcceptCdsUpdate()
1074 auto& eds_state = state_map_[XdsApi::kEdsTypeUrl]; in AcceptEdsUpdate()
1167 ResourceNamesForRequest(XdsApi::kEdsTypeUrl)); in OnResponseReceivedLocked()
1199 } else if (result.type_url == XdsApi::kEdsTypeUrl) { in OnResponseReceivedLocked()
1943 chand_->Subscribe(XdsApi::kEdsTypeUrl, eds_service_name_str); in WatchEndpointData()
1958 chand_->Unsubscribe(XdsApi::kEdsTypeUrl, eds_service_name_str, in CancelEndpointDataWatch()
Dxds_api.h55 static const char* kEdsTypeUrl; variable
Dxds_api.cc529 const char* XdsApi::kEdsTypeUrl = member in grpc_core::XdsApi
554 return type_url == XdsApi::kEdsTypeUrl || type_url == kEdsV2TypeUrl; in IsEds()
754 if (type_url == XdsApi::kEdsTypeUrl) { in TypeUrlExternalToInternal()
2200 return XdsApi::kEdsTypeUrl; in TypeUrlInternalToExternal()
/third_party/grpc/src/core/ext/filters/client_channel/xds/
Dxds_client.cc201 } else if (type_url_ == XdsApi::kEdsTypeUrl) { in OnTimerLocked()
732 Subscribe(XdsApi::kEdsTypeUrl, std::string(p.first)); in AdsCallState()
810 type_url != XdsApi::kCdsTypeUrl && type_url != XdsApi::kEdsTypeUrl) { in SendMessageLocked()
1046 auto& eds_state = state_map_[XdsApi::kEdsTypeUrl]; in AcceptCdsUpdate()
1063 auto& eds_state = state_map_[XdsApi::kEdsTypeUrl]; in AcceptEdsUpdate()
1220 ResourceNamesForRequest(XdsApi::kEdsTypeUrl), &lds_update, &rds_update, in OnResponseReceivedLocked()
1253 } else if (type_url == XdsApi::kEdsTypeUrl) { in OnResponseReceivedLocked()
1890 chand_->Subscribe(XdsApi::kEdsTypeUrl, eds_service_name_str); in WatchEndpointData()
1904 chand_->Unsubscribe(XdsApi::kEdsTypeUrl, eds_service_name_str, in CancelEndpointDataWatch()
Dxds_api.h47 static const char* kEdsTypeUrl; variable
Dxds_api.cc134 const char* XdsApi::kEdsTypeUrl = member in grpc_core::XdsApi
1689 if (!upb_strview_eql(type_url, upb_strview_makez(XdsApi::kEdsTypeUrl))) { in EdsResponseParse()
1801 } else if (*type_url == kEdsTypeUrl) { in ParseAdsResponse()
/third_party/grpc/test/cpp/end2end/
Dxds_end2end_test.cc115 constexpr char kEdsTypeUrl[] = variable
655 return resource_type_response_state_[kEdsTypeUrl]; in eds_response_state()
709 SetResource(std::move(resource), kEdsTypeUrl, assignment.cluster_name()); in SetEdsResource()
3818 balancers_[0]->ads_service()->SetResourceIgnore(kEdsTypeUrl); in TEST_P()