- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 286 for payloadB (0.12 sec)
-
pkg/zdsapi/zds.proto
message Ack { string error = 1; } /* Protocol details: on new connection from ztunnel to CNI, the CNI agent - will send all the existing payloads (that it has in its cache) to the ztunnel using AddWorkload message. - the ztunnel will send an ack for each payload (which the CNI will wait for before sending the next one). - when the CNI finishes sending the content of its current cache, a SnapshotSent message will be sent.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 2.7K bytes - Viewed (0) -
tensorflow/c/tf_status.h
// Record <key, value> as a payload in *s. The previous payload having the // same key (if any) is overwritten. Payload will not be added if the Status // is OK. TF_CAPI_EXPORT void TF_SetPayload(TF_Status* s, const char* key, const char* value); // Iterates over the stored payloads and calls the `visitor(key, value)`
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 12 20:00:09 UTC 2024 - 3.9K bytes - Viewed (0) -
tests/integration/security/https_jwt/https_jwt_test.go
opts.Check = check.And( check.OK(), check.ReachedTargetClusters(t), check.RequestHeaders(map[string]string{ headers.Authorization: "Bearer " + jwt.TokenIssuer1, "X-Test-Payload": payload1, })) }, }, } for _, c := range cases { t.NewSubTest(c.name).Run(func(t framework.TestContext) { echotest.New(t, apps.All.Instances()).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/BaseTestHandler.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
} } /** * Send a connection-level ping to the peer. `ack` indicates this is a reply. The data in * `payload1` and `payload2` opaque binary, and there are no rules on the content. */ @Throws(IOException::class) fun ping( ack: Boolean, payload1: Int, payload2: Int, ) { this.withLock { if (closed) throw IOException("closed") frameHeader( streamId = 0,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
internal const val OPCODE_CONTROL_CLOSE = 0x8 internal const val OPCODE_CONTROL_PING = 0x9 internal const val OPCODE_CONTROL_PONG = 0xa /** * Maximum length of frame payload. Larger payloads, if supported by the frame type, can use the * special values [PAYLOAD_SHORT] or [PAYLOAD_LONG]. */ internal const val PAYLOAD_BYTE_MAX = 125L /** Maximum length of close message in bytes. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
val b1 = source.readByte() and 0xff val isMasked = b1 and B1_FLAG_MASK != 0 if (isMasked == isClient) { // Masked payloads must be read on the server. Unmasked payloads must be read on the client. throw ProtocolException( if (isClient) { "Server-sent frames must not be masked." } else {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.8K bytes - Viewed (0) -
tests/integration/security/remote_jwks/remote_jwks_test.go
opts.Check = check.And( check.OK(), check.ReachedTargetClusters(t), check.RequestHeaders(map[string]string{ headers.Authorization: "Bearer " + jwt.TokenIssuer1, "X-Test-Payload": payload1, })) }, }, { name: "remote-jwks-with-service-entry", policyFile: "./testdata/requestauthn-with-se-timeout.yaml.tmpl", timeout: "10ms", delay: "30ms",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.1K bytes - Viewed (0) -
src/internal/coverage/defs.go
// <length of pkg 0> // <length of pkg 1> // ... // --string table------ // <uleb128 len> 8 // <data> "somestring" // ... // --package payloads------ // <meta-symbol for pkg 0> // <meta-symbol for pkg 1> // ... // // Each package payload is a stand-alone blob emitted by the compiler, // and does not depend on anything else in the meta-data file. In // particular, each blob has it's own string table. Note that the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 14 12:51:16 UTC 2023 - 11.9K bytes - Viewed (0) -
pkg/serviceaccount/jwt.go
// // Note: go-jose currently does not allow access to unverified JWS payloads. // See https://github.com/square/go-jose/issues/169 func (j *jwtTokenAuthenticator) hasCorrectIssuer(tokenData string) bool { if strings.HasPrefix(strings.TrimSpace(tokenData), "{") { return false } parts := strings.Split(tokenData, ".") if len(parts) != 3 { return false } payload, err := base64.RawURLEncoding.DecodeString(parts[1])
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 22:16:08 UTC 2024 - 10.7K bytes - Viewed (0)