- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 118 for Dequeue (0.11 sec)
-
pkg/registry/core/service/ipallocator/controller/repairip.go
eKey, quit := r.ipQueue.Get() if quit { return false } defer r.ipQueue.Done(eKey) err := r.syncIPAddress(eKey) r.handleIPErr(err, eKey) return true } func (r *RepairIPAddress) handleIPErr(err error, key string) { if err == nil { r.ipQueue.Forget(key) return } if r.ipQueue.NumRequeues(key) < maxRetries {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RouteFailureTest.kt
} @Test fun http2OneBadHostOneGoodRetryOnConnectionFailure() { enableProtocol(Protocol.HTTP_2) val request = Request(server1.url("/")) server1.enqueue(refusedStream) server1.enqueue(refusedStream) server2.enqueue(bodyResponse) dns[server1.hostName] = listOf(ipv6, ipv4) socketFactory[ipv6] = server1.inetSocketAddress socketFactory[ipv4] = server2.inetSocketAddress
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue May 14 17:48:07 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/controller/deployment/progress_test.go
expected: time.Duration(-1), }, { name: "complete deployment does not need to be requeued", d: currentDeployment(&pds, 3, 3, 3, 3, nil), status: newDeploymentStatus(3, 3, 3), expected: time.Duration(-1), }, { name: "already failed deployment does not need to be requeued", d: currentDeployment(&pds, 3, 3, 3, 0, failed), status: newDeploymentStatus(3, 3, 0),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
taskFaker.close() routePlanner.close() } @Test fun takeConnectedConnection() { val plan0 = routePlanner.addPlan() plan0.connectState = TLS_CONNECTED taskRunner.newQueue().execute("connect") { val result0 = finder.find() assertThat(result0).isEqualTo(plan0.connection) } taskFaker.runTasks() assertEvents( "take plan 0", )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 20.9K bytes - Viewed (0) -
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
@Test fun suspendCall() { runTest { server.enqueue(MockResponse(body = "abc")) val call = client.newCall(request) call.executeAsync().use { withContext(Dispatchers.IO) { assertThat(it.body.string()).isEqualTo("abc") } } } } @Test fun timeoutCall() { runTest { server.enqueue( MockResponse.Builder()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 18 01:24:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/kubelet/util/queue/work_queue_test.go
} } func TestGetWork(t *testing.T) { q, clock := newTestBasicWorkQueue() q.Enqueue(types.UID("foo1"), -1*time.Minute) q.Enqueue(types.UID("foo2"), -1*time.Minute) q.Enqueue(types.UID("foo3"), 1*time.Minute) q.Enqueue(types.UID("foo4"), 1*time.Minute) expected := []types.UID{types.UID("foo1"), types.UID("foo2")} compareResults(t, expected, q.GetWork())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/controlplane/controller/crdregistration/crdregistration_controller.go
} } // processNextWorkItem deals with one key off the queue. It returns false when it's time to quit. func (c *crdRegistrationController) processNextWorkItem() bool { // pull the next work item from queue. It should be a key we use to lookup something in a cache key, quit := c.queue.Get() if quit { return false } // you always have to indicate to the queue that you've completed a piece of work defer c.queue.Done(key)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
docs/fr/docs/advanced/path-operation-advanced-configuration.md
Ainsi, vous pouvez ajouter des données supplémentaires au schéma généré automatiquement. Par exemple, vous pouvez décider de lire et de valider la requête avec votre propre code, sans utiliser les fonctionnalités automatiques de validation proposée par Pydantic, mais vous pouvez toujours définir la requête dans le schéma OpenAPI. Vous pouvez le faire avec `openapi_extra` : ```Python hl_lines="20-37 39-40"
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
return } ssc.queue.AddAfter(key, duration) } // processNextWorkItem dequeues items, processes them, and marks them done. It enforces that the syncHandler is never // invoked concurrently with the same key. func (ssc *StatefulSetController) processNextWorkItem(ctx context.Context) bool { key, quit := ssc.queue.Get() if quit { return false } defer ssc.queue.Done(key)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
key, quit := jm.queue.Get() if quit { return false } defer jm.queue.Done(key) requeueAfter, err := jm.sync(ctx, key) switch { case err != nil: utilruntime.HandleError(fmt.Errorf("error syncing CronJobController %v, requeuing: %w", key, err)) jm.queue.AddRateLimited(key) case requeueAfter != nil: jm.queue.Forget(key) jm.queue.AddAfter(key, *requeueAfter) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0)