- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,558 for RequestId (0.16 sec)
-
pkg/config/mesh/mesh_test.go
base: ` proxyHeaders: requestId: disabled: true`, overlay: ` proxyHeaders: requestId: disabled: false`, result: ` proxyHeaders: requestId: disabled: false`, }, { name: "enabled then disabled", base: ` proxyHeaders: requestId: disabled: false`, overlay: ` proxyHeaders: requestId: disabled: true`, result: `
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 11.7K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/udp.go
} func (c *udpProtocol) makeRequest(ctx context.Context, cfg *Config, requestID int) (string, error) { conn, err := newUDPConnection(cfg) if err != nil { return "", err } defer func() { _ = conn.Close() }() msgBuilder := strings.Builder{} echo.ForwarderURLField.WriteForRequest(&msgBuilder, requestID, cfg.Request.Url) if cfg.Request.Message != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 17:19:22 UTC 2022 - 3.4K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/tcp.go
return msgBuilder.String(), err } } echo.ForwarderURLField.WriteForRequest(&msgBuilder, requestID, cfg.Request.Url) if cfg.Request.Message != "" { echo.ForwarderMessageField.WriteForRequest(&msgBuilder, requestID, cfg.Request.Message) } // Apply per-request timeout to calculate deadline for reads/writes. ctx, cancel := context.WithTimeout(ctx, cfg.timeout)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 19:13:32 UTC 2023 - 4.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ResponseProducer.java
interface ResponseProducer { default boolean isFailure() { return false; } /** * Called to handle a request. Is *not* called under lock. */ void writeTo(int requestId, HttpExchange exchange) throws IOException; /** * Returns the failure, if any. */ default RuntimeException getFailure() { throw new IllegalStateException(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.1K bytes - Viewed (0) -
internal/logger/reqinfo.go
sync.RWMutex } // NewReqInfo : func NewReqInfo(remoteHost, userAgent, deploymentID, requestID, api, bucket, object string) *ReqInfo { return &ReqInfo{ RemoteHost: remoteHost, UserAgent: userAgent, API: api, DeploymentID: deploymentID, RequestID: requestID, BucketName: bucket, ObjectName: object, } } // AppendTags - appends key/val to ReqInfo.tags
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 4.4K bytes - Viewed (0) -
docs/sts/custom-token-identity.md
</Credentials> <AssumedUser>custom:Alice</AssumedUser> </AssumeRoleWithCustomTokenResult> <ResponseMetadata> <RequestId>16F26E081E36DE63</RequestId> </ResponseMetadata> </AssumeRoleWithCustomTokenResponse>
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 27 00:58:09 UTC 2022 - 3K bytes - Viewed (0) -
src/net/http/fcgi/fcgi_test.go
[]byte(nameData), []byte(valueData), }, nil, ) } func makeRecord( recordType recType, requestId uint16, contentData []byte, ) []byte { requestIdB1 := byte(requestId >> 8) requestIdB0 := byte(requestId) contentLength := len(contentData) contentLengthB1 := byte(contentLength >> 8) contentLengthB0 := byte(contentLength) return bytes.Join([][]byte{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 18:51:39 UTC 2023 - 10.6K bytes - Viewed (0) -
cmd/sts-errors.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 5.8K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java
this.timeout = timeout; condition = lock.newCondition(); this.precondition = precondition; this.content = content; } @Override public void writeTo(int requestId, HttpExchange exchange) throws IOException { exchange.sendResponseHeaders(200, content.length); exchange.getResponseBody().write(content, 0, 1024); exchange.getResponseBody().flush(); lock.lock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/util.go
const ( hostHeader = "Host" ) var fwLog = log.RegisterScope("forwarder", "echo clientside") func writeForwardedHeaders(out *bytes.Buffer, requestID int, header http.Header) { for key, values := range header { for _, v := range values { echo.ForwarderHeaderField.WriteKeyValueForRequest(out, requestID, key, v) } } } func newDialer(cfg *Config) hbone.Dialer { if cfg.Request.Hbone.GetAddress() != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 4.4K bytes - Viewed (0)