Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for CancelRequest (0.23 sec)

  1. staging/src/k8s.io/cli-runtime/pkg/genericclioptions/command_headers.go

    		c.Headers[kubectlCommandHeader] = strings.Join(cmdStrs, " ")
    	}
    }
    
    // CancelRequest is propagated to the Delegate RoundTripper within
    // if the wrapped RoundTripper implements this function.
    func (c *CommandHeaderRoundTripper) CancelRequest(req *http.Request) {
    	type canceler interface {
    		CancelRequest(*http.Request)
    	}
    	// If possible, call "CancelRequest" on the wrapped Delegate RoundTripper.
    	if cr, ok := c.Delegate.(canceler); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/cli-runtime/pkg/genericclioptions/command_headers_test.go

    		currCmd = cmd
    	}
    	return currCmd
    }
    
    // Tests that the CancelRequest function is propogated to the wrapped Delegate
    // RoundTripper; but only if the Delegate implements the CancelRequest function.
    func TestCancelRequest(t *testing.T) {
    	tests := map[string]struct {
    		delegate  http.RoundTripper
    		cancelled bool
    	}{
    		"CancelRequest propagated to delegate": {
    			delegate:  &cancellableRoundTripper{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 20 20:34:02 UTC 2021
    - 4.6K bytes
    - Viewed (0)
Back to top