add clone for cached resources

Signed-off-by: denis-tingaikin <[email protected]>
networkservicemesh · Oct 17, 2024 · 3591697 · 3591697
1 parent 18c9ceb
commit 3591697
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/registry/common/querycache/ns_client.go b/pkg/registry/common/querycache/ns_client.go
@@ -68,7 +68,7 @@ func (q *queryCacheNSClient) Find(ctx context.Context, query *registry.NetworkSe
 		}
 		list = registry.ReadNetworkServiceList(streamClient)
 		for _, item := range list {
-			q.cache.Add(item.GetName(), []*registry.NetworkService{item})
+			q.cache.Add(item.GetName(), []*registry.NetworkService{item.Clone()})
 		}
 	}
 	var resultStreamChannel = make(chan *registry.NetworkServiceResponse, len(list))

diff --git a/pkg/registry/common/querycache/nse_client.go b/pkg/registry/common/querycache/nse_client.go
@@ -68,7 +68,7 @@ func (q *queryCacheNSEClient) Find(ctx context.Context, query *registry.NetworkS
 		}
 		list = registry.ReadNetworkServiceEndpointList(streamClient)
 		for _, item := range list {
-			q.cache.Add(item.GetName(), []*registry.NetworkServiceEndpoint{item})
+			q.cache.Add(item.GetName(), []*registry.NetworkServiceEndpoint{item.Clone()})
 		}
 	}
 	var resultStreamChannel = make(chan *registry.NetworkServiceEndpointResponse, len(list))