- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 393 for queues (0.03 sec)
-
docs/es/docs/advanced/additional-responses.md
"new key": "new value", } ``` Puedes usar esa técnica para reutilizar algunos responses predefinidos en tus *path operations* y combinarlos con otros personalizados adicionales. Por ejemplo: {* ../../docs_src/additional_responses/tutorial004.py hl[13:17,26] *} ## Más información sobre responses OpenAPI Para ver exactamente qué puedes incluir en los responses, puedes revisar estas secciones en la especificación OpenAPI:
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 9.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/tls/BasicCertificateChainCleaner.kt
*/ @Throws(SSLPeerUnverifiedException::class) override fun clean( chain: List<Certificate>, hostname: String, ): List<Certificate> { val queue: Deque<Certificate> = ArrayDeque(chain) val result = mutableListOf<Certificate>() result.add(queue.removeFirst()) var foundTrustedCertificate = false followIssuerChain@ for (c in 0 until MAX_SIGNERS) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.8K bytes - Viewed (0) -
cmd/metrics-v3-ilm.go
var ( ilmExpiryPendingTasksMD = NewGaugeMD(expiryPendingTasks, "Number of pending ILM expiry tasks in the queue") ilmTransitionActiveTasksMD = NewGaugeMD(transitionActiveTasks, "Number of active ILM transition tasks") ilmTransitionPendingTasksMD = NewGaugeMD(transitionPendingTasks, "Number of pending ILM transition tasks in the queue")
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Jun 06 09:36:25 UTC 2024 - 2.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
private fun ensureAllTaskQueuesIdle() { val entryTime = System.nanoTime() for (queue in TaskRunner.INSTANCE.activeQueues()) { // We wait at most 1 second, so we don't ever turn multiple lost threads into // a test timeout failure. val waitTime = (entryTime + 1_000_000_000L - System.nanoTime()) if (!queue.idleLatch().await(waitTime, TimeUnit.NANOSECONDS)) { TaskRunner.INSTANCE.withLock {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 10.5K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/replication/minio-replication-node.json
"interval": "1m", "intervalFactor": 2, "legendFormat": "{{server}}", "refId": "A" } ], "title": "Avg. Queued Size", "type": "timeseries" }, { "datasource": { "type": "prometheus", "uid": "${DS_PROMETHEUS}" }, "fieldConfig": { "defaults": {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Aug 04 01:46:49 UTC 2025 - 57.5K bytes - Viewed (0) -
docs/es/docs/advanced/response-headers.md
# Response Headers ## Usa un parámetro `Response` Puedes declarar un parámetro de tipo `Response` en tu *función de path operation* (como puedes hacer para cookies). Y luego puedes establecer headers en ese objeto de response *temporal*. {* ../../docs_src/response_headers/tutorial002.py hl[1, 7:8] *} Y luego puedes devolver cualquier objeto que necesites, como harías normalmente (un `dict`, un modelo de base de datos, etc).
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 17:46:44 UTC 2024 - 2.4K bytes - Viewed (0) -
docs/es/docs/tutorial/request-files.md
Como todos estos métodos son métodos `async`, necesitas "await" para ellos. Por ejemplo, dentro de una *path operation function* `async` puedes obtener los contenidos con: ```Python contents = await myfile.read() ``` Si estás dentro de una *path operation function* normal `def`, puedes acceder al `UploadFile.file` directamente, por ejemplo: ```Python contents = myfile.file.read() ```
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 7.6K bytes - Viewed (0) -
cmd/site-replication-metrics_gen.go
} case "ReplicaCount": z.ReplicaCount, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "ReplicaCount") return } case "Queued": err = z.Queued.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Queued") return } case "Proxied": err = z.Proxied.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Proxied") return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 40.6K bytes - Viewed (0) -
cmd/bucket-replication.go
EventName: eventName, BucketName: bucket, Object: objInfo, UserAgent: "Internal: [Replication]", Host: globalLocalNodeName, }) // re-queue failures once more - keep a retry count to avoid flooding the queue if // the target site is down. Leave it to scanner to catch up instead. if rinfos.ReplicationStatus() != replication.Completed { ri.OpType = replication.HealReplicationType
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
cmd/mrf.go
// but not written in all disks (having quorum) type PartialOperation struct { Bucket string Object string VersionID string Versions []byte SetIndex, PoolIndex int Queued time.Time BitrotScan bool } // mrfState sncapsulates all the information // related to the global background MRF. type mrfState struct { opCh chan PartialOperation closed int32
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 6.5K bytes - Viewed (0)