Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for roundTripperFor (0.23 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/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)
  3. 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