Trait quilkin::xds::service::discovery::v3::aggregated_discovery_service_server::AggregatedDiscoveryService
source · [−]pub trait AggregatedDiscoveryService: Send + Sync + 'static {
type StreamAggregatedResourcesStream: Stream<Item = Result<DiscoveryResponse, Status>> + Send + 'static;
type DeltaAggregatedResourcesStream: Stream<Item = Result<DeltaDiscoveryResponse, Status>> + Send + 'static;
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
'life0: 'async_trait,
Self: 'async_trait;
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
'life0: 'async_trait,
Self: 'async_trait;
}
Expand description
Generated trait containing gRPC methods that should be implemented for use with AggregatedDiscoveryServiceServer.
Required Associated Types
sourcetype StreamAggregatedResourcesStream: Stream<Item = Result<DiscoveryResponse, Status>> + Send + 'static
type StreamAggregatedResourcesStream: Stream<Item = Result<DiscoveryResponse, Status>> + Send + 'static
Server streaming response type for the StreamAggregatedResources method.
sourcetype DeltaAggregatedResourcesStream: Stream<Item = Result<DeltaDiscoveryResponse, Status>> + Send + 'static
type DeltaAggregatedResourcesStream: Stream<Item = Result<DeltaDiscoveryResponse, Status>> + Send + 'static
Server streaming response type for the DeltaAggregatedResources method.
Required Methods
sourcefn 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
'life0: 'async_trait,
Self: 'async_trait,
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
'life0: 'async_trait,
Self: 'async_trait,
This is a gRPC-only API.
sourcefn delta_aggregated_resources<'life0, 'async_trait>(