- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for matchOrFail (0.23 sec)
-
pilot/pkg/serviceregistry/util/xdsfake/updater.go
continue case <-delay.C: t.Fatalf("timed out waiting for %v", et) } } } // MatchOrFail expects the provided events to arrive, skipping unmatched events func (fx *Updater) MatchOrFail(t test.Failer, events ...Event) { t.Helper() fx.matchOrFail(t, false, events...) } // StrictMatchOrFail expects the provided events to arrive, and nothing else
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache_test.go
return ic.serviceImports.Get(name.Name, name.Namespace) != nil } func (ic *serviceImportCacheImpl) checkXDS(t test.Failer) { t.Helper() ic.opts.XDSUpdater.(*xdsfake.Updater).MatchOrFail(t, xdsfake.Event{Type: "service", ID: serviceImportClusterSetHost.String()}) } func (ic *serviceImportCacheImpl) clusterLocalHost() host.Name {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 15.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
// Other than proxy update, no event pushed when workload entry created as no service entry fx.WaitOrFail(t, "proxy") fx.AssertEmpty(t, 40*time.Millisecond) makeService(t, kube, service) fx.MatchOrFail(t, xdsfake.Event{Type: "eds cache", EndpointCount: 1}) instances := []EndpointResponse{{ Address: workloadEntry.Spec.(*networking.WorkloadEntry).Address, Port: 80, }}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
ExternalName: externalName, }, } clienttest.Wrap(t, controller.services).Create(service) if features.EnableExternalNameAlias { xdsEvents.MatchOrFail(t, xdsfake.Event{Type: "service"}) } else { xdsEvents.MatchOrFail(t, xdsfake.Event{Type: "service"}, xdsfake.Event{Type: "eds cache"}) } return service }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
func (s *ambientTestServer) assertUnorderedEvent(t *testing.T, ip ...string) { t.Helper() ev := []xdsfake.Event{} for _, i := range ip { ev = append(ev, xdsfake.Event{Type: "xds", ID: i}) } s.fx.MatchOrFail(t, ev...) } func (s *ambientTestServer) assertNoEvent(t *testing.T) { t.Helper() s.fx.AssertEmpty(t, time.Millisecond*10) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0)