Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for roundTripperFor (0.17 sec)

  1. pkg/kube/spdy.go

    	"crypto/tls"
    	"fmt"
    	"net/http"
    
    	spdyStream "k8s.io/apimachinery/pkg/util/httpstream/spdy"
    	"k8s.io/client-go/rest"
    	"k8s.io/client-go/transport/spdy"
    )
    
    // roundTripperFor creates a SPDY upgrader that will work over custom transports.
    func roundTripperFor(restConfig *rest.Config) (http.RoundTripper, spdy.Upgrader, error) {
    	// Get the TLS config.
    	tlsConfig, err := rest.TLSConfigFor(restConfig)
    	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. pkg/client/tests/portfoward_test.go

    		t.Run(testName, func(t *testing.T) {
    			server := httptest.NewServer(fakePortForwardServer(t, testName, test.serverSends, test.clientSends))
    			defer server.Close()
    
    			transport, upgrader, err := spdy.RoundTripperFor(&restclient.Config{})
    			if err != nil {
    				t.Fatal(err)
    			}
    			url, _ := url.Parse(server.URL)
    			dialer := spdy.NewDialer(upgrader, &http.Client{Transport: transport}, "POST", url)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 05 06:08:18 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  3. pkg/kube/portforwarder.go

    	if err != nil {
    		return nil, err
    	}
    
    	req := restClient.Post().Resource("pods").Namespace(f.ns).Name(f.podName).SubResource("portforward")
    	serverURL := req.URL()
    
    	roundTripper, upgrader, err := roundTripperFor(f.restConfig)
    	if err != nil {
    		return nil, fmt.Errorf("failure creating roundtripper: %v", err)
    	}
    
    	dialer := spdy.NewDialer(upgrader, &http.Client{Transport: roundTripper}, http.MethodPost, serverURL)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 14 02:12:37 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  4. pkg/client/tests/remotecommand_test.go

    					req.Param(api.ExecStderrParam, "1")
    					streamErr = localErr
    				}
    
    				conf := &restclient.Config{
    					Host: server.URL,
    				}
    				transport, upgradeTransport, err := spdy.RoundTripperFor(conf)
    				if err != nil {
    					t.Fatalf("%s: unexpected error: %v", name, err)
    				}
    				e, err := remoteclient.NewSPDYExecutorForProtocols(transport, upgradeTransport, "POST", req.URL(), testCase.ClientProtocols...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 05 06:08:18 UTC 2023
    - 10.2K bytes
    - Viewed (0)
  5. pkg/kube/client.go

    			Container: container,
    			Command:   commands,
    			Stdin:     false,
    			Stdout:    true,
    			Stderr:    true,
    			TTY:       false,
    		}, kubescheme.ParameterCodec)
    
    	wrapper, upgrader, err := roundTripperFor(c.config)
    	if err != nil {
    		return "", "", err
    	}
    	exec, err := remotecommand.NewSPDYExecutorForTransports(wrapper, upgrader, "POST", req.URL())
    	if err != nil {
    		return "", "", err
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 14:44:17 UTC 2024
    - 39K bytes
    - Viewed (0)
Back to top