Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 393 for queues (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top