Trait quilkin::xds::service::cluster::v3::cluster_discovery_service_server::ClusterDiscoveryService

source · [−]
pub trait ClusterDiscoveryService: Send + Sync + 'static {
    type StreamClustersStream: Stream<Item = Result<DiscoveryResponse, Status>> + Send + 'static;
    type DeltaClustersStream: Stream<Item = Result<DeltaDiscoveryResponse, Status>> + Send + 'static;

    fn stream_clusters<'life0, 'async_trait>(
        &'life0 self,
        request: Request<Streaming<DiscoveryRequest>>
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamClustersStream>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn delta_clusters<'life0, 'async_trait>(
        &'life0 self,
        request: Request<Streaming<DeltaDiscoveryRequest>>
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::DeltaClustersStream>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn fetch_clusters<'life0, 'async_trait>(
        &'life0 self,
        request: Request<DiscoveryRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<DiscoveryResponse>, 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 ClusterDiscoveryServiceServer.

Required Associated Types

Server streaming response type for the StreamClusters method.

Server streaming response type for the DeltaClusters method.

Required Methods

Implementors