Add warning message for resources missing from linear cache to help d…

…ebugging
utilitywarehouse · Jan 16, 2025 · 95eac4c · 95eac4c
1 parent 758883b
commit 95eac4c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/xds/snapshotter.go b/xds/snapshotter.go
@@ -448,6 +448,12 @@ func (s *Snapshotter) OnStreamDeltaRequest(id int64, r *discovery.DeltaDiscovery
 		"unsubscribes", strings.Join(r.GetResourceNamesUnsubscribe(), ", "),
 		"response_nonce", r.GetResponseNonce(),
 	)
+	for _, resource := range r.GetResourceNamesSubscribe() {
+		resources := s.getDeltaCacheForType(r.GetTypeUrl()).GetResources()
+		if _, ok := resources[resource]; !ok {
+			log.Logger.Warn("Resource not found in cache", "type", r.GetTypeUrl(), "resource", resource)
+		}
+	}
 	return nil
 }