- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 103 for responses (0.25 sec)
-
istioctl/pkg/proxystatus/proxystatus_test.go
_, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer, Resp: &http.Response{ StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: cmdtesting.ObjBody(codec, cmdtesting.NewInternalType("", "", "foo")), }, } return tf }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 08:28:50 UTC 2024 - 5.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) -
pilot/pkg/xds/xdsgen.go
} return g } // Push an XDS resource for the given connection. Configuration will be generated // based on the passed in generator. Based on the updates field, generators may // choose to send partial or even no response if there are no changes. func (s *DiscoveryServer) pushXds(con *Connection, w *model.WatchedResource, req *model.PushRequest) error { if w == nil { return nil } gen := s.findGenerator(w.TypeUrl, con)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/config/validation/validation.go
return fmt.Errorf(`invalid header %q: header cannot have ":" prefix`, name) } return nil } // ValidateHTTPHeaderOperationName validates a header name when used to remove from request or modify response. func ValidateHTTPHeaderOperationName(name string) error { if name == "" { return fmt.Errorf("header name cannot be empty") } if strings.EqualFold(name, "host") {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
pkg/workloadapi/workload.pb.go
// The hostname for the workload to be resolved by the ztunnel. // DNS queries are sent on-demand by default. // If the resolved DNS query has several endpoints, the request will be forwarded // to the first response. // // At a minimum, each workload must have either an address or hostname. For example, // a workload that backs a Kubernetes service will typically have only endpoints. A
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 65.9K 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/pkg/serviceregistry/kube/controller/controller_test.go
assert.EventuallyEqual(t, func() int { ep := GetEndpointsForPort(svc, ctl.Endpoints, 80) return len(ep) }, 2) ep := GetEndpointsForPort(svc, ctl.Endpoints, 80) if len(ep) != 2 { t.Fatalf("Invalid response for GetEndpoints %v", ep) } if ep[0].Address == "10.10.1.1" && ep[0].Network != "network1" { t.Fatalf("Endpoint with IP 10.10.1.1 is expected to be in network1 but get: %s", ep[0].Network) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pkg/xds/server_test.go
ResourceNames: []string{}, }, response: false, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { if response, _ := ShouldRespond(tt.proxy, "test", tt.request); response != tt.response { t.Fatalf("Unexpected value for response, expected %v, got %v", tt.response, response) } if tt.name != "reconnect" && tt.response {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 4.8K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient.go
if err != nil { return err } var response *http.Response response, err = cniClient.client.Post(cniClient.url, "application/json", bytes.NewBuffer(eventData)) if err != nil { return err } defer response.Body.Close() if response.StatusCode != http.StatusOK { return fmt.Errorf("unable to push CNI event, error was %d", response.StatusCode) } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 2.4K bytes - Viewed (0)