- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 110 for Response (0.16 sec)
-
cmd/api-response.go
w.WriteHeader(statusCode) if response != nil { w.Write(response) } } // mimeType represents various MIME type used API responses. type mimeType string const ( // Means no response type. mimeNone mimeType = "" // Means response type is JSON. mimeJSON mimeType = "application/json" // Means response type is XML.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
istioctl/pkg/multixds/gather.go
return nil, err } responses = append(responses, resp) return responses, nil } return responses, nil } func mergeShards(responses map[string]*discovery.DiscoveryResponse) (*discovery.DiscoveryResponse, error) { retval := discovery.DiscoveryResponse{} if len(responses) == 0 { return &retval, nil } for _, response := range responses {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
internal/grid/handlers.go
// when it has been returned on a handler. // This will disable automatic response recycling/pooling. // Typically this is used when the response sharing part of its data structure. func (h *SingleHandler[Req, Resp]) WithSharedResponse() *SingleHandler[Req, Resp] { h.sharedResp = true return h } // NewResponse creates a new response.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/server_test.go
// execute the http request to fetch object. response, err = s.client.Do(request) c.Assert(err, nil) // assert the http response status code. c.Assert(response.StatusCode, http.StatusOK) var buffer bytes.Buffer // extract the body of the response. responseBody, err := io.ReadAll(response.Body) c.Assert(err, nil) // assert the http response body content.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
internal/grid/connection.go
if handler == nil { return nil, ErrUnknownHandler } var requests chan []byte var responses chan Response if handler.InCapacity > 0 { requests = make(chan []byte, handler.InCapacity) } if handler.OutCapacity > 0 { responses = make(chan Response, handler.OutCapacity) } else { responses = make(chan Response, 1) } cl, err := c.newMuxClient(ctx) if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/grid/muxclient.go
} m.addResponse(Response{Err: ErrIncorrectSequence}) return false } m.RecvSeq++ return true } // response will send handleIncoming response to client. // may never block. // Should return whether the next call would block. func (m *muxClient) response(seq uint32, r Response) { if debugReqs { fmt.Println(m.MuxID, m.parent.String(), "RESP") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/object-api-datatypes.go
type ListObjectVersionsInfo struct { // Indicates whether the returned list objects response is truncated. A // value of true indicates that the list was truncated. The list can be truncated // if the number of objects exceeds the limit allowed or specified // by max keys. IsTruncated bool // When response is truncated (the IsTruncated element value in the response is true), // you can use the key name in this field as marker in the subsequent
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
cmd/test-utils_test.go
// HEAD HTTP Request doesn't contain body in its response, // for other type of HTTP requests compare the response body content with the expected one. if req.Method != http.MethodHead { // read the response body. actualContent, err := io.ReadAll(rec.Body) if err != nil { t.Fatalf("MinIO %s: Failed parsing response body: <ERROR> %v", instanceType, err) } actualError := &APIErrorResponse{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K 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) -
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)