- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for InsertContains (0.17 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
func (s *ambientTestServer) assertUniqueWorkloads(t *testing.T) { t.Helper() uids := sets.New[string]() workloads := s.lookup("") for _, wl := range workloads { if wl.GetWorkload() != nil && uids.InsertContains(wl.GetWorkload().GetUid()) { t.Fatal("Index has workloads with the same UID") } } } func (s *ambientTestServer) deletePolicy(name, ns string, kind config.GroupVersionKind, ) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
if !f { // The destination we are pointing to is not an alias, so this is the terminal step resolvedAliases[alias] = referencedService break } if seen.InsertContains(n) { // We did a loop! // Kubernetes will make these NXDomain, so we can just treat it like it doesn't exist at all break } referencedService = n } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)