- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 62 for responses (0.29 sec)
-
tests/integration/security/egress_gateway_origination_test.go
}, Check: check.And( check.NoErrorAndStatus(statusCode), check.Each(func(r echoClient.Response) error { if _, f := r.RequestHeaders["Handled-By-Egress-Gateway"]; useGateway && !f { return fmt.Errorf("expected to be handled by gateway. response: %s", r) } return nil })), } } func newTLSGatewayTest(t framework.TestContext) *echotest.T {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 15.4K bytes - Viewed (0) -
tests/integration/security/filebased_tls_origination/egress_gateway_origination_test.go
}, Check: check.And( check.NoError(), check.Status(tc.code), check.Each(func(r echoClient.Response) error { if _, f := r.RequestHeaders["Handled-By-Egress-Gateway"]; tc.gateway && !f { return fmt.Errorf("expected to be handled by gateway. response: %s", r) } return nil })), } internalClient[0].CallOrFail(t, opts) })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 11.9K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
} sdcnum = 0 versionCount := make(map[string]int) for _, response := range pilotResponses { var configVersions []xds.SyncedVersions err = json.Unmarshal(response, &configVersions) if err != nil { respStr := string(response) if strings.Contains(respStr, xds.DistributionTrackingDisabledMessage) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 12:24:17 UTC 2024 - 10.1K bytes - Viewed (0) -
pilot/pkg/model/context.go
node.Lock() defer node.Unlock() node.WatchedResources[typeURL] = &WatchedResource{TypeUrl: typeURL, ResourceNames: names} // For all EDS requests that we have already responded with in the same stream let us // force the response. It is important to respond to those requests for Envoy to finish // warming of those resources(Clusters). // This can happen with the following sequence
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
defaultGateway.Annotations = map[string]string{ControllerVersionAnnotation: fmt.Sprint(ControllerVersion)} gws.Update(defaultGateway) expectReconciled() // We shouldn't write in response to our write. assert.ChannelIsEmpty(t, writes) defaultGateway.Annotations["foo"] = "bar" gws.Update(defaultGateway) expectReconciled()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/kube/inject/webhook_test.go
t.Fatalf("could not decode response body: %v", err) } if gotReview.Response.Allowed != c.wantAllowed { t.Fatalf("AdmissionReview.Response.Allowed is wrong : got %v want %v", gotReview.Response.Allowed, c.wantAllowed) } var gotPatch bytes.Buffer if len(gotReview.Response.Patch) > 0 { if err := json.Compact(&gotPatch, gotReview.Response.Patch); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 39K bytes - Viewed (1) -
operator/cmd/mesh/install.go
// to take effect. ReadinessTimeout time.Duration // SkipConfirmation determines whether the user is prompted for confirmation. // If set to true, the user is not prompted and a Yes response is assumed in all cases. SkipConfirmation bool // Force proceeds even if there are validation errors Force bool // Verify after installation Verify bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 21:52:35 UTC 2024 - 15.4K bytes - Viewed (0) -
tests/integration/security/sds_ingress/util/util.go
return fmt.Errorf("unexpected error: %w", err) } if !exRsp.SkipErrorMessageVerification && !strings.Contains(err.Error(), exRsp.ErrorMessage) { return fmt.Errorf("expected response error message %s but got %w", exRsp.ErrorMessage, err) } return nil } if callType == Mtls { return check.And(check.Status(exRsp.StatusCode), check.MTLSForHTTP()).Check(result, nil) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 05:12:36 UTC 2023 - 20.2K bytes - Viewed (0) -
tests/integration/security/sds_ingress/ingress_test.go
// (2) Rotates key/cert by deleting the secret generated in (1) and // replacing it a new secret with a different server key/cert. // (3) verify that client using older CA cert gets a 404 response // (4) verify that client using the newer CA cert is able to establish TLS connection // to deliver the HTTPS request. func TestSingleTlsGateway_SecretRotation(t *testing.T) { framework. NewTest(t).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 32.7K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go
} if !le.tryAcquireOrRenew(context.Background()) { t.Errorf("unexpected result of tryAcquireOrRenew: [succeeded=%v]", true) } le.maybeReportTransition() // Wait for a response to the leader transition, and add 1 so that we can track the final transition. wg.Wait() wg.Add(1) if test.expectSuccess != le.release() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 23 16:39:43 UTC 2023 - 42.5K bytes - Viewed (0)