- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 171 for resps (0.57 sec)
-
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
assert.True(t, hic.initialized, "successfully parsed http response headers") assert.Equal(t, expectedResponseHeaders, testConnConstructor.resp.Header) assert.Equal(t, "101 Switching Protocols", testConnConstructor.resp.Status) assert.Equal(t, "portforward.k8s.io", testConnConstructor.resp.Header.Get("X-App-Protocol"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/goaway_test.go
} resp, err := client.Do(req) if err != nil { return nil, fmt.Errorf("failed request test server, err: %v", err) } if resp.StatusCode != http.StatusOK { defer resp.Body.Close() body, err := ioutil.ReadAll(resp.Body) if err != nil { return nil, fmt.Errorf("failed to read response body and status code is %d, error: %v", resp.StatusCode, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 12:58:54 UTC 2021 - 13.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config_test.go
// healthz checks are installed in PrepareRun resp, err := http.Get(server.URL + "/healthz?exclude=wrapping-health&exclude=delegate-health") if err != nil { t.Fatal(err) } data, _ := io.ReadAll(resp.Body) if http.StatusOK != resp.StatusCode { t.Logf("got %d", resp.StatusCode) t.Log(string(data)) return false, nil } return true, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 13.1K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
func (c *ControlzClient) GetScopes() ([]*ScopeInfo, error) { var scopeInfos []*ScopeInfo resp, err := c.httpClient.Get(c.baseURL.String()) if err != nil { return nil, err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return nil, fmt.Errorf("request not successful %s", resp.Status) } err = json.NewDecoder(resp.Body).Decode(&scopeInfos) 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) -
pilot/cmd/pilot-agent/status/server_test.go
if err != nil { t.Fatalf("[%v] failed to create request", pprofPath) } resp, err := client.Do(req) if err != nil { t.Fatal("request failed: ", err) } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { t.Errorf("[%v] unexpected status code, want = %v, got = %v", pprofPath, http.StatusOK, resp.StatusCode) } } func TestStats(t *testing.T) { cases := []struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go
// healthz checks are installed in PrepareRun resp, err = http.Get(server.URL + "/healthz") assert.NoError(err) data, _ := io.ReadAll(resp.Body) if http.StatusOK != resp.StatusCode { t.Logf("got %d", resp.StatusCode) t.Log(string(data)) return false, nil } return true, nil })) resp, err = http.Get(server.URL + "/healthz/ping") assert.NoError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 23.2K bytes - Viewed (0) -
internal/kms/kms.go
return DEK{ KeyID: name, Version: resp.Version, Plaintext: resp.Plaintext, Ciphertext: resp.Ciphertext, }, nil } func (c *kmsConn) Decrypt(ctx context.Context, req *DecryptRequest) ([]byte, error) { aad, err := req.AssociatedData.MarshalText() if err != nil { return nil, err } ciphertext, _ := parseCiphertext(req.Ciphertext) resp, err := c.client.Decrypt(ctx, &kms.DecryptRequest{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/controlplane/instance_test.go
defer etcdserver.Terminate(t) req, _ := http.NewRequest("GET", "/version", nil) resp := httptest.NewRecorder() s.ControlPlane.GenericAPIServer.Handler.ServeHTTP(resp, req) if resp.Code != 200 { t.Fatalf("expected http 200, got: %d", resp.Code) } var info version.Info err := json.NewDecoder(resp.Body).Decode(&info) if err != nil { t.Errorf("unexpected error: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.5K bytes - Viewed (0) -
cmd/storage-rest-client.go
}) if err != nil { return cache, toStorageErr(err) } var final *dataUsageCache err = st.Results(func(resp *nsScannerResp) error { if resp.Update != nil { select { case <-ctx.Done(): case updates <- *resp.Update: } } if resp.Final != nil { final = resp.Final } // We can't reuse the response since it is sent upstream. return nil }) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.4K bytes - Viewed (0) -
pkg/client/tests/remotecommand_test.go
req *http.Request resp *http.Response conn httpstream.Connection err, connErr error checkResponse bool called bool t *testing.T } func (u *fakeUpgrader) RoundTrip(req *http.Request) (*http.Response, error) { u.called = true u.req = req return u.resp, u.err } func (u *fakeUpgrader) NewConnection(resp *http.Response) (httpstream.Connection, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 06:08:18 UTC 2023 - 10.2K bytes - Viewed (0)