- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 62 for responses (1.42 sec)
-
pkg/test/echo/proto/echo.pb.go
ServerName string `protobuf:"bytes,20,opt,name=serverName,proto3" json:"serverName,omitempty"` // Expected response determines what string to look for in the response to validate TCP requests succeeded. // If not set, defaults to "StatusCode=200"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 02:27:10 UTC 2024 - 33.3K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/config.go
timeout time.Duration count int headers http.Header newConnectionPerRequest bool PropagateResponse func(req *http.Request, resp *http.Response) forceDNSLookup bool hostHeader string urlHost string urlPath string method string secure bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 9.8K bytes - Viewed (0) -
tools/istio-iptables/pkg/capture/run.go
f.Run("-p", "udp", "--dport", "53", "-m", "owner", "--uid-owner", uid, "-j", constants.CT, "--zone", "1") // Packets with src port 15053 from istio to zone 2. These are Istio response packets to application clients f.Run("-p", "udp", "--sport", "15053", "-m", "owner", "--uid-owner", uid, "-j", constants.CT, "--zone", "2") } for _, gid := range split(proxyGID) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 03:53:23 UTC 2024 - 35.4K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
return nil, fmt.Errorf("request not successful %s", resp.Status) } err = json.NewDecoder(resp.Body).Decode(&scopeInfos) if err != nil { return nil, fmt.Errorf("cannot deserialize response %s", err) } return scopeInfos, nil } func (c *ControlzClient) PutScope(scope *ScopeInfo) error { var jsonScopeInfo bytes.Buffer err := json.NewEncoder(&jsonScopeInfo).Encode(scope) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/kube/client.go
if err != nil { return nil, err } if len(res) > 0 { result[istiod.Name] = res } } // If any Discovery servers responded, treat as a success if len(result) > 0 { return result, nil } return nil, nil } func (c *client) EnvoyDo(ctx context.Context, podName, podNamespace, method, path string) ([]byte, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
SubResource: "", RequestKind: nil, RequestResource: nil, RequestSubResource: "", Name: pod.Name, Namespace: deploymentNS, }, Response: nil, } revBytes, err := json.Marshal(rev) if err != nil { return nil, err } resp, err := client.Post(address, "application/json", bytes.NewBuffer(revBytes)) if err != nil { return nil, err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 21.6K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod", "Kubernetes//Pod/default/pod2") // Now create pods in the service... createPod(s, "pod4", "not-sa", "127.0.0.4", "not-node") // Not subscribed, no response ads.ExpectNoResponse() // Now we subscribe to the service explicitly ads.Request(&discovery.DeltaDiscoveryRequest{ ResourceNamesSubscribe: []string{"/10.0.0.1"}, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server_test.go
"istio.io/istio/pkg/test/util/retry" ) type handler struct { // LastALPN stores the most recent ALPN requested. This is needed to determine info about a request, // since the appProber strips all headers/responses. lastAlpn *atomic.String } const ( testHeader = "Some-Header" testHeaderValue = "some-value" testHostValue = "test.com:9999" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/kube/adapter.go
Request *AdmissionRequest `json:"request,omitempty"` // Response describes the attributes for the admission response. Response *AdmissionResponse `json:"response,omitempty"` } // AdmissionRequest describes the admission.Attributes for the admission request. type AdmissionRequest struct { // UID is an identifier for the individual request/response. It allows us to distinguish instances of requests which are
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 10 16:40:00 UTC 2023 - 13.2K bytes - Viewed (0) -
security/pkg/server/ca/server_test.go
} response, err := server.CreateCertificate(ctx, request) s, _ := status.FromError(err) code := s.Code() if code != c.code { t.Errorf("Case %s: expecting code to be (%d) but got (%d): %s", id, c.code, code, s.Message()) } else if c.code == codes.OK { if len(response.CertChain) != len(mockCertChain) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 15.8K bytes - Viewed (0)