ws

Documentation

Index

• Variables
• type Client
  • func NewClient(w http.ResponseWriter, r *http.Request, rHandle ReadHandle, ...) *Client
  • func (c *Client) Run(pingPeriod, writeWait, pongWait, maxMsgSize int64)
• type CloseHandle
• type ReadHandle

Variables

var (
	NewLineChar = []byte{'\n'}
)

Types

type Client

type Client struct {
	Send chan []byte
	// contains filtered or unexported fields
}

func NewClient

func NewClient(w http.ResponseWriter, r *http.Request, rHandle ReadHandle, cHandle CloseHandle, log logger.Interface, sChanCnt int) *Client

func (*Client) Run

func (c *Client) Run(pingPeriod, writeWait, pongWait, maxMsgSize int64)

type CloseHandle

type CloseHandle func(*Client)

type ReadHandle

type ReadHandle func(*Client, []byte)