- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 95 for delay (0.04 sec)
-
tests/integration/ambient/untaint/untaint_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 1.5K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
tests/integration/security/file_mounted_certs/p2p_mtls_test.go
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) -
okhttp/src/main/kotlin/okhttp3/internal/platform/Android10Platform.kt
class Android10Platform : Platform() { private val socketAdapters = listOfNotNull( Android10SocketAdapter.buildIfSupported(), DeferredSocketAdapter(AndroidSocketAdapter.playProviderFactory), // Delay and Defer any initialisation of Conscrypt and BouncyCastle DeferredSocketAdapter(ConscryptSocketAdapter.factory), DeferredSocketAdapter(BouncyCastleSocketAdapter.factory), ).filter { it.isSupported() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.7K bytes - Viewed (0)