- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 108 for Petry (0.03 sec)
-
pilot/pkg/networking/core/route/retry/retry.go
// See the License for the specific language governing permissions and // limitations under the License. package retry import ( "net/http" "strconv" "strings" route "github.com/envoyproxy/go-control-plane/envoy/config/route/v3" previouspriorities "github.com/envoyproxy/go-control-plane/envoy/extensions/retry/priority/previous_priorities/v3" wrappers "google.golang.org/protobuf/types/known/wrapperspb"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 5K bytes - Viewed (0) -
pkg/test/util/assert/tracker.go
} return nil }, retry.Timeout(time.Second), retry.BackoffDelay(time.Millisecond)) if err != nil { t.t.Fatal(err) } t.Empty() } // WaitCompare waits for an event to happen and ensures it meets a custom comparison function func (t *Tracker[T]) WaitCompare(f func(T) bool) { t.t.Helper() var err error retry.UntilSuccessOrFail(t.t, func() error { t.mu.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/flags.go
} // DefaultCallRetryOptions returns the default call retry options as specified in command-line flags. func DefaultCallRetryOptions() []retry.Option { return []retry.Option{retry.Timeout(callTimeout), retry.BackoffDelay(callDelay), retry.Converge(callConverge)} } // DefaultReadinessTimeout returns the default echo readiness check timeout.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 13 17:44:00 UTC 2022 - 2.4K bytes - Viewed (0) -
tests/integration/pilot/gw_topology_test.go
--- `).ApplyOrFail(t, apply.NoCleanup) cs := t.Clusters().Default().(*kubecluster.Cluster) retry.UntilSuccessOrFail(t, func() error { _, err := kubetest.CheckPodsAreReady(kubetest.NewPodFetch(cs, gatewayNs.Name(), "istio=ingressgateway")) return err }, retry.Timeout(time.Minute*2), retry.Delay(time.Second))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8K bytes - Viewed (0) -
pkg/security/retry.go
var CARetryOptions = []retry.CallOption{ retry.WithMax(5), retry.WithBackoff(wrapBackoffWithMetrics(retry.BackoffExponentialWithJitter(100*time.Millisecond, 0.1))), retry.WithCodes(codes.Canceled, codes.DeadlineExceeded, codes.ResourceExhausted, codes.Aborted, codes.Internal, codes.Unavailable), } // CARetryInterceptor is a grpc UnaryInterceptor that adds retry options, as a convenience wrapper
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.2K bytes - Viewed (0) -
pkg/istio-agent/health/health_check_test.go
} cont <- struct{}{} eventNum.Inc() }, quitChan) retry.UntilSuccessOrFail(t, func() error { if int(eventNum.Load()) != len(expectedTCPEvents) { return fmt.Errorf("waiting for %v events", len(expectedTCPEvents)-int(eventNum.Load())) } return nil }, retry.Delay(time.Millisecond*10), retry.Timeout(time.Second)) close(quitChan) }) t.Run("http", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 09 16:50:11 UTC 2023 - 6.3K bytes - Viewed (0) -
tests/integration/telemetry/tracing/zipkin/client_tracing_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/webhooks/webhookpatch_test.go
return nil } success.Inc() return nil }) go queue.Run(test.NewStop(t)) retry.UntilOrFail(t, queue.HasSynced) queue.Add(types.NamespacedName{Name: "success"}) retry.UntilOrFail(t, func() bool { return success.Load() == 1 }) queue.Add(types.NamespacedName{Name: "conflict-success"}) retry.UntilOrFail(t, func() bool { return success.Load() == 2 && retries.Load() == 5 })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 02 09:53:38 UTC 2023 - 8.6K bytes - Viewed (0) -
pkg/test/util/assert/assert.go
func EventuallyEqual[T any](t test.Failer, fetch func() T, expected T, retryOpts ...retry.Option) { t.Helper() var a T // Unit tests typically need shorter default; opts can override though ro := []retry.Option{retry.Timeout(time.Second * 2), retry.BackoffDelay(time.Millisecond * 2)} ro = append(ro, retryOpts...) err := retry.UntilSuccess(func() error { a = fetch() if !cmp.Equal(a, expected, opts(expected)...) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 18 17:21:50 UTC 2023 - 4.4K bytes - Viewed (0) -
tests/integration/telemetry/api/istioctl_metrics_test.go
"istio.io/istio/pkg/test/util/retry" ) // TestIstioctlMetrics contains a basic validation of the experimental // metrics command. It validates that values are being returned when there is // traffic and that the expected default output format is matched. func TestIstioctlMetrics(t *testing.T) { framework.NewTest(t). Run(func(t framework.TestContext) { retry.UntilSuccessOrFail(t, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.8K bytes - Viewed (0)