websocket

type Client struct {
	ConnectionHandler
	WriteWait time.Duration
}

type Connection struct {
	Context route.RequestContext
	// contains filtered or unexported fields
}

type ConnectionEvents struct {
	// contains filtered or unexported fields
}

type ConnectionHandler struct {
	service.Container
	route.Grouper
	ConnectionEvents
	// contains filtered or unexported fields
}

type GetHandlerFunc func(data *JSONMessage) (middleware []route.Middleware, h route.Handler)

type HTTPContext struct {
	Writer         netHttp.ResponseWriter
	Request        *netHttp.Request
	ResponseHeader netHttp.Header
}

type JSONMessage struct {
	Route     string     `json:"r"`
	Type      route.Type `json:"t"`
	Payload   string     `json:"p"`
	AuthToken string     `json:"a,omitempty"`
}

type Message struct {
	Name   string
	T      route.Type
	Data   interface{}
	Filter func(*Connection) bool
}

type OnAfterRequest func(tx *storage.Transaction) (err error)

type OnBeforeRequest func(ctx route.RequestContext, msg *JSONMessage) (cancelConnection bool, err error)

type OnCreateRequest func(conn *Connection, tx *storage.Transaction) (r route.Request)

type OnNewConnection func(c *Connection, uctx UpgradeContext) (err error)

type RequestContext struct {
	route.BaseRequestContext
}

type Server struct {
	ConnectionHandler
	// contains filtered or unexported fields
}

type ServerConfig struct {
	Upgrader       *gorilla.Upgrader
	WriteWait      time.Duration
	PongWait       time.Duration
	PingInterval   time.Duration
	MaxMessageSize int64
}

type UpgradeContext interface {
	HTTPContext() (ctx *HTTPContext)
	Language() (lang *language.Tag)
}