| /third_party/grpc/src/core/ext/filters/client_channel/xds/ |
| D | xds_client_stats.cc | 39 absl::string_view eds_service_name) in XdsClusterDropStats() argument
43 eds_service_name_(eds_service_name) {} in XdsClusterDropStats()
68 absl::string_view cluster_name, absl::string_view eds_service_name, in XdsClusterLocalityStats() argument
73 eds_service_name_(eds_service_name), in XdsClusterLocalityStats()
|
| D | xds_client.h | 111 void WatchEndpointData(absl::string_view eds_service_name,
113 void CancelEndpointDataWatch(absl::string_view eds_service_name,
120 absl::string_view eds_service_name);
123 absl::string_view eds_service_name,
130 absl::string_view eds_service_name,
134 absl::string_view eds_service_name,
|
| D | xds_client.cc | 1002 xds_client(), cluster_name, cds_update.eds_service_name.c_str(), in AcceptCdsUpdate()
1008 eds_resource_names_seen.insert(cds_update.eds_service_name.empty() in AcceptCdsUpdate()
1010 : cds_update.eds_service_name); in AcceptCdsUpdate()
1014 cds_update.eds_service_name == cluster_state.update->eds_service_name && in AcceptCdsUpdate()
1065 const char* eds_service_name = p.first.c_str(); in AcceptEdsUpdate() local
1067 auto& state = eds_state.subscribed_resources[eds_service_name]; in AcceptEdsUpdate()
1118 xds_client()->endpoint_map_[eds_service_name]; in AcceptEdsUpdate()
1875 absl::string_view eds_service_name, in WatchEndpointData() argument
1877 std::string eds_service_name_str = std::string(eds_service_name); in WatchEndpointData()
1893 void XdsClient::CancelEndpointDataWatch(absl::string_view eds_service_name, in CancelEndpointDataWatch() argument
[all …]
|
| D | xds_client_stats.h | 107 absl::string_view eds_service_name);
179 absl::string_view eds_service_name,
|
| D | xds_api.cc | 1542 cds_update.eds_service_name = UpbStringToStdString(service_name); in CdsResponseParse()
2014 const std::string& eds_service_name = p.first.second; in CreateLrsRequest() local
2025 if (!eds_service_name.empty()) { in CreateLrsRequest()
2028 upb_strview_make(eds_service_name.data(), eds_service_name.size())); in CreateLrsRequest()
|
| D | xds_api.h | 168 std::string eds_service_name; member
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | xds_cluster_impl.cc | 68 const std::string& eds_service_name);
79 const std::string& eds_service_name) { in GetOrCreate() argument
80 Key key(cluster, eds_service_name); in GetOrCreate()
126 std::string cluster_name, std::string eds_service_name, in XdsClusterImplLbConfig() argument
132 eds_service_name_(std::move(eds_service_name)), in XdsClusterImplLbConfig()
144 const std::string& eds_service_name() const { return eds_service_name_; } in eds_service_name() function in grpc_core::__anon93b706d90111::XdsClusterImplLbConfig
436 config_->cluster_name(), config_->eds_service_name()); in UpdateLocked()
439 config_->cluster_name(), config_->eds_service_name()); in UpdateLocked()
445 GPR_ASSERT(config_->eds_service_name() == old_config->eds_service_name()); in UpdateLocked()
559 xds_cluster_impl_policy_->config_->eds_service_name(), in CreateSubchannel()
[all …]
|
| D | lrs.cc | 44 std::string cluster_name, std::string eds_service_name, in LrsLbConfig() argument
49 eds_service_name_(std::move(eds_service_name)), in LrsLbConfig()
60 const std::string& eds_service_name() const { return eds_service_name_; } in eds_service_name() function in grpc_core::__anonbac676690111::LrsLbConfig
250 config_->eds_service_name() != old_config->eds_service_name() || in UpdateLocked()
254 config_->eds_service_name(), config_->locality_name()); in UpdateLocked()
417 std::string eds_service_name; in ParseLoadBalancingConfig() local
424 eds_service_name = it->second.string_value(); in ParseLoadBalancingConfig()
460 std::move(eds_service_name), std::move(lrs_load_reporting_server_name), in ParseLoadBalancingConfig()
|
| D | eds.cc | 58 EdsLbConfig(std::string cluster_name, std::string eds_service_name, in EdsLbConfig() argument
62 eds_service_name_(std::move(eds_service_name)), in EdsLbConfig()
71 const std::string& eds_service_name() const { return eds_service_name_; } in eds_service_name() function in grpc_core::__anona97502f40111::EdsLbConfig
167 if (!config_->eds_service_name().empty()) { in GetEdsResourceName()
168 return config_->eds_service_name(); in GetEdsResourceName()
178 return {config_->cluster_name(), config_->eds_service_name()}; in GetLrsClusterKey()
809 std::string eds_service_name; in ParseLoadBalancingConfig() local
816 eds_service_name = it->second.string_value(); in ParseLoadBalancingConfig()
888 std::move(cluster_name), std::move(eds_service_name), in ParseLoadBalancingConfig()
913 old_eds_config->eds_service_name() != in ConfigChangeRequiresNewPolicyInstance()
[all …]
|
| D | xds_cluster_resolver.cc | 73 std::string eds_service_name; member
80 type == other.type && eds_service_name == other.eds_service_name); in operator ==()
137 .eds_service_name.empty()) { in GetXdsClusterResolverResourceName()
139 .eds_service_name; in GetXdsClusterResolverResourceName()
151 parent_->config_->discovery_mechanisms()[index_].eds_service_name}; in GetLrsClusterKey()
1333 discovery_mechanism->eds_service_name = it->second.string_value(); in ParseDiscoveryMechanism()
|
| D | cds.cc | 410 if (!state.update->eds_service_name.empty()) { in GenerateDiscoveryMechanismForCluster()
411 mechanism["edsServiceName"] = state.update->eds_service_name; in GenerateDiscoveryMechanismForCluster()
|
| /third_party/grpc/src/core/ext/xds/ |
| D | xds_client.h | 158 void WatchEndpointData(absl::string_view eds_service_name,
160 void CancelEndpointDataWatch(absl::string_view eds_service_name,
167 absl::string_view eds_service_name);
170 absl::string_view eds_service_name,
177 absl::string_view eds_service_name,
181 absl::string_view eds_service_name,
|
| D | xds_client_stats.cc | 47 absl::string_view eds_service_name) in XdsClusterDropStats() argument
54 eds_service_name_(eds_service_name) { in XdsClusterDropStats()
99 absl::string_view cluster_name, absl::string_view eds_service_name, in XdsClusterLocalityStats() argument
107 eds_service_name_(eds_service_name), in XdsClusterLocalityStats()
|
| D | xds_client.cc | 1008 eds_resource_names_seen.insert(cds_update.eds_service_name.empty() in AcceptCdsUpdate()
1010 : cds_update.eds_service_name); in AcceptCdsUpdate()
1076 const char* eds_service_name = p.first.c_str(); in AcceptEdsUpdate() local
1078 auto& state = eds_state.subscribed_resources[eds_service_name]; in AcceptEdsUpdate()
1082 eds_service_name, eds_update.ToString().c_str()); in AcceptEdsUpdate()
1085 xds_client()->endpoint_map_[eds_service_name]; in AcceptEdsUpdate()
1927 absl::string_view eds_service_name, in WatchEndpointData() argument
1929 std::string eds_service_name_str = std::string(eds_service_name); in WatchEndpointData()
1946 void XdsClient::CancelEndpointDataWatch(absl::string_view eds_service_name, in CancelEndpointDataWatch() argument
1951 std::string eds_service_name_str = std::string(eds_service_name); in CancelEndpointDataWatch()
[all …]
|
| D | xds_api.cc | 432 if (!eds_service_name.empty()) { in ToString()
434 absl::StrFormat("eds_service_name=%s", eds_service_name)); in ToString()
1710 cds_update.eds_service_name = UpbStringToStdString(service_name); in CdsResponseParse()
2108 std::string eds_service_name = UpbStringToStdString( in EdsResponseParse() local
2111 if (expected_eds_service_names.find(eds_service_name) == in EdsResponseParse()
2116 if (eds_update_map->find(eds_service_name) != eds_update_map->end()) { in EdsResponseParse()
2118 absl::StrCat("duplicate resource name \"", eds_service_name, "\"") in EdsResponseParse()
2120 resource_names_failed->insert(eds_service_name); in EdsResponseParse()
2123 XdsApi::EdsUpdate& eds_update = (*eds_update_map)[eds_service_name]; in EdsResponseParse()
2148 absl::StrCat(eds_service_name, ": locality validation error") in EdsResponseParse()
[all …]
|
| D | xds_api.h | 237 std::string eds_service_name; member
261 eds_service_name == other.eds_service_name &&
|
| D | xds_client_stats.h | 133 absl::string_view eds_service_name);
207 absl::string_view eds_service_name,
|