- Sort Score
- Result 10 results
- Languages All
Results 21 - 27 of 27 for UntilOrFail (0.53 sec)
-
pilot/pkg/serviceregistry/kube/controller/pod_test.go
} func waitForPod(t test.Failer, c *FakeController, ip string) { retry.UntilOrFail(t, func() bool { c.pods.RLock() defer c.pods.RUnlock() if _, ok := c.pods.podsByIP[ip]; ok { return true } return false }) } func waitForNode(t test.Failer, c *FakeController, name string) { retry.UntilOrFail(t, func() bool { return c.nodes.Get(name, "") != nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pilot/test/xds/fake.go
// initialized. s.ConfigUpdate(&model.PushRequest{Full: true}) // Wait until initial updates are committed c := s.InboundUpdates.Load() retry.UntilOrFail(t, func() bool { return s.CommittedUpdates.Load() >= c }, retry.Delay(time.Millisecond)) // Mark ourselves ready s.CachesSynced() bufListener, _ := listener.(*bufconn.Listener)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pilot/pkg/config/aggregate/config_test.go
Meta: config.Meta{ GroupVersionKind: gvk.HTTPRoute, Name: "another", }, }) if err != nil { t.Fatal(err) } retry.UntilOrFail(t, handled.Load, retry.Timeout(time.Second)) }) } func schemaFor(kind, proto string) resource.Schema { return resource.Builder{ Kind: kind, Plural: strings.ToLower(kind) + "s", Proto: proto,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 6.7K bytes - Viewed (0) -
tests/util/leak/check.go
func MustGarbageCollect(tb test.Failer, i any) { tb.Helper() collected := atomic.NewBool(false) runtime.SetFinalizer(i, func(x any) { collected.Store(true) }) tb.Cleanup(func() { retry.UntilOrFail(tb, func() bool { // Trigger GC explicitly, otherwise we may need to wait a long time for it to run runtime.GC() return collected.Load()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 10:22:38 UTC 2023 - 6.9K bytes - Viewed (0) -
pilot/pkg/xds/xds_cache_test.go
c.Add(k, req, v) } // 5 round of xds push for vals := 0; vals < 5; vals++ { c.ClearAll() n.Inc() start := time.Now() for i := 0; i < 5; i++ { go work(start, n.Load()) } retry.UntilOrFail(t, func() bool { val := c.Get(k) return val != nil && val.Resource.TypeUrl == fmt.Sprint(n.Load()) }) for i := 0; i < 5; i++ { val := c.Get(k) if val == nil { t.Fatalf("no cache found") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 31 20:43:08 UTC 2023 - 7.8K bytes - Viewed (0) -
tests/integration/helm/util.go
"istio.io/rev": revision, } } createOptions := metav1.CreateOptions{DryRun: []string{metav1.DryRunAll}} istioClient := ctx.Clusters().Default().Istio().NetworkingV1alpha3() retry.UntilOrFail(ctx, func() bool { _, err := istioClient.Gateways(IstioNamespace).Create(context.TODO(), invalidGateway, createOptions) rejected := err != nil return rejected })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 18.7K bytes - Viewed (0) -
tests/integration/ambient/baseline_test.go
grace := p.Spec.TerminationGracePeriodSeconds if grace != nil && *grace == want { return true } } return false } // check that waypoint deployment is unmodified retry.UntilOrFail(t, func() bool { return getGracePeriod(2) }) // change the waypoint template istio.GetOrFail(t, t).UpdateInjectionConfig(t, func(cfg *inject.Config) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0)