- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 117 for respAdd (0.31 sec)
-
pilot/pkg/networking/core/route/route_test.go
g.Expect(weightedCluster).NotTo(BeNil()) g.Expect(len(weightedCluster.GetClusters())).To(Equal(2)) expectResults := []struct { reqAdd []*envoycore.HeaderValueOption reqRemove []string respAdd []*envoycore.HeaderValueOption respRemove []string authority string }{ { reqAdd: []*envoycore.HeaderValueOption{ { Header: &envoycore.HeaderValue{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 88.1K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route.go
requestHeadersToAdd = append(requestHeadersToAdd, reqAdd...) responseHeadersToAdd, _ := translateAppendHeaders(resp.GetSet(), false) respAdd, _ := translateAppendHeaders(resp.GetAdd(), true) responseHeadersToAdd = append(responseHeadersToAdd, respAdd...) auth := addAuthority if setAuthority != "" { // If authority is set in 'add' and 'set', pick the one from 'set' auth = setAuthority }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 56.1K bytes - Viewed (0) -
platforms/core-execution/snapshots/src/test/groovy/org/gradle/internal/snapshot/RespondWithPathToParent.groovy
RespondWithPathToParent(String pathToParent) { this.pathToParent = pathToParent } @Override Object respond(IMockInvocation invocation) { if (invocation.getMethod().name == "getPathToParent") { return pathToParent } return EmptyOrDummyResponse.INSTANCE.respond(invocation) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:34:50 UTC 2023 - 1.2K bytes - Viewed (0) -
platforms/core-execution/execution/src/test/groovy/org/gradle/internal/execution/steps/StepSpecBase.groovy
*/ static class GuavaImmutablesResponse implements IDefaultResponse { static final IDefaultResponse INSTANCE = new GuavaImmutablesResponse() @Override Object respond(IMockInvocation invocation) { if (ImmutableCollection.isAssignableFrom(invocation.method.returnType) || ImmutableMap.isAssignableFrom(invocation.method.returnType)) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 22 09:41:33 UTC 2023 - 2.8K bytes - Viewed (0) -
container-tests/src/test/java/okhttp3/containers/BasicMockServerTest.kt
mockServerClient .`when`( request().withPath("/person") .withQueryStringParameter("name", "peter"), ) .respond(response().withBody("Peter the person!")) val response = client.newCall(Request((mockServer.endpoint + "/person?name=peter").toHttpUrl())).execute() assertThat(response.body.string()).contains("Peter the person")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 3.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/HttpBuildCacheServer.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/xds/server.go
// Envoy can send two DiscoveryRequests with same version and nonce. // when it detects a new resource. We should respond if they change. prev := sets.New(previousResources...) cur := sets.New(request.ResourceNames...) removed := prev.Difference(cur) added := cur.Difference(prev) // We should always respond "alwaysRespond" marked requests to let Envoy finish warming // even though Nonce match and it looks like an ACK.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
// with EDS and SDS. // This can happen with the following sequence // 1. Envoy disconnects and reconnects to Istiod. // 2. Envoy sends EDS request and we respond with it. // 3. Envoy sends CDS request and we respond with clusters. // 4. Envoy detects a change in cluster state and tries to warm those clusters but never sends // an EDS request for them.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
platforms/core-execution/build-cache-http/src/integTest/groovy/org/gradle/caching/http/internal/HttpBuildCacheServiceErrorHandlingIntegrationTest.groovy
// then the subsequent is flat refused because we stopped the server. String errorPattern = /(Connect to 127\.0\.0\.1:\d+ \[\/127\.0\.0\.1\] failed: Connection refused|127\.0\.0\.1:\d+ failed to respond|Connection reset)/ when: executer.withStackTraceChecksDisabled() withBuildCache().run "customTask" then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:43:12 UTC 2023 - 7.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Authenticator.kt
* should give up. * * When reactive authentication is requested by an origin web server, the response code is 401 * and the implementation should respond with a new request that sets the "Authorization" header. * * ```java * if (response.request().header("Authorization") != null) { * return null; // Give up, we've already failed to authenticate. * } *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.5K bytes - Viewed (0)