- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewErrorResponder (0.21 sec)
-
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) -
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) -
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) -
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) -
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)