- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 150 for resps (0.13 sec)
-
pkg/proxy/healthcheck/healthcheck_test.go
req, err := http.NewRequest("GET", "/healthz", nil) if err != nil { t.Fatal(err) } resp := httptest.NewRecorder() handler.ServeHTTP(resp, req) if resp.Code != status { t.Errorf("expected status code %v, got %v", status, resp.Code) } var payload hcPayload if err := json.Unmarshal(resp.Body.Bytes(), &payload); err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
src/net/http/response_test.go
func TestReadResponse(t *testing.T) { for i, tt := range respTests { resp, err := ReadResponse(bufio.NewReader(strings.NewReader(tt.Raw)), tt.Resp.Request) if err != nil { t.Errorf("#%d: %v", i, err) continue } rbody := resp.Body resp.Body = nil diff(t, fmt.Sprintf("#%d Response", i), resp, &tt.Resp) var bout strings.Builder if rbody != nil { _, err = io.Copy(&bout, rbody)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 19:01:29 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/pod_devices.go
for _, devices := range resources { resp := devices.allocResp // Each Allocate response has the following artifacts. // Environment variables // Mount points // Device files // Container annotations // CDI device IDs // These artifacts are per resource per container. // Updates RunContainerOptions.Envs. for k, v := range resp.Envs { if e, ok := envsMap[k]; ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 16.7K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice_test.go
return cmb.GetPrivateKey().GetInlineBytes() } func (s *TestServer) Verify(resp *discovery.DiscoveryResponse, expectations ...Expectation) *discovery.DiscoveryResponse { s.t.Helper() if len(resp.Resources) != len(expectations) { s.t.Fatalf("expected %d resources, got %d", len(expectations), len(resp.Resources)) } got := xdstest.ExtractTLSSecrets(s.t, resp.Resources) for _, e := range expectations { scrt := got[e.ResourceName]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 17 20:12:58 UTC 2024 - 11.6K bytes - Viewed (0) -
src/net/rpc/server.go
server.respLock.Lock() resp := server.freeResp if resp == nil { resp = new(Response) } else { server.freeResp = resp.next *resp = Response{} } server.respLock.Unlock() return resp } func (server *Server) freeResponse(resp *Response) { server.respLock.Lock() resp.next = server.freeResp server.freeResp = resp server.respLock.Unlock() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/driver/fetch.go
Timeout: timeout + 5*time.Second, } resp, err := client.Get(source) if err != nil { return nil, fmt.Errorf("http fetch: %v", err) } if resp.StatusCode != http.StatusOK { defer resp.Body.Close() return nil, statusCodeError(resp) } return resp.Body, nil } func statusCodeError(resp *http.Response) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 19K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/instrumented_services.go
defer recordOperation(operation, time.Now()) resp, err := in.service.Exec(ctx, req) recordError(operation, err) return resp, err } func (in instrumentedRuntimeService) Attach(ctx context.Context, req *runtimeapi.AttachRequest) (*runtimeapi.AttachResponse, error) { const operation = "attach" defer recordOperation(operation, time.Now()) resp, err := in.service.Attach(ctx, req) recordError(operation, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 13.1K bytes - Viewed (0) -
cmd/update.go
StatusCode: http.StatusInternalServerError, } } if resp == nil { return content, AdminError{ Code: AdminUpdateUnexpectedFailure, Message: fmt.Sprintf("No response from server to download URL %s", u), StatusCode: http.StatusInternalServerError, } } defer xhttp.DrainBody(resp.Body) if resp.StatusCode != http.StatusOK { return content, AdminError{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 18.7K bytes - Viewed (0) -
pkg/volume/csi/csi_client_test.go
nodeID string, maxVolumePerNode int64, accessibleTopology map[string]string, err error) { resp, err := c.nodeClient.NodeGetInfo(ctx, &csipbv1.NodeGetInfoRequest{}) topology := resp.GetAccessibleTopology() if topology != nil { accessibleTopology = topology.Segments } return resp.GetNodeId(), resp.GetMaxVolumesPerNode(), accessibleTopology, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.9K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver.go
if err != nil { return nil, err } resp, err := client.Do(req) if err != nil { return nil, err } defer resp.Body.Close() body, err := io.ReadAll(resp.Body) if err != nil { return nil, err } if resp.StatusCode < 200 || resp.StatusCode >= 300 { message := strconv.Quote(string(body)) if len(message) > 100 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 20.3K bytes - Viewed (0)