- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 110 for Petry (0.09 sec)
-
pilot/pkg/xds/xds_cache_test.go
"istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/xds/endpoints" "istio.io/istio/pkg/config" "istio.io/istio/pkg/config/schema/kind" "istio.io/istio/pkg/test/util/retry" "istio.io/istio/pkg/util/sets" ) var ( proxy = &model.Proxy{Metadata: &model.NodeMetadata{}} any1 = &discovery.Resource{Resource: &anypb.Any{TypeUrl: "foo"}}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 31 20:43:08 UTC 2023 - 7.8K bytes - Viewed (0) -
pkg/webhooks/webhookpatch.go
func (w *WebhookCertPatcher) webhookPatchTask(o types.NamespacedName) error { err := w.patchMutatingWebhookConfig(o.Name) // do not want to retry the task if these errors occur, they indicate that // we should no longer be patching the given webhook
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 28 00:36:38 UTC 2023 - 6.1K bytes - Viewed (0) -
security/pkg/server/ca/node_auth.go
// This would only happen if a pod is re-created with the same name, and the CSR client is not in sync on which is current; // this is fine and should be eventually consistent. Client is expected to retry in this case. return fmt.Errorf("pod found, but UID does not match: %v vs %v", callerPod.UID, caller.PodUID) } if callerPod.Spec.ServiceAccountName != caller.PodServiceAccount {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 6.4K bytes - Viewed (0) -
pilot/pkg/networking/core/route/retry/retry_test.go
g.Expect(policy.HostSelectionRetryMaxAttempts).To(Equal(retry.DefaultPolicy().HostSelectionRetryMaxAttempts)) g.Expect(policy.RetryHostPredicate).To(Equal(retry.DefaultPolicy().RetryHostPredicate)) }, }, { name: "TestRetryOnWithEmptyParts", // Create a route with a retry policy with empty retry conditions configured. route: &networking.HTTPRoute{ Retries: &networking.HTTPRetry{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/config/mesh/kubemesh/watcher_test.go
}) t.Run("only core", func(t *testing.T) { cms, w := setup(t) if _, err := cms.Create(context.Background(), cmCore, metav1.CreateOptions{}); err != nil { t.Fatal(err) } retry.UntilOrFail(t, func() bool { return w.Mesh().GetIngressClass() == "core" }, retry.Delay(time.Millisecond), retry.Timeout(time.Second)) }) t.Run("invalid user config", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 7.7K bytes - Viewed (0) -
tests/integration/pilot/multicluster_test.go
"istio.io/istio/pkg/test/framework/components/echo" "istio.io/istio/pkg/test/framework/components/echo/check" "istio.io/istio/pkg/test/util/retry" "istio.io/istio/pkg/test/util/tmpl" ) var ( multiclusterRetryTimeout = retry.Timeout(1 * time.Minute) multiclusterRetryDelay = retry.Delay(500 * time.Millisecond) ) func TestClusterLocal(t *testing.T) { // nolint: staticcheck framework.NewTest(t).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.2K bytes - Viewed (0) -
tests/integration/ambient/wasm_test.go
} return nil } func sendTraffic(ctx framework.TestContext, checker echo.Checker, options ...retry.Option) { ctx.Helper() if len(GetClientInstances()) == 0 { ctx.Fatal("there is no client") } cltInstance := GetClientInstances()[0] defaultOptions := []retry.Option{retry.Delay(100 * time.Millisecond), retry.Timeout(200 * time.Second)} httpOpts := echo.CallOptions{ To: GetTarget(), Port: echo.Port{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 21:02:05 UTC 2024 - 7.2K bytes - Viewed (0) -
tests/integration/security/file_mounted_certs/p2p_mtls_test.go
Count: 1, Port: echo.Port{ Name: "http", }, Check: check.And( check.OK(), check.RequestHeader("X-Forwarded-Client-Cert", ExpectedXfccHeader)), Retry: echo.Retry{ Options: []retry.Option{retry.Delay(5 * time.Second), retry.Timeout(1 * time.Minute)}, }, } client[0].CallOrFail(t, opts) }) } const ( DestinationRuleConfigMutual = ` apiVersion: networking.istio.io/v1alpha3
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.8K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/sidecar.go
t.Fatal(err) } return cfg } func (s *sidecar) WaitForConfig(accept func(*admin.ConfigDump) (bool, error), options ...retry.Option) error { options = append([]retry.Option{retry.BackoffDelay(defaultConfigDelay), retry.Timeout(defaultConfigTimeout)}, options...) var cfg *admin.ConfigDump _, err := retry.UntilComplete(func() (result any, completed bool, err error) { cfg, err = s.Config() if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 09 03:49:49 UTC 2023 - 5.6K bytes - Viewed (0) -
tests/integration/pilot/vm_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.4K bytes - Viewed (0)