- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 205 for delay (0.03 sec)
-
tests/integration/telemetry/tracing/zipkin/server_tracing_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz_test.go
*/ package server import ( "testing" "time" testingclock "k8s.io/utils/clock/testing" ) func TestDelayedHealthCheck(t *testing.T) { t.Run("test that liveness check returns true until the delay has elapsed", func(t *testing.T) { t0 := time.Unix(0, 0) c := testingclock.NewFakeClock(t0) doneCh := make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 2.2K bytes - Viewed (0) -
pilot/pkg/xds/monitoring.go
ldsSendErrPushes = pushes.With(typeTag.Value("lds_senderr")) rdsSendErrPushes = pushes.With(typeTag.Value("rds_senderr")) debounceTime = monitoring.NewDistribution( "pilot_debounce_time", "Delay in seconds between the first config enters debouncing and the merged push request is pushed into the push queue.", []float64{.01, .1, 1, 3, 5, 10, 20, 30}, ) pushContextInitTime = monitoring.NewDistribution(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/kube/rpc_creds_test.go
} var m3 map[string]string retry.UntilOrFail(t, func() bool { m3, err = perCred.GetRequestMetadata(ctx) return err == nil && !reflect.DeepEqual(m1, m3) }, retry.Delay(refreshSeconds*time.Second), retry.Timeout(expirationSeconds*time.Second), ) if reflect.DeepEqual(m1, m3) { t.Fatalf("Unexpectedly not getting a new token") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 16 06:24:33 UTC 2022 - 2.4K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-fail-first-gen-first.go
// Regression test for #55160. // // The issue is that the parser reads ahead to the first batch of the // next generation to find generation boundaries, but if it finds an // error, it needs to delay handling that error until later. Previously // it would handle that error immediately and a totally valid generation // would be skipped for parsing and rejected because of an error in a // batch in the following generation. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.7K bytes - Viewed (0) -
src/encoding/json/example_test.go
// Ed: Go fmt. // Sam: Go fmt who? // Ed: Go fmt yourself! // json.Delim: ] } // This example uses RawMessage to delay parsing part of a JSON message. func ExampleRawMessage_unmarshal() { type Color struct { Space string Point json.RawMessage // delay parsing until we know the color space } type RGB struct { R uint8 G uint8 B uint8 } type YCbCr struct { Y uint8
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 6.1K bytes - Viewed (0) -
tests/integration/operator/uninstall_test.go
if checkErr != nil { return checkErr } if exist { return fmt.Errorf("fail to delete iop") } return nil }, retry.Timeout(deletionTimeout), retry.Delay(retryDelay)) }) // For negative casse, use default profile, ingressgateway alway connect to istiod // deletion will fail t.NewSubTest("delete-iop-fail").Run(func(t framework.TestContext) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 7.7K bytes - Viewed (0) -
tests/integration/ambient/wasm_test.go
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{ Name: "http", }, HTTP: echo.HTTP{ Path: "/path", Method: "GET",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 21:02:05 UTC 2024 - 7.2K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformWithDependenciesParallelIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 3.2K bytes - Viewed (0) -
cmd/metrics-v2_test.go
}, { val: 0.79, label: labels[2], }, } ticker := time.NewTicker(1 * time.Millisecond) defer ticker.Stop() for _, obs := range observations { // Send observations once every 1ms, to simulate delay between // observations. This is to test the channel based // synchronization used internally. select { case <-ticker.C: ttfbHist.With(prometheus.Labels{"api": obs.label}).Observe(obs.val) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 04 18:05:56 UTC 2024 - 2.3K bytes - Viewed (0)