Struct quilkin_xds::server::ControlPlane

pub struct ControlPlane<C> {
    pub config: Arc<C>,
    pub idle_request_interval: Duration,
    pub is_relay: bool,
    /* private fields */
}

Fields

config: Arc<C>

idle_request_interval: Duration

is_relay: bool

Implementations

impl<C: Configuration> ControlPlane<C>

pub fn from_arc(config: Arc<C>, idle_request_interval: Duration) -> Self

pub fn management_server( self, listener: TcpListener ) -> Result<impl Future<Output = Result<()>>>

pub fn relay_server( self, listener: TcpListener ) -> Result<impl Future<Output = Result<()>>>

pub fn push_update(&self, resource_type: &'static str)

pub async fn delta_aggregated_resources<S>( &self, streaming: S ) -> Result<impl Stream<Item = Result<DeltaDiscoveryResponse, Status>> + Send, Status>

where S: Stream<Item = Result<DeltaDiscoveryRequest, Status>> + Send + Unpin + 'static,

Trait Implementations

impl<C: Configuration> AggregatedControlPlaneDiscoveryService for ControlPlane<C>

type StreamAggregatedResourcesStream = Pin<Box<dyn Stream<Item = Result<DiscoveryRequest, Status>> + Send>>

Server streaming response type for the StreamAggregatedResources method.

type DeltaAggregatedResourcesStream = Pin<Box<dyn Stream<Item = Result<DeltaDiscoveryRequest, Status>> + Send>>

Server streaming response type for the DeltaAggregatedResources method.

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

where Self: 'async_trait, 'life0: 'async_trait,

This RPC is not supported but remains here as part of the xDS standard, as Quilkin only uses a delta configuration transport for performance reasons.

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

where Self: 'async_trait, 'life0: 'async_trait,

Delta (Incremental) xDS implementation

impl<C: Configuration> AggregatedDiscoveryService for ControlPlane<C>

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

Server streaming response type for the StreamAggregatedResources method.

type DeltaAggregatedResourcesStream = Pin<Box<dyn Stream<Item = Result<DeltaDiscoveryResponse, Status>> + Send>>

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<C> Clone for ControlPlane<C>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.