- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 86 for delay (0.05 sec)
-
pilot/pkg/xds/discovery_test.go
return fmt.Errorf("got %v full and %v partial, expected %v full and %v partial", full, partial, expectedFull, expectedPartial) } return nil } }, retry.Timeout(opts.DebounceAfter*8), retry.Delay(opts.DebounceAfter/2)) if err != nil { t.Error(err) } } // Send updates tt.test(updateCh, expect) close(stopCh) wg.Wait() }) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/test/framework/components/namespace/kube.go
"default", types.JSONPatchType, []byte(`[{"op": "add", "path": "/imagePullSecrets", "value": [{"name": "test-gcr-secret"}]}]`), metav1.PatchOptions{}) return err }, retry.Delay(1*time.Second), retry.Timeout(10*time.Second)) if err != nil { return err } } return nil } func (n *kubeNamespace) forEachCluster(fn func(i int, c cluster.Cluster) error) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 9K bytes - Viewed (0) -
src/time/sleep.go
func sendTime(c any, seq uintptr, delta int64) { // delta is how long ago the channel send was supposed to happen. // The current time can be arbitrarily far into the future, because the runtime // can delay a sendTime call until a goroutines tries to receive from // the channel. Subtract delta to go back to the old time that we // used to send. select { case c.(chan Time) <- Now().Add(Duration(-delta)): default: }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:21:30 UTC 2024 - 8.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
source.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_CLEAN, 13L, metadata.size, "abcdefghijklm", metadata) } @Test fun multipleSources() { val upstream = Buffer() upstream.writeUtf8("abcdefghijklm") val relay = edit(file, upstream, metadata, 1024) val source1 = relay.newSource()!!.buffer() val source2 = relay.newSource()!!.buffer()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.1K bytes - Viewed (0) -
testing/performance/src/performanceTest/groovy/org/gradle/performance/regression/corefeature/ParallelDownloadsPerformanceTest.groovy
def path = httpRequest.servletPath // compute a digest based on the path, allowing us to use the same latency for the same request each time int sig = DELAYS[path.bytes.sum() % DELAYS.length] def ext = path.contains('.') ? path.substring(1 + path.lastIndexOf('.')) : '' int latency = sig * FACTORS[ext] def file = path.substring(path.lastIndexOf('/'))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 5.3K bytes - Viewed (0) -
docs/tr/docs/advanced/testing-websockets.md
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Mon May 27 16:21:03 UTC 2024 - 471 bytes - Viewed (0) -
docs/pt/docs/advanced/index.md
Na próxima seção você verá outras opções, configurações, e recursos adicionais. !!! tip "Dica" As próximas seções **não são necessáriamente "avançadas"** E é possível que para seu caso de uso, a solução esteja em uma delas. ## Leia o Tutorial primeiro Você ainda pode usar a maior parte dos recursos no **FastAPI** com o conhecimento do [Tutorial - Guia de Usuário](../tutorial/index.md){.internal-link target=_blank}.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Mar 31 23:52:53 UTC 2024 - 1.2K bytes - Viewed (0) -
docs/tr/docs/tutorial/static-files.md
Bu parametrelerin hepsi "`static`"den farklı olabilir, bunları kendi uygulamanızın ihtiyaçlarına göre belirleyebilirsiniz. ## Daha Fazla Bilgi
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Mon May 20 23:57:08 UTC 2024 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/wrap.go
} else { metrics.RecordRequestAbort(req, info) } // This call can have different handlers, but the default chain rate limits. Call it after the metrics are updated // in case the rate limit delays it. If you outrun the rate for this one timed out requests, something has gone // seriously wrong with your server, but generally having a logging signal for timeouts is useful.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 3.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
/** How long to wait to retry pre-emptive connection attempts that fail. */ @JvmField val backoffDelayMillis: Long = 60 * 1000, /** How much jitter to introduce in connection retry backoff delays */ @JvmField val backoffJitterMillis: Int = 100, )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 03 20:39:41 UTC 2024 - 5.6K bytes - Viewed (0)