wss

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

type Config struct {
}

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

type IRouter interface {
	Channel() string
	Register(*Client, *Message) error
	Unregister(*Client, *Message) error
	Perform(*Client, *Message) error
	IsClosed() bool
	Run()
	Stop()
}

type Message struct {
	Command string          `json:"command"`
	Channel string          `json:"channel"`
	Data    json.RawMessage `json:"data"`
}

type Reply struct {
	Type    string          `json:"type,omitempty"`
	Channel string          `json:"channel,omitempty"`
	Data    json.RawMessage `json:"data"`
}

type Server struct {
	Conf *Config
	// contains filtered or unexported fields
}

type SubchannelMessage struct {
	Subchannel string
	Message    json.RawMessage
}

type SubchannelReply struct {
	Subchannel string
	Data       json.RawMessage
}

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

type SubchannelWorker interface {
	SetRouter(*SubchannelRouter)
	Run()
	Stop()
}