Struct quilkin::xds::ControlPlane

pub struct ControlPlane { /* private fields */ }

Implementations

impl ControlPlane

pub fn new(config: Config) -> Self

Creates a new server for managing Config.

pub fn from_arc(config: Arc<Config>) -> Self

pub async fn stream_aggregated_resources<S>( &self, streaming: S ) -> Result<impl Stream<Item = Result<DiscoveryResponse, Status>> + Send, Status>where S: Stream<Item = Result<DiscoveryRequest, Status>> + Send + Unpin + 'static,

Trait Implementations

impl AggregatedDiscoveryService for ControlPlane

type StreamAggregatedResourcesStream = Pin<Box<dyn Stream<Item = Result<DiscoveryResponse, Status>> + Send + 'static, Global>>

Server streaming response type for the StreamAggregatedResources method.

type DeltaAggregatedResourcesStream = ReceiverStream<Result<DeltaDiscoveryResponse, Status>>

Server streaming response type for the DeltaAggregatedResources method.

fn stream_aggregated_resources<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<DiscoveryRequest>> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamAggregatedResourcesStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

This is a gRPC-only API.

fn delta_aggregated_resources<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<DeltaDiscoveryRequest>> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::DeltaAggregatedResourcesStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

impl Clone for ControlPlane

fn clone(&self) -> ControlPlane

Returns a copy of the value.

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

Performs copy-assignment from source.