Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 233 for SENT (0.02 sec)

  1. cni/pkg/nodeagent/ztunnelserver_test.go

    	// send ack so the server doesn't wait for us.
    	sendAck(ztunClient)
    
    	// second message should be the snap sent message
    	m, fds = readRequest(t, ztunClient)
    	assert.Equal(t, len(fds), 0)
    
    	sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent
    	if sent == nil {
    		panic("expected snapshot sent")
    	}
    	sendAck(ztunClient)
    	ztunClient.Close()
    	// this will retry for a bit, so shouldn't flake
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/pilot/testdata/multiXdsStatusMultiPilot.txt

    proxy1     cluster1     STALE        SYNCED      SYNCED      NOT SENT     SYNCED       istiod1     1.20
    proxy2     cluster2     STALE        SYNCED      STALE       SYNCED       STALE        istiod2     1.19
    proxy3     cluster3     NOT SENT     ERROR       STALE       NOT SENT     NOT SENT     istiod3     1.20
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Mar 06 03:42:52 UTC 2024
    - 522 bytes
    - Viewed (0)
  3. istioctl/pkg/writer/pilot/testdata/multiXdsStatusSinglePilot.txt

    NAME       CLUSTER      CDS       LDS        EDS        RDS          ECDS         ISTIOD      VERSION
    proxy1     cluster1     STALE     SYNCED     SYNCED     NOT SENT     NOT SENT     istiod1     1.20
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Mar 06 03:42:52 UTC 2024
    - 300 bytes
    - Viewed (0)
  4. fastapi/background.py

            return {"message": "Notification sent in the background"}
        ```
        """
    
        def add_task(
            self,
            func: Annotated[
                Callable[P, Any],
                Doc(
                    """
                    The function to call after the response is sent.
    
                    It can be a regular `def` function or an `async def` function.
                    """
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Apr 02 02:48:51 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  5. okhttp-sse/README.md

    OkHttp Server-Sent Events
    =========================
    
    Experimental support for server-sent events.
    API is not considered stable and may change at any time.
    
    ### Download
    
    ```kotlin
    testImplementation("com.squareup.okhttp3:okhttp-sse:4.12.0")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Dec 17 15:34:10 UTC 2023
    - 245 bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt

        client.webSocket!!.finishReader()
        assertThat(client.closed).isTrue()
        client.listener.assertFailure(
          ProtocolException::class.java,
          "Server-sent frames must not be masked.",
        )
        server.listener.assertClosing(1000, "Hello")
        server.listener.assertExhausted() // Client should not have sent second close.
      }
    
      @Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 01:59:58 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  7. cmd/metrics-v3-cluster-notification.go

    	notificationEventsSentTotalMD       = NewCounterMD(notificationEventsSentTotal, "Total number of events sent to the targets")
    	notificationEventsSkippedTotalMD    = NewCounterMD(notificationEventsSkippedTotal, "Events that were skipped to be sent to the targets due to the in-memory queue being full")
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 24 04:10:35 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/ztunnelserver.go

    			}
    		}()
    	}
    }
    
    // ZDS protocol is very simple, for every message sent, and ack is sent.
    // the ack only has temporal correlation (i.e. it is the first and only ack msg after the message was sent)
    // All this to say, that we want to make sure that message to ztunnel are sent from a single goroutine
    // so we don't mix messages and acks.
    // nolint: unparam
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/WebSocket.kt

     *    either peer may not have been transmitted to the other.
     *
     * Note that the state progression is independent for each peer. Arriving at a gracefully-closed
     * state indicates that a peer has sent all of its outgoing messages and received all of its
     * incoming messages. But it does not guarantee that the other peer will successfully receive all of
     * its incoming messages.
     */
    interface WebSocket {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  10. common-protos/k8s.io/api/admissionregistration/v1beta1/generated.proto

    // Package-wide variables from generator "generated".
    option go_package = "k8s.io/api/admissionregistration/v1beta1";
    
    // MatchCondition represents a condition which must be fulfilled for a request to be sent to a webhook.
    message MatchCondition {
      // Name is an identifier for this match condition, used for strategic merging of MatchConditions,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 22.6K bytes
    - Viewed (0)
Back to top