websocket

type Authenticator interface {
	// Authenticate 验证请求是否合法，第一个返回值为用户 id，第二个返回值为错误
	Authenticate(r *http.Request) (map[string]interface{}, error)
}

type BinaryMessageHandler interface {
	Handler(ctx context.Context, clientId, userId string, data []byte) error
	// contains filtered or unexported methods
}

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

type Handler func(msg message.WsMessage, err error)

type Hub struct {

	// 互斥锁，保护 userClients 以及 clients 的读写
	sync.RWMutex
	// contains filtered or unexported fields
}

type JWTAuthenticator struct{}

type TextMessageHandler interface {
	Handler(ctx context.Context, clientId, userId string, data []byte) error
	// contains filtered or unexported methods
}

type UnimplementedBinaryMessageHandler struct{}

type UnimplementedTextMessageHandler struct{}