- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 131 for response (0.15 sec)
-
istioctl/pkg/util/handlers/handlers_test.go
NegotiatedSerializer: ns, Client: fake.CreateHTTPClient(func(req *http.Request) (*http.Response, error) { switch p, m := req.URL.Path, req.Method; { case p == "/namespaces/istio-system/deployments/foo" && m == "GET": body := cmdtesting.ObjBody(codec, attachDeploy("istio-system")) return &http.Response{StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: body}, nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 6.6K bytes - Viewed (0) -
internal/grid/msg.go
OpAckMux // OpRequest is a single request + response. // MuxID is returned in response. OpRequest // OpResponse is a response to a single request. // FlagPayloadIsErr is used to signify that the payload is a string error converted to byte slice. // When a response is received, the mux is already removed from the remote. OpResponse // OpDisconnect instructs that remote wants to disconnect OpDisconnect
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
internal/rest/client.go
if xnet.IsNetworkOrHostDown(err, r.expectTimeouts) { r.errorStatusOnce.Do(func() { atomic.AddUint64(&globalStats.errs, 1) }) } } // dumpHTTP - dump HTTP request and response. func (c *Client) dumpHTTP(req *http.Request, resp *http.Response) { // Starts http dump. _, err := fmt.Fprintln(c.TraceOutput, "---------START-HTTP---------") if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
internal/s3select/select_test.go
w := &testResponseWriter{} s3Select.Evaluate(w) s3Select.Close() if !reflect.DeepEqual(w.response, testCase.expectedResult) { resp := http.Response{ StatusCode: http.StatusOK, Body: io.NopCloser(bytes.NewReader(w.response)), ContentLength: int64(len(w.response)), } res, err := minio.NewSelectResults(&resp, "testbucket") if err != nil { t.Error(err)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 76.2K bytes - Viewed (0) -
istioctl/pkg/util/common.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.6K bytes - Viewed (0) -
internal/dsync/lock-args.go
Quorum int } // ResponseCode is the response code for a locking request. type ResponseCode uint8 // Response codes for a locking request. const ( RespOK ResponseCode = iota RespLockConflict RespLockNotInitialized RespLockNotFound RespErr ) // LockResp is a locking request response. type LockResp struct { Code ResponseCode Err string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K bytes - Viewed (0) -
internal/grid/grid_test.go
} // Start processing requests. close(processHandler) // Drain responses got := 0 for resp := range st.responses { // t.Log("got response", resp) errFatal(resp.Err) if resp.Msg[0] != byte(got) { t.Error("expected response", got, "got", resp.Msg[0]) } got++ } if got != 100 { t.Error("expected 100 responses, got", got) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/http-tracer.go
// If trace is enabled, execute the request if it is traced by other handlers // otherwise, generate a trace event with request information but no response. func httpTracerMiddleware(h http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { // Setup a http request response recorder - this is needed for // http stats requests and audit if enabled. respRecorder := xhttp.NewResponseRecorder(w)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K 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
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
writer io.Writer, istioNamespace string, xdsResponses map[string]*discovery.DiscoveryResponse, ) (map[string]*discovery.DiscoveryResponse, error) { for _, response := range xdsResponses { for _, resource := range response.Resources { eString := string(resource.Value) switch { case strings.Contains(eString, "You must provide a proxyID in the query string"):
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0)