ws

Jun 18, 2018

Changes in this version

type Request

+ func (r *Request) URL() *url.URL

May 11, 2018

Changes in this version

type Engine

+ func (e *Engine) SetIDGenerator(g IDGenerator)

+ type IDGenerator func(ctx *Context) string

Apr 27, 2018

Changes in this version

+ var ErrAbortRequest = errors.New("aahws: abort request")

+ var ErrConnectFailed = errors.New("aahws: connect failed")

+ var ErrNotFound = errors.New("aahws: not found")

type Context

+ func (ctx *Context) Abort(httpErroCode int)

type Engine

+ func (e *Engine) Handle(w http.ResponseWriter, r *http.Request)

Apr 23, 2018

Changes in this version

+ const EventOnError

+ const EventOnPostConnect

+ const EventOnPostDisconnect

+ const EventOnPreConnect

+ const Version

+ var ErrAuthenticationFailed = errors.New("aahws: authentication failed")

+ var ErrConnectionClosed = errors.New("aahws: connection closed")

+ var ErrOriginMismatch = errors.New("aahws: origin mismatch")

+ var ErrParameterParseFailed = errors.New("aahws: parameter parse failed")

+ var ErrUseOfClosedConnection = errors.New("aahws: use of closed ws connection")

+ var ErrWebSocketConnectFailed = errors.New("aahws: connect failed")

+ var ErrWebSocketNotFound = errors.New("aahws: not found")

+ func IsDisconnected(err error) bool

+ type AuthCallbackFunc func(ctx *Context) bool

+ type Context struct

+ Conn net.Conn

+ Header http.Header

+ Req *Request

+ func (ctx *Context) Disconnect() error

+ func (ctx *Context) ErrorReason() error

+ func (ctx *Context) Log() log.Loggerer

+ func (ctx *Context) ReadBinary() ([]byte, error)

+ func (ctx *Context) ReadJSON(t interface{}) error

+ func (ctx *Context) ReadText() (string, error)

+ func (ctx *Context) ReadXML(t interface{}) error

+ func (ctx *Context) ReplyBinary(v []byte) error

+ func (ctx *Context) ReplyJSON(v interface{}) error

+ func (ctx *Context) ReplyText(v string) error

+ func (ctx *Context) ReplyXML(v interface{}) error

+ type Engine struct

+ func New(cfg *config.Config, logger log.Loggerer) (*Engine, error)

+ func (e *Engine) AddWebSocket(t interface{}, methods []*ainsp.Method)

+ func (e *Engine) CallAction(ctx *Context)

+ func (e *Engine) Connect(w http.ResponseWriter, r *http.Request, route *router.Route, ...) (*Context, error)

+ func (e *Engine) Log() log.Loggerer

+ func (e *Engine) OnError(ecf EventCallbackFunc)

+ func (e *Engine) OnPostConnect(ecf EventCallbackFunc)

+ func (e *Engine) OnPostDisconnect(ecf EventCallbackFunc)

+ func (e *Engine) OnPreConnect(ecf EventCallbackFunc)

+ func (e *Engine) ReplyError(w http.ResponseWriter, errCode int)

+ func (e *Engine) SetAuthCallback(ac AuthCallbackFunc)

+ type EventCallbackFunc func(eventName string, ctx *Context)

+ type Request struct

+ Header http.Header

+ Host string

+ ID string

+ Path string

+ func (r *Request) ClientIP() string

+ func (r *Request) PathValue(key string) string

+ func (r *Request) QueryArrayValue(key string) []string

+ func (r *Request) QueryValue(key string) string

+ func (r Request) String() string