Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for SpdyRoundTripper (5.97 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go

    	upgradeTransport http.RoundTripper
    }
    
    var _ utilnet.TLSClientConfigHolder = &SpdyRoundTripper{}
    var _ httpstream.UpgradeRoundTripper = &SpdyRoundTripper{}
    var _ utilnet.Dialer = &SpdyRoundTripper{}
    
    // NewRoundTripper creates a new SpdyRoundTripper that will use the specified
    // tlsConfig.
    func NewRoundTripper(tlsConfig *tls.Config) (*SpdyRoundTripper, error) {
    	return NewRoundTripperWithConfig(RoundTripperConfig{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper_test.go

    			if err != nil {
    				t.Fatalf("error creating request: %s", err)
    			}
    
    			spdyTransport, err := NewRoundTripper(testCase.clientTLS)
    			if err != nil {
    				t.Fatalf("error creating SpdyRoundTripper: %v", err)
    			}
    
    			var proxierCalled bool
    			var proxyCalledWithHost string
    			var proxyCalledWithAuth bool
    			var proxyCalledWithAuthHeader string
    			if testCase.proxyServerFunc != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 32.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator.go

    		return
    	}
    	spdyExecutor, err := remotecommand.NewSPDYExecutorRejectRedirects(spdyRoundTripper, spdyRoundTripper, "POST", h.Location)
    	if err != nil {
    		websocketStreams.writeStatus(apierrors.NewInternalError(err)) //nolint:errcheck
    		metrics.IncStreamTranslatorRequest(req.Context(), strconv.Itoa(http.StatusInternalServerError))
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 27 23:21:55 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. pkg/kube/spdy.go

    		// If using a custom transport, skip server verification on the upgrade.
    		// nolint: gosec
    		tlsConfig = &tls.Config{
    			InsecureSkipVerify: true,
    		}
    	}
    
    	var upgrader *spdyStream.SpdyRoundTripper
    	if restConfig.Proxy != nil {
    		upgrader, err = spdyStream.NewRoundTripperWithProxy(tlsConfig, restConfig.Proxy)
    		if err != nil {
    			return nil, nil, err
    		}
    	} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Dec 15 21:30:37 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  5. pkg/kubelet/server/server_test.go

    	upgradeRoundTripper, err := spdy.NewRoundTripper(&tls.Config{})
    	if err != nil {
    		t.Fatalf("Error creating SpdyRoundTripper: %v", err)
    	}
    	c := &http.Client{Transport: upgradeRoundTripper}
    
    	resp, err := c.Do(makeReq(t, "POST", url, "v4.channel.k8s.io"))
    	if err != nil {
    		t.Fatalf("Got error POSTing: %v", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.7.md

    	* HostAliases is now parsed with hostAliases json keys to be in line with the feature's name. ([#47512](https://github.com/kubernetes/kubernetes/pull/47512), [@rickypai](https://github.com/rickypai))
    
    	* Add redirect support to SpdyRoundTripper ([#44451](https://github.com/kubernetes/kubernetes/pull/44451), [@ncdc](https://github.com/ncdc))
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 308.7K bytes
    - Viewed (0)
Back to top