feat(tonic-xds): implement gRFC A50 outlier detection (failure-percentage) + LoadBalancer integration

tonic-xds/Cargo.toml

@@ -45,7 +45,7 @@ tokio = { version = "1", features = ["sync", "time"] }
 fastrand = "2"
 indexmap = "2"
 tracing = "0.1"
-tokio-stream = "0.1"
+tokio-stream = { version = "0.1", features = ["sync"] }
 tokio-util = "0.7"
 backoff = "0.4"
 shared_http_body = "0.1"

tonic-xds/src/client/endpoint.rs

@@ -5,7 +5,7 @@ use std::task::{Context, Poll};
 use tower::{Service, load::Load};
 
 /// Represents the host part of an endpoint address
-#[derive(Debug, Clone, PartialEq, Eq, Hash)]
+#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
 enum EndpointHost {
     Ipv4(std::net::Ipv4Addr),
     Ipv6(std::net::Ipv6Addr),
@@ -25,7 +25,7 @@ impl From<String> for EndpointHost {
 }
 
 /// Represents a validated endpoint address extracted from xDS
-#[derive(Debug, Clone, PartialEq, Eq, Hash)]
+#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
 pub(crate) struct EndpointAddress {
     /// The IP address or hostname
     host: EndpointHost,