- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for makeTransport (0.16 sec)
-
pkg/kubelet/client/kubelet_client.go
} // MakeTransport creates a secure RoundTripper for HTTP Transport. func MakeTransport(config *KubeletClientConfig) (http.RoundTripper, error) { return makeTransport(config, false) } // MakeInsecureTransport creates an insecure RoundTripper for HTTP Transport. func MakeInsecureTransport(config *KubeletClientConfig) (http.RoundTripper, error) { return makeTransport(config, true) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 07 01:34:49 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/kubelet/client/kubelet_client_test.go
CertFile: "../../client/testdata/mycertinvalid.cer", KeyFile: "../../client/testdata/mycertinvalid.key", CAFile: "../../client/testdata/myCA.cer", }, } rt, err := MakeTransport(config) if err == nil { t.Errorf("Expected an error") } if rt != nil { t.Error("rt should be nil as we provided invalid cert file") } } func TestMakeTransportValid(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 07 01:34:49 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/scheduler/extender.go
prioritizeVerb string bindVerb string weight int64 client *http.Client nodeCacheCapable bool managedResources sets.Set[string] ignorable bool } func makeTransport(config *schedulerapi.Extender) (http.RoundTripper, error) { var cfg restclient.Config if config.TLSConfig != nil { cfg.TLSClientConfig.Insecure = config.TLSConfig.Insecure
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/rest/streamer_test.go
} func fakeTransport(mime, message string) http.RoundTripper { content := fmt.Sprintf("HTTP/1.1 200 OK\nContent-Type: %s\n\n%s", mime, message) return &testTransport{body: content} } func TestInputStreamContentType(t *testing.T) { location, _ := url.Parse("http://www.example.com") streamer := &LocationStreamer{ Location: location, Transport: fakeTransport("application/json", "hello world"), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 27 08:25:24 UTC 2021 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
spdyLocation, err := url.Parse(spdyServer.URL) if err != nil { t.Fatalf("Unable to parse spdy server URL: %s", spdyServer.URL) } spdyTransport, err := fakeTransport() if err != nil { t.Fatalf("Unexpected error creating transport: %v", err) } streams := Options{Stdin: true, Stdout: true} streamTranslator := NewStreamTranslatorHandler(spdyLocation, spdyTransport, 0, streams)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
pkg/registry/core/pod/strategy_test.go
} }) } } type fakeTransport struct { val string } func (f fakeTransport) RoundTrip(*http.Request) (*http.Response, error) { return nil, nil } var ( fakeSecureRoundTripper = fakeTransport{val: "secure"} fakeInsecureRoundTripper = fakeTransport{val: "insecure"} ) func TestPodIndexFunc(t *testing.T) { tcs := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
// create TunnelingHandler by injecting upgrade handler. Create TunnelingServer. url, err := url.Parse(spdyServer.URL) require.NoError(t, err) transport, err := fakeTransport() require.NoError(t, err) upgradeHandler := proxy.NewUpgradeAwareHandler(url, transport, false, true, proxy.NewErrorResponder(&fakeResponder{})) tunnelingHandler := NewTunnelingHandler(upgradeHandler)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0)