- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewTranslatingHandler (0.3 sec)
-
pkg/registry/core/pod/rest/subresources.go
} maxBytesPerSec := capabilities.Get().PerConnectionBandwidthLimitBytesPerSec streamtranslator := translator.NewStreamTranslatorHandler(location, transport, maxBytesPerSec, streamOptions) handler = translator.NewTranslatingHandler(handler, streamtranslator, wsstream.IsWebSocketRequestWithStreamCloseProtocol) } return handler, nil } // NewConnectOptions returns the versioned object that represents exec parameters
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/translatinghandler.go
// handles the request. type translatingHandler struct { delegate http.Handler translator http.Handler shouldTranslate func(*http.Request) bool } func NewTranslatingHandler(delegate http.Handler, translator http.Handler, shouldTranslate func(*http.Request) bool) http.Handler { return &translatingHandler{ delegate: delegate, translator: translator,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/translatinghandler_test.go
} if len(test.version) > 0 { req.Header.Add(wsstream.WebSocketProtocolHeader, test.version) } delegate := fakeHandler{} translator := fakeHandler{} translatingHandler := NewTranslatingHandler(&delegate, &translator, wsstream.IsWebSocketRequestWithStreamCloseProtocol) translatingHandler.ServeHTTP(nil, req) if !delegate.served && !translator.served {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 3.6K bytes - Viewed (0)