websocket

type Method string

type Options struct {
	Auth      func(ctx *hfwContext.Context) error             // WebSocket 认证
	Buffer    int                                             // 缓冲区间。default: 16
	Timeout   time.Duration                                   // 超时时间。default: 3s
	Heartbeat time.Duration                                   // 心跳。default: 5s
	Action    func(ctx *hfwContext.Context, session *Session) // 主动推送
}

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

type WebSocketBroadcast struct {
	Subject subject     `json:"subject" validate:"required"`
	Time    string      `json:"time" validate:"required"`
	Data    interface{} `json:"data" validate:"required"`
}

type WebSocketRequest struct {
	ID     sessionID        `json:"id" validate:"required"`
	Method Method           `json:"method" validate:"required"`
	Params *json.RawMessage `json:"params,omitempty"`
}

type WebSocketResponse struct {
	ID      sessionID      `json:"id" validate:"required"`
	Code    webserver.Code `json:"code,omitempty"`
	Message string         `json:"message,omitempty"`
	Method  Method         `json:"method,omitempty"`
	Data    interface{}    `json:"data,omitempty"`
}