Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewRoundTripper (0.22 sec)

  1. pkg/kube/spdy.go

    	if restConfig.Proxy != nil {
    		upgrader, err = spdyStream.NewRoundTripperWithProxy(tlsConfig, restConfig.Proxy)
    		if err != nil {
    			return nil, nil, err
    		}
    	} else {
    		upgrader, err = spdyStream.NewRoundTripper(tlsConfig)
    		if err != nil {
    			return nil, nil, err
    		}
    	}
    	wrapper, err := rest.HTTPWrappersForConfig(restConfig, upgrader)
    	if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Dec 15 21:30:37 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go

    }
    
    var _ utilnet.TLSClientConfigHolder = &SpdyRoundTripper{}
    var _ httpstream.UpgradeRoundTripper = &SpdyRoundTripper{}
    var _ utilnet.Dialer = &SpdyRoundTripper{}
    
    // NewRoundTripper creates a new SpdyRoundTripper that will use the specified
    // tlsConfig.
    func NewRoundTripper(tlsConfig *tls.Config) (*SpdyRoundTripper, error) {
    	return NewRoundTripperWithConfig(RoundTripperConfig{
    		TLS:              tlsConfig,
    		UpgradeTransport: nil,
    	})
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper_test.go

    				t.Fatalf("error creating request: %s", err)
    			}
    			req, err := http.NewRequest("GET", server.URL, nil)
    			if err != nil {
    				t.Fatalf("error creating request: %s", err)
    			}
    
    			spdyTransport, err := NewRoundTripper(testCase.clientTLS)
    			if err != nil {
    				t.Fatalf("error creating SpdyRoundTripper: %v", err)
    			}
    
    			var proxierCalled bool
    			var proxyCalledWithHost string
    			var proxyCalledWithAuth bool
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 32.7K bytes
    - Viewed (0)
  4. pkg/kubelet/server/server_test.go

    	expectedContainerName := "baz"
    
    	url := fw.testHTTPServer.URL + "/exec/" + podNamespace + "/" + podName + "/" + expectedContainerName + "?c=ls&c=-a&" + api.ExecStdinParam + "=1"
    
    	upgradeRoundTripper, err := spdy.NewRoundTripper(&tls.Config{})
    	if err != nil {
    		t.Fatalf("Error creating SpdyRoundTripper: %v", err)
    	}
    	c := &http.Client{Transport: upgradeRoundTripper}
    
    	resp, err := c.Do(makeReq(t, "POST", url, "v4.channel.k8s.io"))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
Back to top