Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewErrorResponder (0.23 sec)

  1. pkg/registry/core/node/rest/proxy.go

    	handler := proxy.NewUpgradeAwareHandler(location, transport, wrapTransport, upgradeRequired, proxy.NewErrorResponder(responder))
    	handler.MaxBytesPerSec = capabilities.Get().PerConnectionBandwidthLimitBytesPerSec
    	return handler
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 19 13:59:13 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  2. pkg/registry/core/service/proxy.go

    	handler := proxy.NewUpgradeAwareHandler(location, transport, wrapTransport, upgradeRequired, proxy.NewErrorResponder(responder))
    	handler.MaxBytesPerSec = capabilities.Get().PerConnectionBandwidthLimitBytesPerSec
    	return handler
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 19 13:59:13 UTC 2022
    - 2.9K bytes
    - Viewed (0)
  3. pkg/registry/core/pod/rest/subresources.go

    	handler := proxy.NewUpgradeAwareHandler(location, transport, wrapTransport, upgradeRequired, proxy.NewErrorResponder(responder))
    	handler.MaxBytesPerSec = capabilities.Get().PerConnectionBandwidthLimitBytesPerSec
    	return handler
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:10:30 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go

    	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)
    	tunnelingServer := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
    		tunnelingHandler.ServeHTTP(w, req)
    	}))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 02:21:50 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go

    // SimpleErrorResponder is the legacy implementation of ErrorResponder for callers that only
    // service a single request/response per proxy.
    type SimpleErrorResponder interface {
    	Error(err error)
    }
    
    func NewErrorResponder(r SimpleErrorResponder) ErrorResponder {
    	return simpleResponder{r}
    }
    
    type simpleResponder struct {
    	responder SimpleErrorResponder
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:10:30 UTC 2024
    - 19.6K bytes
    - Viewed (0)
Back to top