- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for roundTripperFor (0.22 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/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) -
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/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) -
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)