Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 185 for Chan (0.23 sec)

  1. internal/grid/README.md

    The handler function has this signature.
    
    Sample handler:
    ```go
        handler :=  func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr {
            fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context))
            fmt.Println("Subroute:", GetSubroute(ctx))
            for {
                select {
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

       * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until
       * the already-requested ones are in service, otherwise we might create more threads than we need.
       *
       * We use [executeCallCount] and [runCallCount] to defend against starting more threads than we
       * need. Both fields are guarded by [lock].
       */
      private var executeCallCount = 0
      private var runCallCount = 0
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  3. docs/metrics/prometheus/alerts.md

          description: "MinIO instance {{ $labels.server }} of job {{ $labels.job }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }} for more than 5 minutes."
    ```
    
    ## Verify the configuration and alerts
    To verify the above sample alert follow below steps
    
    1. Start a distributed MinIO instance (4 nodes setup)
    2. Start Prometheus server and AlertManager
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 28 20:53:59 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

     *
     * This class may be used to stream very large responses. For example, it is possible to use this
     * class to read a response that is larger than the entire memory allocated to the current process.
     * It can even stream a response larger than the total storage on the current device, which is a
     * common requirement for video streaming applications.
     *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.7K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/certificates/v1/generated.proto

      //      implementations prior to v1.22)
      //   2. Signer whose configured maximum is shorter than the requested duration
      //   3. Signer whose configured minimum is longer than the requested duration
      //
      // The minimum valid value for expirationSeconds is 600, i.e. 10 minutes.
      //
      // +optional
      optional int32 expirationSeconds = 8;
    
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 11.6K bytes
    - Viewed (0)
  6. docs/en/docs/advanced/custom-response.md

    Import the `Response` class (sub-class) you want to use and declare it in the *path operation decorator*.
    
    For large responses, returning a `Response` directly is much faster than returning a dictionary.
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 11.7K bytes
    - Viewed (0)
  7. docs/en/docs/advanced/security/http-basic-auth.md

    And then they can try again knowing that it's probably something more similar to `stanleyjobsox` than to `johndoe`.
    
    #### A "professional" attack
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Jan 11 14:33:05 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/admission/v1/generated.proto

      optional string name = 5;
    
      // Namespace is the namespace associated with the request (if any).
      // +optional
      optional string namespace = 6;
    
      // Operation is the operation being performed. This may be different than the operation
      // requested. e.g. a patch can result in either a CREATE or UPDATE Operation.
      optional string operation = 7;
    
      // UserInfo is information about the requesting user
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 8.1K bytes
    - Viewed (0)
  9. docs/en/docs/async.md

    And as you can have parallelism and asynchronicity at the same time, you get higher performance than most of the tested NodeJS frameworks and on par with Go, which is a compiled language closer to C <a href="https://www.techempower.com/benchmarks/#section=data-r17&hw=ph&test=query&l=zijmkf-1" class="external-link" target="_blank">(all thanks to Starlette)</a>.
    
    ### Is concurrency better than parallelism?
    
    Nope! That's not the moral of the story.
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 23K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

       * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as
       * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than
       * `streamId`.
       *
       * @param streamId client-initiated stream ID.  Must be an odd number.
       * @param promisedStreamId server-initiated stream ID.  Must be an even number.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 11.3K bytes
    - Viewed (0)
Back to top