- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for UntilOrFail (0.29 sec)
-
pkg/kube/multicluster/secretcontroller_test.go
for _, override := range configOverrides { override(fakeRestConfig) } return kube.NewFakeClient(), nil } client.RunAndWait(stopCh) assert.NoError(t, c.Run(stopCh)) retry.UntilOrFail(t, c.HasSynced, retry.Timeout(2*time.Second)) secret0 := makeSecret(secretNamespace, "s0", clusterCredential{"c0", []byte("kubeconfig0-0")}) secrets := clienttest.NewWriter[*v1.Secret](t, client)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller_test.go
meshWatcher, stop, ) kube.SetObjectFilter(client, discoveryNamespacesFilter) nc := NewNamespaceController(client, watcher) client.RunAndWait(stop) go nc.Run(stop) retry.UntilOrFail(t, nc.queue.HasSynced) expectedData := map[string]string{ constants.CACertNamespaceConfigMapDataName: string(caBundle), } createNamespace(t, client.Kube(), "foo", nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 8.1K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
// Ensure that the client can run without CRDs present func TestClientNoCRDs(t *testing.T) { schema := collection.NewSchemasBuilder().MustAdd(collections.Sidecar).Build() store, _ := makeClient(t, schema, nil) retry.UntilOrFail(t, store.HasSynced, retry.Timeout(time.Second)) r := collections.VirtualService configMeta := config.Meta{ Name: "name", Namespace: "ns", GroupVersionKind: r.GroupVersionKind(), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
enabled: true, } l.AddRunFunction(func(stop <-chan struct{}) { <-stop }) for _, fn := range fns { l.AddRunFunction(fn) } stop := make(chan struct{}) go l.Run(stop) retry.UntilOrFail(t, func() bool { return l.isLeader() == expectLeader }, retry.Converge(5), retry.Delay(time.Millisecond*100), retry.Timeout(time.Second*10)) return l, stop } type fakeDefaultWatcher struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver_test.go
pk, err := r.GetPublicKey("", mockCertURL, testRequestTimeout) if err == nil { t.Fatalf("GetPublicKey(%q, %+v) fails: expected error, got no error: (%v)", pk, mockCertURL, err) } retry.UntilOrFail(t, func() bool { pk, _ := r.GetPublicKey("", mockCertURL, testRequestTimeout) return test.JwtPubKey2 == pk }, retry.Delay(time.Millisecond)) r.Close() i := 0
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 19.2K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
deployments.AddEventHandler(controllers.EventHandler[*appsv1.Deployment]{ AddFunc: func(obj *appsv1.Deployment) { handled.Inc() }, }) c.RunAndWait(test.NewStop(t)) retry.UntilOrFail(t, deployments.HasSynced, retry.Timeout(time.Second*2), retry.Delay(time.Millisecond)) // This checks sync worked properly. This MUST be immediately available, not eventually assert.Equal(t, handled.Load(), 1) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
f.t.Fatalf("failed to create config %v: %v", cfg.Name, err) } } // TODO allow passing event handlers for controller retry.UntilOrFail(f.t, f.store.HasSynced, retry.Delay(time.Millisecond)) retry.UntilOrFail(f.t, f.Registry.HasSynced, retry.Delay(time.Millisecond)) f.ServiceEntryRegistry.ResyncEDS() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
tests/integration/ambient/cacert_rotation_test.go
istioCtl istioctl.Instance, originalCert *configdump.CertsDump, ) *configdump.CertsDump { var newSecret *configdump.CertsDump retry.UntilOrFail(t, func() bool { updatedCert, _, err := getWorkloadSecret(t, []v1.Pod{ztunnelPod}, serviceAccount, istioCtl) if err != nil { t.Logf("failed to get current workload secret: %v", err) return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 6.1K bytes - Viewed (0) -
tests/integration/security/cacert_rotation/main_test.go
} // Abstracted function to wait for workload cert to be updated func waitForWorkloadCertUpdate(t framework.TestContext, from echo.Instance, istioCtl istioctl.Instance, lastUpdateTime time.Time) time.Time { retry.UntilOrFail(t, func() bool { updateTime, err := getWorkloadCertLastUpdateTime(t, from, istioCtl) if err != nil { t.Logf("failed to get workload cert last update time: %v", err) return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 6.6K bytes - Viewed (0) -
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)