Function quilkin_xds::config::handle_delta_discovery_responses
source · pub fn handle_delta_discovery_responses<C: Configuration>(
identifier: String,
stream: impl Stream<Item = Result<DeltaDiscoveryResponse>> + 'static + Send,
config: Arc<C>,
local: Arc<LocalVersions>,
remote_addr: Option<SocketAddr>,
notifier: Option<UnboundedSender<String>>
) -> Pin<Box<dyn Stream<Item = Result<DeltaDiscoveryRequest>> + Send>>
Expand description
Processes responses from management servers, applying resources to the proxy