- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for webSocketServerStreams (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator.go
// Create WebSocket server, including particular streams requested. If this websocket // endpoint is not able to be upgraded, the websocket library will return errors // to the client. websocketStreams, err := webSocketServerStreams(req, w, h.Options) if err != nil { // Client error increments bad request status code. metrics.IncStreamTranslatorRequest(req.Context(), strconv.Itoa(http.StatusBadRequest)) 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) -
staging/src/k8s.io/apiserver/pkg/util/proxy/websocket.go
resizeChan chan remotecommand.TerminalSize tty bool } // Create WebSocket server streams to respond to a WebSocket client. Creates the streams passed // in the stream options. func webSocketServerStreams(req *http.Request, w http.ResponseWriter, opts Options) (*conns, error) { ctx, err := createWebSocketStreams(req, w, opts) if err != nil { return nil, err } if ctx.resizeStream != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 6.2K bytes - Viewed (0)