Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 426 for SENT (0.05 sec)

  1. docs/em/docs/tutorial/dependencies/dependencies-with-yield.md

    participant dep as Dep with yield
    participant operation as Path Operation
    participant tasks as Background tasks
    
        Note over client,tasks: Can raise exception for dependency, handled after response is sent
        Note over client,operation: Can raise HTTPException and can change the response
        client ->> dep: Start request
        Note over dep: Run code up to yield
        opt raise
            dep -->> handler: Raise HTTPException
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  2. docs/kms/README.md

    ```
    
    ### Verify auto-encryption
    
    > Note that auto-encryption only affects requests without S3 encryption headers. So, if a S3 client sends
    > e.g. SSE-C headers, MinIO will encrypt the object with the key sent by the client and won't reach out to
    > the configured KMS.
    
    To verify auto-encryption, use the following `mc` command:
    
    ```
    mc cp test.file myminio/bucket/
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/DuplexTest.kt

      }
    
      /**
       * We delay sending the last byte of the request body 1500 ms. The 1000 ms read timeout should
       * only elapse 1000 ms after the request body is sent.
       */
      @Test
      fun headersReadTimeoutDoesNotStartUntilLastRequestBodyByteFire() {
        enableProtocol(Protocol.HTTP_2)
        server.enqueue(
          MockResponse.Builder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  4. tests/test_tutorial/test_schema_extra_example/test_tutorial004_an_py39.py

    @pytest.fixture(name="client")
    def get_client():
        from docs_src.schema_extra_example.tutorial004_an_py39 import app
    
        client = TestClient(app)
        return client
    
    
    # Test required and embedded body parameters with no bodies sent
    @needs_py39
    def test_post_body_example(client: TestClient):
        response = client.put(
            "/items/5",
            json={
                "name": "Foo",
                "description": "A very nice Item",
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Jul 07 17:12:13 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  5. tests/test_tutorial/test_schema_extra_example/test_tutorial004_py310.py

    @pytest.fixture(name="client")
    def get_client():
        from docs_src.schema_extra_example.tutorial004_py310 import app
    
        client = TestClient(app)
        return client
    
    
    # Test required and embedded body parameters with no bodies sent
    @needs_py310
    def test_post_body_example(client: TestClient):
        response = client.put(
            "/items/5",
            json={
                "name": "Foo",
                "description": "A very nice Item",
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Jul 07 17:12:13 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  6. internal/s3select/json/preader.go

    	readerWg    sync.WaitGroup  // used to keep track of async reader.
    }
    
    // queueItem is an item in the queue.
    type queueItem struct {
    	input []byte             // raw input sent to the worker
    	dst   chan []jstream.KVS // result of block decode
    	err   error              // any error encountered will be set here
    }
    
    // Read - reads single record.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  7. tests/test_tutorial/test_schema_extra_example/test_tutorial004.py

    from dirty_equals import IsDict
    from fastapi.testclient import TestClient
    
    from docs_src.schema_extra_example.tutorial004 import app
    
    client = TestClient(app)
    
    
    # Test required and embedded body parameters with no bodies sent
    def test_post_body_example():
        response = client.put(
            "/items/5",
            json={
                "name": "Foo",
                "description": "A very nice Item",
                "price": 35.4,
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Jul 07 17:12:13 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  8. cmd/metrics-v3-logger-webhook.go

    		allWebhookLabels...)
    	webhookQueueLengthMD = NewGaugeMD(webhookQueueLength,
    		"Webhook queue length",
    		allWebhookLabels...)
    	webhookTotalMessagesMD = NewCounterMD(webhookTotalMessages,
    		"Total number of messages sent to this target",
    		allWebhookLabels...)
    )
    
    // loadLoggerWebhookMetrics - `MetricsLoaderFn` for logger webhook
    // such as failed messages and total messages.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 14 07:27:33 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. internal/event/target/mqtt.go

    	if err != nil {
    		return err
    	}
    
    	eventData, err := target.store.Get(key)
    	if err != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(err) {
    			return nil
    		}
    		return err
    	}
    
    	if err = target.send(eventData); err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

        internal set
    
      /** Received headers yet to be [taken][takeHeaders]. */
      private val headersQueue = ArrayDeque<Headers>()
    
      /** True if response headers have been sent or received. */
      private var hasResponseHeaders: Boolean = false
    
      internal val source =
        FramingSource(
          maxByteCount = connection.okHttpSettings.initialWindowSize.toLong(),
          finished = inFinished,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
Back to top