Struct AdsService 

pub struct AdsService { /* private fields */ }

Aggregated Discovery Service.

Implements the ADS gRPC service, multiplexing CDS, EDS, LDS, RDS, and SDS over a single bidirectional stream.

Implementations

impl AdsService

pub fn new(cache: Arc<ShardedCache>, registry: Arc<ResourceRegistry>) -> Self

Create a new ADS service.

pub fn with_config( cache: Arc<ShardedCache>, registry: Arc<ResourceRegistry>, config: AdsConfig, ) -> Self

Create with custom configuration.

pub fn cache(&self) -> &ShardedCache

Get a reference to the cache.

pub fn registry(&self) -> &ResourceRegistry

Get a reference to the registry.

pub fn config(&self) -> &AdsConfig

Get a reference to the configuration.

pub fn into_service(self) -> AggregatedDiscoveryServiceServer<Self>

Convert this service into a tonic service for use with Server::add_service.

This creates a properly typed gRPC service using the data-plane-api generated server.

pub fn process_sotw_request( &self, ctx: &StreamContext, type_url: &str, version_info: &str, resource_names: &[String], node_hash: NodeHash, response_nonce: &str, error_detail: Option<&str>, ) -> Result<Option<DiscoveryResponse>, Status>

Process an incoming SotW discovery request.

Trait Implementations

impl AggregatedDiscoveryService for AdsService

type StreamAggregatedResourcesStream = ReceiverStream<Result<DiscoveryResponse, Status>>

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 AdsService

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AdsService

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.