- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 152 for payloadB (0.19 sec)
-
internal/grid/handlers.go
NewStream(ctx context.Context, h HandlerID, payload []byte) (st *Stream, err error) } // Call the remove with the request and func (h *StreamTypeHandler[Payload, Req, Resp]) Call(ctx context.Context, c Streamer, payload Payload) (st *TypedStream[Req, Resp], err error) { if c == nil { return nil, ErrDisconnected } var payloadB []byte if h.WithPayload { var err error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
pkg/volume/util/atomic_writer_test.go
for _, payload := range tc.payloads { writer.Write(payload, nil) checkVolumeContents(targetDir, tc.name, payload, t) } } } func checkVolumeContents(targetDir, tcName string, payload map[string]FileProjection, t *testing.T) { dataDirPath := filepath.Join(targetDir, dataDirName) // use filepath.Walk to reconstruct the payload, then deep equal
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 30.5K bytes - Viewed (0) -
tests/integration/security/jwt_test.go
"istio.io/istio/tests/common/jwt" ) // TestRequestAuthentication tests beta authn policy for jwt. func TestRequestAuthentication(t *testing.T) { payload1 := strings.Split(jwt.TokenIssuer1, ".")[1] payload2 := strings.Split(jwt.TokenIssuer2, ".")[1] payload3 := strings.Split(jwt.TokenIssuer1WithNestedClaims2, ".")[1] framework.NewTest(t). Label(label.IPv4). // https://github.com/istio/istio/issues/35835
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 25.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.7K bytes - Viewed (0) -
internal/grid/grid_test.go
errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) { t.Log("1: server payload: ", len(payload), "bytes.") return append([]byte{}, payload...), nil })) // 2: Return as error errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) { t.Log("2: server payload: ", len(payload), "bytes.") err := RemoteErr(payload) return nil, &err }))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
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/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) -
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)