- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for addWorkloadEntries (0.55 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go
s := newAmbientTestServer(t, testC, testNW) s.addWorkloadEntries(t, "127.0.0.1", "name1", "sa1", map[string]string{"app": "a"}) s.assertWorkloads(t, "", workloadapi.WorkloadStatus_HEALTHY, "name1") s.assertEvent(t, s.wleXdsName("name1")) s.addWorkloadEntries(t, "127.0.0.2", "name2", "sa2", map[string]string{"app": "a", "other": "label"}) s.addWorkloadEntries(t, "127.0.0.3", "name3", "sa3", map[string]string{"app": "other"})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go
s.assertEvent(t, s.podXdsName("pod2")) s.assertWorkloads(t, "", workloadapi.WorkloadStatus_HEALTHY, "pod1", "pod2") s.addWorkloadEntries(t, "240.240.34.56", "name1", "sa1", map[string]string{"app": "a"}) s.assertEvent(t, s.wleXdsName("name1")) s.addWorkloadEntries(t, "240.240.34.57", "name2", "sa1", map[string]string{"app": "other"}) s.assertEvent(t, s.wleXdsName("name2"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 03:01:04 UTC 2024 - 12.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
t.Helper() svc := s.sc.Get(name, testNS) if svc == nil { return } svc.ObjectMeta.Labels = labels s.sc.Update(svc) } func (s *ambientTestServer) addWorkloadEntries(t *testing.T, ip string, name, sa string, labels map[string]string) { t.Helper() s.we.CreateOrUpdate(generateWorkloadEntry(ip, name, "ns1", sa, labels, nil)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0)