Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewErrorResponder (0.27 sec)

  1. 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)
  2. 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