- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 150 for resps (0.06 sec)
-
cmd/kubeadm/app/util/etcd/etcd.go
resp, err = cli.MemberAddAsLearner(ctx, []string{peerAddrs}) if err != nil { lastError = err return false, nil } learnerID = resp.Member.ID } respMembers = resp.Members return true, nil } resp, err = cli.MemberAdd(ctx, []string{peerAddrs}) if err == nil { respMembers = resp.Members return true, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 21.2K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/helper_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 09:47:52 UTC 2023 - 25.2K bytes - Viewed (0) -
internal/rest/client.go
// For errors we make sure to dump response body as well. if resp.StatusCode != http.StatusOK && resp.StatusCode != http.StatusPartialContent && resp.StatusCode != http.StatusNoContent { respTrace, err = httputil.DumpResponse(resp, true) if err != nil { return } } else { respTrace, err = httputil.DumpResponse(resp, false) if err != nil { return } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0) -
src/net/http/response.go
} if resp.ProtoMajor, resp.ProtoMinor, ok = ParseHTTPVersion(resp.Proto); !ok { return nil, badStringError("malformed HTTP version", resp.Proto) } // Parse the response headers. mimeHeader, err := tp.ReadMIMEHeader() if err != nil { if err == io.EOF { err = io.ErrUnexpectedEOF } return nil, err } resp.Header = Header(mimeHeader) fixPragmaCacheControl(resp.Header)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0) -
src/net/http/client.go
// here to ensure that it is non-nil. if resp.ContentLength > 0 && req.Method != "HEAD" { return nil, didTimeout, fmt.Errorf("http: RoundTripper implementation (%T) returned a *Response with content length %d but a nil Body", rt, resp.ContentLength) } resp.Body = io.NopCloser(strings.NewReader("")) } if !deadline.IsZero() { resp.Body = &cancelTimerBody{ stop: stopTimer,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 06:06:11 UTC 2024 - 33.7K bytes - Viewed (0) -
src/internal/fuzz/worker.go
dur, cov, errMsg := fuzzOnce(entry) if errMsg != "" { resp.Err = errMsg return resp } if cov != nil { resp.CoverageData = cov resp.InterestingDuration = dur return resp } if shouldStop() { return resp } } } } func (ws *workerServer) minimize(ctx context.Context, args minimizeArgs) (resp minimizeResponse) { start := time.Now()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 37.7K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
w.Header()[k[len(trim):]] = v } } } func fwdStatusToAPIError(resp *http.Response) *APIError { if status := resp.Header.Get(xhttp.AmzFwdStatus); status != "" && StatusCode(status) > -1 { apiErr := &APIError{ HTTPStatusCode: StatusCode(status), Description: resp.Header.Get(xhttp.AmzFwdErrorMessage), Code: resp.Header.Get(xhttp.AmzFwdErrorCode), } if apiErr.HTTPStatusCode == http.StatusOK {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10.2K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/symbolizer/symbolizer.go
client := &http.Client{ Transport: tr, } resp, err := client.Post(source, "application/octet-stream", strings.NewReader(post)) if err != nil { return nil, fmt.Errorf("http post %s: %v", source, err) } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return nil, fmt.Errorf("http post %s: %v", source, statusCodeError(resp)) } return io.ReadAll(resp.Body) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator_test.go
// populate cache if resp, ok, err := a.AuthenticateToken(context.Background(), "usertoken1"); err != nil || !ok || resp.User.GetName() != "user1" { t.Errorf("Expected user1") } if resp, ok, err := a.AuthenticateToken(context.Background(), "usertoken2"); err != nil || !ok || resp.User.GetName() != "user2" { t.Errorf("Expected user2") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 20.3K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
) func buildExpect(t *testing.T) func(resp *discovery.DeltaDiscoveryResponse, names ...string) { return func(resp *discovery.DeltaDiscoveryResponse, names ...string) { t.Helper() want := sets.New(names...) have := sets.New[string]() for _, r := range resp.Resources { have.Insert(r.Name) } if len(resp.RemovedResources) > 0 { t.Fatalf("unexpected removals: %v", resp.RemovedResources) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0)