websocket

Oct 21, 2020

Changes in this version

type Client

+ func (this *Client) SetNetDial(fn func(network, addr string) (net.Conn, error))

type Server

+ func (this *Server) UpgradeWithValues(w http.ResponseWriter, r *http.Request, v *Values, args ...interface{})

type Values

+ func (this *Values) String() string

Apr 23, 2020

Changes in this version

+ type ClientDialer struct

+ func NewClientDialer(client *Client, url string) *ClientDialer

+ func (this *ClientDialer) Dial(network, addr string) (net.Conn, error)

+ func (this *ClientDialer) SetHandler(fn func(net.Conn, string, string) (net.Conn, error))

+ func (this *ClientDialer) SetTimeout(d time.Duration)

type Conn

+ func (this *Conn) SetDeadline(t time.Time) error

Apr 13, 2020

Changes in this version

+ const FlagActive

+ const FlagClosed

+ const FlagFrozen

+ const FlagMax

+ const FlagRunning

+ const WebsocketFlagClosed

+ const WebsocketFlagIdle

+ const WebsocketFlagMax

+ var ErrBadInput = errors.New("bad input")

+ var ErrClosed = errors.New("conn closed")

+ var ErrEmptyData = errors.New("empty data")

+ var ErrListAdd = errors.New("unable add to list")

+ func CoroutineGo(fn func())

+ func GenUUID() (string, error)

+ func InitCoroutinePool(p *ants.Pool)

+ func IsDialTimeout(err error) bool

+ type Client struct

+ func NewClient() *Client

+ func (this *Client) Close()

+ func (this *Client) Dial(urlStr string) (*Conn, error)

+ func (this *Client) GetConnByID(id string) *Conn

+ func (this *Client) Len() int

+ func (this *Client) Lists() []string

+ func (this *Client) SetTLSConfig(config *tls.Config)

+ type Conn struct

+ func (this *Conn) AddCloseHandler(fn func(string))

+ func (this *Conn) AddPongHandler(fn func(*Conn))

+ func (this *Conn) Close() error

+ func (this *Conn) HandleConn(fn func(*Conn, string))

+ func (this *Conn) ID() string

+ func (this *Conn) Read(data []byte) (int, error)

+ func (this *Conn) SetIsolatorTime(timeout time.Duration)

+ func (this *Conn) StartIdlaCheck(timeout time.Duration, fns ...func(uint64, uint64))

+ func (this *Conn) UnSetIsolatorTime()

+ func (this *Conn) Write(data []byte) (int, error)

+ func (this *Conn) WriteJSON(v interface{}) (int, error)

+ func (this *Conn) WriteMessage(messageType int, data []byte) error

+ func (this *Conn) WriteString(msg string) error

+ type JsonEncoder struct

+ func NewJsonEncoder() *JsonEncoder

+ func (this *JsonEncoder) Bytes() []byte

+ func (this *JsonEncoder) Encode(v interface{}) error

+ func (this *JsonEncoder) String() string

+ type Server struct

+ func NewServer(fn func(*Conn, string)) *Server

+ func (this *Server) AddAuthHandler(fn func(*Values, interface{}) bool)

+ func (this *Server) AddConnectedHandler(fn func(*Conn) bool)

+ func (this *Server) AddRawConnectionHandler(fn func(*Conn))

+ func (this *Server) BroadCastData(data []byte) error

+ func (this *Server) BroadCastJSON(v interface{}) error

+ func (this *Server) BroadCastString(msg string) error

+ func (this *Server) Close()

+ func (this *Server) GetConnByID(id string) *Conn

+ func (this *Server) Lists() []string

+ func (this *Server) Upgrade(w http.ResponseWriter, r *http.Request, args ...interface{})

+ type Values struct

+ func (this *Values) KVClear()

+ func (this *Values) KVGet(key string) interface{}

+ func (this *Values) KVGetBoolean(key string, def ...bool) bool

+ func (this *Values) KVGetByte(key string, def ...byte) byte

+ func (this *Values) KVGetInt(key string, def ...int) int

+ func (this *Values) KVGetInt64(key string, def ...int64) int64

+ func (this *Values) KVGetString(key string, def ...string) string

+ func (this *Values) KVSet(key string, value interface{})

+ func (this *Values) KVUnSet(key string)