Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewRequest (0.2 sec)

  1. internal/grid/handlers.go

    func (h *SingleHandler[Req, Resp]) NewResponse() Resp {
    	return h.newResp()
    }
    
    // NewRequest creates a new request.
    // Handlers can use this to create a reusable request.
    // The request may be reused, so caller should clear any fields.
    func (h *SingleHandler[Req, Resp]) NewRequest() Req {
    	return h.newReq()
    }
    
    // Register a handler for a Req -> Resp roundtrip.
    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)
  2. internal/rest/client.go

    func removeEmptyPort(host string) string {
    	if hasPort(host) {
    		return strings.TrimSuffix(host, ":")
    	}
    	return host
    }
    
    // Copied from http.NewRequest but implemented to ensure we reuse `url.URL` instance.
    func (c *Client) newRequest(ctx context.Context, u url.URL, body io.Reader) (*http.Request, error) {
    	rc, ok := body.(io.ReadCloser)
    	if !ok && body != nil {
    		rc = io.NopCloser(body)
    	}
    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)
  3. cmd/update.go

    	}
    	uaAppend(")", "")
    
    	return strings.Join(userAgentParts, "")
    }
    
    func downloadReleaseURL(u *url.URL, timeout time.Duration, mode string) (content string, err error) {
    	req, err := http.NewRequest(http.MethodGet, u.String(), nil)
    	if err != nil {
    		return content, AdminError{
    			Code:       AdminUpdateUnexpectedFailure,
    			Message:    err.Error(),
    			StatusCode: http.StatusInternalServerError,
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  4. istioctl/pkg/admin/istiodconfig.go

    	var jsonScopeInfo bytes.Buffer
    	err := json.NewEncoder(&jsonScopeInfo).Encode(scope)
    	if err != nil {
    		return fmt.Errorf("cannot serialize scope %+v", *scope)
    	}
    	req, err := http.NewRequest(http.MethodPut, c.baseURL.String()+"/"+scope.Name, &jsonScopeInfo)
    	if err != nil {
    		return err
    	}
    	defer req.Body.Close()
    
    	resp, err := c.httpClient.Do(req)
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 13.5K bytes
    - Viewed (0)
  5. cmd/post-policy_test.go

    	}
    	writer.Write([]byte("hello world"))
    	// Close before creating the new request.
    	w.Close()
    
    	// Set the body equal to the created policy.
    	reader := bytes.NewReader(buf.Bytes())
    
    	req, err := http.NewRequest(http.MethodPost, makeTestTargetURL(endPoint, bucketName, "", nil), reader)
    	if err != nil {
    		return nil, err
    	}
    
    	// Set form content-type.
    	req.Header.Set("Content-Type", w.FormDataContentType())
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 29.6K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    func newTestStreamingRequest(method, urlStr string, dataLength, chunkSize int64, body io.ReadSeeker) (*http.Request, error) {
    	if method == "" {
    		method = http.MethodPost
    	}
    
    	req, err := http.NewRequest(method, urlStr, nil)
    	if err != nil {
    		return nil, err
    	}
    
    	if body == nil {
    		// this is added to avoid panic during io.ReadAll(req.Body).
    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)
Back to top