kubernetes/vendor/golang.org/x/net/websocket/hybi.go

const websocketGUID …

const closeStatusNormal …

const closeStatusGoingAway …

const closeStatusProtocolError …

const closeStatusUnsupportedData …

const closeStatusFrameTooLarge …

const closeStatusNoStatusRcvd …

const closeStatusAbnormalClosure …

const closeStatusBadMessageData …

const closeStatusPolicyViolation …

const closeStatusTooBigData …

const closeStatusExtensionMismatch …

const maxControlFramePayloadLength …

var ErrBadMaskingKey …

var ErrBadPongMessage …

var ErrBadClosingStatus …

var ErrUnsupportedExtensions …

var ErrNotImplemented …

var handshakeHeader …

type hybiFrameHeader …

type hybiFrameReader …

func (frame *hybiFrameReader) Read(msg []byte) (n int, err error) { … }

func (frame *hybiFrameReader) PayloadType() byte { … }

func (frame *hybiFrameReader) HeaderReader() io.Reader { … }

func (frame *hybiFrameReader) TrailerReader() io.Reader { … }

func (frame *hybiFrameReader) Len() (n int) { … }

type hybiFrameReaderFactory …

// NewFrameReader reads a frame header from the connection, and creates new reader for the frame.
// See Section 5.2 Base Framing protocol for detail.
// http://tools.ietf.org/html/draft-ietf-hybi-thewebsocketprotocol-17#section-5.2
func (buf hybiFrameReaderFactory) NewFrameReader() (frame frameReader, err error) { … }

type hybiFrameWriter …

func (frame *hybiFrameWriter) Write(msg []byte) (n int, err error) { … }

func (frame *hybiFrameWriter) Close() error { … }

type hybiFrameWriterFactory …

func (buf hybiFrameWriterFactory) NewFrameWriter(payloadType byte) (frame frameWriter, err error) { … }

type hybiFrameHandler …

func (handler *hybiFrameHandler) HandleFrame(frame frameReader) (frameReader, error) { … }

func (handler *hybiFrameHandler) WriteClose(status int) (err error) { … }

func (handler *hybiFrameHandler) WritePong(msg []byte) (n int, err error) { … }

// newHybiConn creates a new WebSocket connection speaking hybi draft protocol.
func newHybiConn(config *Config, buf *bufio.ReadWriter, rwc io.ReadWriteCloser, request *http.Request) *Conn { … }

// generateMaskingKey generates a masking key for a frame.
func generateMaskingKey() (maskingKey []byte, err error) { … }

// generateNonce generates a nonce consisting of a randomly selected 16-byte
// value that has been base64-encoded.
func generateNonce() (nonce []byte) { … }

// removeZone removes IPv6 zone identifier from host.
// E.g., "[fe80::1%en0]:8080" to "[fe80::1]:8080"
func removeZone(host string) string { … }

// getNonceAccept computes the base64-encoded SHA-1 of the concatenation of
// the nonce ("Sec-WebSocket-Key" value) with the websocket GUID string.
func getNonceAccept(nonce []byte) (expected []byte, err error) { … }

// Client handshake described in draft-ietf-hybi-thewebsocket-protocol-17
func hybiClientHandshake(config *Config, br *bufio.Reader, bw *bufio.Writer) (err error) { … }

// newHybiClientConn creates a client WebSocket connection after handshake.
func newHybiClientConn(config *Config, buf *bufio.ReadWriter, rwc io.ReadWriteCloser) *Conn { … }

type hybiServerHandshaker …

func (c *hybiServerHandshaker) ReadHandshake(buf *bufio.Reader, req *http.Request) (code int, err error) { … }

// Origin parses the Origin header in req.
// If the Origin header is not set, it returns nil and nil.
func Origin(config *Config, req *http.Request) (*url.URL, error) { … }

func (c *hybiServerHandshaker) AcceptHandshake(buf *bufio.Writer) (err error) { … }

func (c *hybiServerHandshaker) NewServerConn(buf *bufio.ReadWriter, rwc io.ReadWriteCloser, request *http.Request) *Conn { … }

// newHybiServerConn returns a new WebSocket connection speaking hybi draft protocol.
func newHybiServerConn(config *Config, buf *bufio.ReadWriter, rwc io.ReadWriteCloser, request *http.Request) *Conn { … }