- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 195 for Petry (0.03 sec)
-
pilot/pkg/networking/grpcgen/grpcecho_test.go
// ensure we can make 10 consecutive successful requests retry.UntilSuccessOrFail(tt.T, func() error { cw := tt.dialEcho("xds:///echo-app.default.svc.cluster.local:7070") for i := 0; i < 10; i++ { _, err := cw.Echo(context.Background(), &proto.EchoRequest{Message: "needle"}) if err != nil { return err } } return nil }, retry.Timeout(5*time.Second), retry.Delay(0)) } func TestFault(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 8.3K bytes - Viewed (0) -
tests/integration/security/util/reachability/context.go
opts.To = to if len(toClusters) == 1 { opts.Count = 1 } // TODO(https://github.com/istio/istio/issues/37629) go back to converge opts.Retry.Options = []retry.Option{retry.Converge(1)} // TODO(https://github.com/istio/istio/issues/37629) go back to 5s opts.Timeout = time.Second * 10 expectSuccess := c.ExpectSuccess(from, opts)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 23 21:20:43 UTC 2022 - 8.6K bytes - Viewed (0) -
tests/integration/security/filebased_tls_origination/egress_gateway_origination_test.go
Count: 1, Port: echo.Port{ Name: "http", }, HTTP: echo.HTTP{ Headers: headers.New().WithHost(host).Build(), }, Retry: echo.Retry{ Options: []retry.Option{retry.Delay(1 * time.Second), retry.Timeout(2 * time.Minute)}, }, Check: check.And( check.NoError(), check.Status(tc.code), check.Each(func(r echoClient.Response) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/instance.go
"istio.io/istio/pkg/test/framework/resource" "istio.io/istio/pkg/test/util/retry" "istio.io/istio/pkg/util/istiomultierror" ) const ( tcpHealthPort = 3333 httpReadinessPort = 8080 ) var ( _ echo.Instance = &instance{} _ io.Closer = &instance{} startDelay = retry.BackoffDelay(time.Millisecond * 100) ) type instance struct { id resource.ID
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 16 18:55:23 UTC 2023 - 9K bytes - Viewed (0) -
tests/integration/security/sds_ingress/util/util.go
callType CallType, tlsCtx TLSContext, exRsp ExpectedResponse, useHTTP3 bool, ) { ctx.Helper() opts := echo.CallOptions{ Timeout: time.Second, Retry: echo.Retry{ Options: []retry.Option{retry.Timeout(time.Minute * 2)}, }, Port: echo.Port{ Protocol: protocol.HTTPS, }, HTTP: echo.HTTP{ HTTP3: useHTTP3, Path: fmt.Sprintf("/%s", path),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 05:12:36 UTC 2023 - 20.2K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta_test.go
} // Wait until nonce was updated, which represents an ACK/NACK has been received. retry.UntilSuccessOrFail(t, func() error { if proxy.ecdsLastNonce.Load() == n1.Load() { return errors.New("last process nonce has not been updated. no ecds ack/nack is received yet") } return nil }, retry.Timeout(time.Second), retry.Delay(time.Millisecond))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 6.3K bytes - Viewed (0) -
tests/integration/pilot/mirror_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/test/framework/components/istio/util.go
scopes.Framework.Info("Creating dummy virtual service to check for validation webhook readiness") return retry.UntilSuccess(func() error { err := ctx.ConfigKube(cluster).YAML("", dummyValidationVirtualService).Apply() if err == nil { return nil } return fmt.Errorf("validation webhook not ready yet: %v", err) }, retry.Timeout(time.Minute)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 17:13:34 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/test/framework/components/crd/gateway.go
"istio.io/istio/pkg/test/env" "istio.io/istio/pkg/test/framework" "istio.io/istio/pkg/test/framework/resource" "istio.io/istio/pkg/test/framework/resource/config/apply" "istio.io/istio/pkg/test/util/retry" ) // SupportsGatewayAPI checks if the gateway API is supported. func SupportsGatewayAPI(t resource.Context) bool { for _, cluster := range t.Clusters() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 17:54:38 UTC 2023 - 2.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
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 }, retry.Timeout(time.Second*1), retry.Delay(time.Millisecond*5))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0)