Struct EdsService 

pub struct EdsService { /* private fields */ }

Endpoint Discovery Service.

Implementations

impl EdsService

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

Create a new EDS service.

pub fn new_with_handlers( cache: Arc<ShardedCache>, registry: Arc<ResourceRegistry>, sotw_handler: Arc<SotwHandler>, delta_handler: Arc<DeltaHandler>, ) -> Self

Create a new EDS service with shared protocol handlers.

This allows sharing handlers across multiple services for better resource efficiency.

pub fn type_url() -> &'static str

Get the type URL for endpoints.

pub fn cache(&self) -> &ShardedCache

Get a reference to the cache.

pub fn registry(&self) -> &ResourceRegistry

Get a reference to the registry.

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

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

Trait Implementations

impl Clone for EdsService

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 EdsService

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

Formats the value using the given formatter.

impl EndpointDiscoveryService for EdsService

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

Server streaming response type for the StreamEndpoints method.

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

Server streaming response type for the DeltaEndpoints method.

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

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

The resource_names field in DiscoveryRequest specifies a list of clusters to subscribe to updates for.

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

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

fn fetch_endpoints<'life0, 'async_trait>( &'life0 self, request: Request<DiscoveryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DiscoveryResponse>, Status>> + Send + 'async_trait>>

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