Type Alias quilkin_xds::client::AdsClient
source · pub type AdsClient = Client<AggregatedDiscoveryServiceClient<Channel>>;Aliased Type§
struct AdsClient { /* private fields */ }Implementations§
source§impl AdsClient
impl AdsClient
sourcepub async fn delta_subscribe<C: Configuration>(
self,
config: Arc<C>,
is_healthy: Arc<AtomicBool>,
notifier: Option<UnboundedSender<String>>,
resources: impl IntoIterator<Item = (&'static str, Vec<String>)>
) -> Result<DeltaSubscription, Self>
pub async fn delta_subscribe<C: Configuration>( self, config: Arc<C>, is_healthy: Arc<AtomicBool>, notifier: Option<UnboundedSender<String>>, resources: impl IntoIterator<Item = (&'static str, Vec<String>)> ) -> Result<DeltaSubscription, Self>
Attempts to start a new delta stream to the xDS management server, if the management server does not support delta xDS we return the client as an error