websockets

type Client struct {
	Id            string
	Send          chan []byte
	IsServer      bool
	CloseCallBack func()

	Server *Server
	// contains filtered or unexported fields
}

type Manager struct {
	Clients cmap.ConcurrentMap
}

type ParserHandler func(c *Client, msg interface{})

type Protocol interface {
	Register(protocol int64, t interface{}, handler ParserHandler)
	Receive(c *Client, msg []byte) error
	Send(c *Client, msg SubscriberBody) error
}

type Server struct {
	Manager    *Manager
	Protocol   Protocol
	Subscriber Subscriber
}

type Subscriber interface {
	Conn()
	Destroy()
	Producer(c *Client, message SubscriberMessage)
	Consumer(server *Server)
}

type SubscriberBody struct {
	Protocol  int64
	Data      interface{}
	Condition interface{}
}

type SubscriberMessage struct {
	Type string
	Body SubscriberBody
}