- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 151 for respAdd (0.14 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) -
src/cmd/go/testdata/script/script_wait.txt
# programs, but that should not cause the test to fail if it does not # care about the exit status of those programs. [exec:sleep] ? exec sleep 86400 & # It should also cancel any backgrounded builtins that respond to Context # cancellation.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 24 21:18:10 UTC 2022 - 693 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) -
pkg/registry/core/pod/rest/log.go
// Given that underlying store is shared with REST, // we don't destroy it here explicitly. } // ProducesMIMETypes returns a list of the MIME types the specified HTTP verb (GET, POST, DELETE, // PATCH) can respond with. func (r *LogREST) ProducesMIMETypes(verb string) []string { // Since the default list does not include "plain/text", we need to // explicitly override ProducesMIMETypes, so that it gets added to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 24 10:50:43 UTC 2023 - 4.4K 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)