- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 108 for Petry (0.17 sec)
-
pkg/revisions/default_watcher_test.go
} } func expectRevision(t test.Failer, watcher DefaultWatcher, expected string) { t.Helper() retry.UntilSuccessOrFail(t, func() error { got := watcher.GetDefault() if got != expected { return fmt.Errorf("wanted default revision %q, got %q", expected, got) } return nil }, retry.Timeout(time.Second*10), retry.BackoffDelay(time.Millisecond*10)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 23 17:46:59 UTC 2023 - 3.2K bytes - Viewed (0) -
tools/istio-iptables/pkg/cmd/root.go
When using Istio CNI, this can occur if a pod is scheduled before the node is ready. If installed with 'cni.repair.deletePods=true', this pod should automatically be deleted and retry. Otherwise, this pod will need to be manually removed so that it is scheduled on a node with istio-cni running, allowing iptables rules to be established. `) handleErrorWithCode(msg, constants.ValidationErrorCode) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 17:36:41 UTC 2024 - 8.1K bytes - Viewed (0) -
pilot/pkg/xds/vm_test.go
}, } ds.Connect(ds.SetupProxy(proxy), nil, nil) var we *config.Config retry.UntilSuccessOrFail(t, func() error { we = ds.Store().Get(gvk.WorkloadEntry, "wg-1.1.1.1-network1", "namespace") if we == nil { return fmt.Errorf("no WE found") } return nil }, retry.Timeout(time.Second*10)) assert.Equal(t, we.Spec.(*v1alpha3.WorkloadEntry).Labels, map[string]string{ "merge": "meta",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/gatewayclass_test.go
gateway "sigs.k8s.io/gateway-api/apis/v1beta1" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/kclient/clienttest" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/retry" ) func TestClassController(t *testing.T) { client := kube.NewFakeClient() cc := NewClassController(client) classes := clienttest.Wrap(t, cc.classes) stop := test.NewStop(t) client.RunAndWait(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 08:41:13 UTC 2024 - 3K bytes - Viewed (0) -
tests/integration/pilot/workloadentry_test.go
Port: ports.HTTP, Scheme: scheme.HTTP, NewConnectionPerRequest: true, Retry: echo.Retry{Options: []retry.Option{multiclusterRetryDelay, retry.Timeout(time.Minute)}}, Count: 10, }) }) } }) } })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/test/framework/components/registryredirector/kube.go
} body, err := json.Marshal(tagMap) if err != nil { return err } err = retry.UntilSuccess(func() error { _, err := client.Post(fmt.Sprintf("http://%s/admin/v1/tagmap", c.forwarder.Address()), "application/json", bytes.NewBuffer(body)) return err }, retry.Delay(100*time.Millisecond), retry.Timeout(20*time.Second)) if err != nil { return err } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 00:53:57 UTC 2024 - 4.6K bytes - Viewed (0) -
tests/integration/telemetry/util.go
t.Helper() err := retry.UntilSuccess(func() error { got, err := prometheus.QuerySum(cluster, query) t.Logf("%s: %f", query.Metric, got) if err != nil { return err } if got < want { return fmt.Errorf("bad metric value: got %f, want at least %f", got, want) } return nil }, retry.Delay(time.Second), retry.Timeout(time.Second*20)) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 16:30:22 UTC 2022 - 4.8K bytes - Viewed (0) -
pkg/monitoring/monitortest/test.go
} return nil } } func (m *MetricsTest) Assert(name string, tags map[string]string, compare Compare, opts ...retry.Option) { m.t.Helper() opt := []retry.Option{retry.Timeout(time.Second * 5), retry.Message("metric not found")} opt = append(opt, opts...) err := retry.UntilSuccess(func() error { res, err := m.reg.Gather() if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 13 16:04:48 UTC 2023 - 7.2K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/tcp.go
func (s *tcpInstance) awaitReady(onReady OnReadyFunc, address string) { defer onReady() err := retry.UntilSuccess(func() error { conn, err := net.Dial("tcp", address) if err != nil { return err } defer func() { _ = conn.Close() }() // Server is up now, we're ready. return nil }, retry.Timeout(readyTimeout), retry.Delay(readyInterval)) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 16:20:31 UTC 2023 - 5.7K bytes - Viewed (0) -
tests/integration/pilot/webhook_test.go
"k8s.io/client-go/kubernetes" "istio.io/api/label" networking "istio.io/api/networking/v1alpha3" "istio.io/client-go/pkg/apis/networking/v1alpha3" "istio.io/istio/pkg/test/framework" "istio.io/istio/pkg/test/util/retry" ) func TestWebhook(t *testing.T) { // nolint: staticcheck framework.NewTest(t). RequiresSingleCluster(). Run(func(t framework.TestContext) { vwcName := "istio-validator"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 01 13:31:34 UTC 2023 - 4.7K bytes - Viewed (0)