- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 263 for payloadB (0.18 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) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/FileLockPacketPayloadTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 2K bytes - Viewed (0) -
internal/grid/README.md
It includes built in muxing of concurrent requests as well as congestion handling for streams. Requests can be "Single Payload" or "Streamed". Use the MinIO Grid for: * Small, frequent requests with low latency requirements. * Long-running requests with small/medium payloads. Do *not* use the MinIO Grid for: * Large payloads. Only a single connection is ever made between two servers.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
requireSettings = false, object : BaseTestHandler() { override fun ping( ack: Boolean, payload1: Int, payload2: Int, ) { assertThat(ack).isTrue() assertThat(payload1).isEqualTo(expectedPayload1) assertThat(payload2).isEqualTo(expectedPayload2) } }, ) } @Test fun maxLengthDataFrame() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 28.1K 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) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
) { if (length != 8) throw IOException("TYPE_PING length != 8: $length") if (streamId != 0) throw IOException("TYPE_PING streamId != 0") val payload1 = source.readInt() val payload2 = source.readInt() val ack = flags and FLAG_ACK != 0 handler.ping(ack, payload1, payload2) } @Throws(IOException::class) private fun readGoAway( handler: Handler, length: Int, flags: Int,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K 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)