Home
last modified time | relevance | path

Searched refs:EdsUpdate (Results 1 – 11 of 11) sorted by relevance

/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
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.cc301 void OnEndpointChanged(XdsApi::EdsUpdate update) override { in OnEndpointChanged()
/third_party/grpc/src/core/ext/xds/
Dxds_api.h274 struct EdsUpdate { struct
349 bool operator==(const EdsUpdate& other) const { argument
356 using EdsUpdateMap = std::map<std::string /*eds_service_name*/, EdsUpdate>;
Dxds_client.h77 virtual void OnEndpointChanged(XdsApi::EdsUpdate update) = 0;
273 absl::optional<XdsApi::EdsUpdate> update;
Dxds_api.cc453 std::string XdsApi::EdsUpdate::Priority::Locality::ToString() const { in ToString()
463 bool XdsApi::EdsUpdate::Priority::operator==(const Priority& other) const { in operator ==()
476 std::string XdsApi::EdsUpdate::Priority::ToString() const { in ToString()
484 bool XdsApi::EdsUpdate::DropConfig::ShouldDrop( in ShouldDrop()
498 std::string XdsApi::EdsUpdate::DropConfig::ToString() const { in ToString()
508 std::string XdsApi::EdsUpdate::ToString() const { in ToString()
1992 XdsApi::EdsUpdate::Priority::Locality* output_locality, size_t* priority) { in LocalityParse()
2034 XdsApi::EdsUpdate::DropConfig* drop_config) { in DropParseAndAppend()
2123 XdsApi::EdsUpdate& eds_update = (*eds_update_map)[eds_service_name]; in EdsResponseParse()
2132 XdsApi::EdsUpdate::Priority::Locality locality; in EdsResponseParse()
[all …]
Dxds_client.cc1077 XdsApi::EdsUpdate& eds_update = p.second; in AcceptEdsUpdate()
/third_party/grpc/src/core/ext/filters/client_channel/xds/
Dxds_client.h74 virtual void OnEndpointChanged(XdsApi::EdsUpdate update) = 0;
217 absl::optional<XdsApi::EdsUpdate> update;
Dxds_api.h279 struct EdsUpdate { struct
284 using EdsUpdateMap = std::map<std::string /*eds_service_name*/, EdsUpdate>; argument
Dxds_client.cc1066 XdsApi::EdsUpdate& eds_update = p.second; in AcceptEdsUpdate()
1121 const XdsApi::EdsUpdate& prev_update = endpoint_state.update.value(); in AcceptEdsUpdate()
Dxds_api.cc1686 XdsApi::EdsUpdate eds_update; in EdsResponseParse()