Struct Service 

pub struct Service {
    pub cache: Arc<Cache>,
}

Fields

cache: Arc<Cache>

Implementations

impl Service

pub fn new(cache: Arc<Cache>) -> Self

pub fn stream( &self, req: Request<Streaming<DiscoveryRequest>>, type_url: &'static str, ) -> Result<Response<StreamResponse<DiscoveryResponse>>, Status>

pub async fn fetch( &self, req: &DiscoveryRequest, type_url: &'static str, ) -> Result<Response<DiscoveryResponse>, Status>

Trait Implementations

impl AggregatedDiscoveryService for Service

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, req: 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, __arg1: Request<Streaming<DeltaDiscoveryRequest>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::DeltaAggregatedResourcesStream>, Status>> + Send + 'async_trait>>

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

impl ClusterDiscoveryService for Service

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

Server streaming response type for the StreamClusters method.

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

Server streaming response type for the DeltaClusters method.

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

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

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

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

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

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

impl Debug for Service

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

Formats the value using the given formatter.

impl EndpointDiscoveryService for Service

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

Server streaming response type for the StreamEndpoints method.

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

Server streaming response type for the DeltaEndpoints method.

fn stream_endpoints<'life0, 'async_trait>( &'life0 self, req: 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, __arg1: 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, req: Request<DiscoveryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DiscoveryResponse>, Status>> + Send + 'async_trait>>

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

impl ExtensionConfigDiscoveryService for Service

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

Server streaming response type for the StreamExtensionConfigs method.

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

Server streaming response type for the DeltaExtensionConfigs method.

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

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

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

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

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

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

impl ListenerDiscoveryService for Service

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

Server streaming response type for the StreamListeners method.

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

Server streaming response type for the DeltaListeners method.

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

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

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

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

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

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

impl RouteDiscoveryService for Service

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

Server streaming response type for the StreamRoutes method.

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

Server streaming response type for the DeltaRoutes method.

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

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

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

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

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

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

impl RuntimeDiscoveryService for Service

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

Server streaming response type for the StreamRuntime method.

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

Server streaming response type for the DeltaRuntime method.

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

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

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

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

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

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

impl ScopedRoutesDiscoveryService for Service

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

Server streaming response type for the StreamScopedRoutes method.

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

Server streaming response type for the DeltaScopedRoutes method.

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

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

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

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

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

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

impl SecretDiscoveryService for Service

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

Server streaming response type for the StreamSecrets method.

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

Server streaming response type for the DeltaSecrets method.

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

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

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

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

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

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

impl VirtualHostDiscoveryService for Service

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

Server streaming response type for the DeltaVirtualHosts method.

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

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