luxolus
/
open-consul
2
0
Fork 0
Code Issues 1 Pull Requests Packages Releases Wiki Activity

Cancel upstream watches when the discovery chain has been removed

This commit is contained in:
Kyle Havlovitz 2022-07-20 14:26:52 -07:00
parent 77a263ebbb
commit affbb28eb5
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
agent/proxycfg/ingress_gateway.go
View File

@ -148,6 +148,16 @@ func (s *handlerIngressGateway) handleUpdate(ctx context.Context, u UpdateEvent,
for uid, cancelFn := range snap.IngressGateway.WatchedDiscoveryChains {
if _, ok := watchedSvcs[uid]; !ok {
for targetID, cancelUpstreamFn := range snap.IngressGateway.WatchedUpstreams[uid] {
s.logger.Debug("stopping watch of target",
"upstream", uid,
"target", targetID,
)
delete(snap.IngressGateway.WatchedUpstreams[uid], targetID)
delete(snap.IngressGateway.WatchedUpstreamEndpoints[uid], targetID)
cancelUpstreamFn()
}
cancelFn()
delete(snap.IngressGateway.WatchedDiscoveryChains, uid)
}