- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for roundTripperFor (0.23 sec)
-
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) -
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) -
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)