Struct quilkin_xds::client::Client

pub struct Client<C: ServiceClient> { /* private fields */ }

Client that can talk to an XDS server using the aDS protocol.

Implementations

impl<C: ServiceClient> Client<C>

pub async fn connect( identifier: String, management_servers: Vec<Endpoint> ) -> Result<Self>

impl Client<AggregatedControlPlaneDiscoveryServiceClient<Channel>>

pub async fn delta_stream<C: Configuration>( self, config: Arc<C>, is_healthy: Arc<AtomicBool> ) -> Result<DeltaSubscription, Self>

impl Client<AggregatedDiscoveryServiceClient<Channel>>

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

Trait Implementations

impl<C: Clone + ServiceClient> Clone for Client<C>

fn clone(&self) -> Client<C>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.