Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for InsertContains (0.17 sec)

  1. 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)
  2. 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)
Back to top