Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for makeTransport (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top