Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for webSocketServerStreams (0.16 sec)

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