rhub

type Client struct {

	// props sync.Map
	Props map[string]interface{}
	// contains filtered or unexported fields
}

type ClientMessage struct {
	*MessageIn
	Client IClient
}

type Conf struct {
	Redis string
}

type Filter func(msg *MessageIn, next func())

type Handler func(msg *MessageIn)

type HandlerWs func(message *ClientMessage)

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

type IClient interface {
	Close()
	// Send() chan []byte
	SendChan() chan []byte
	// Send(subject string, msg interface{})
	Hub() IHub
	WritePump()
	ReadPump()
	GetProps() map[string]interface{}
	// Get(key interface{}) interface{}
	// Set(key, value interface{})
	NewClientMessage(data []byte) (*ClientMessage, error)
	GetClient() *Client
}

type IFilters interface {
	Do(fn Handler)
}

type IHub interface {
	//Get hub's id
	Id() interface{}
	//before new client join
	BeforeJoin(callback func(client IClient) error)
	AfterJoin(callback func(client IClient))
	//On client leave
	BeforeLeave(callback func(client IClient))
	AfterLeave(callback func(client IClient))
	BeforeWsMsg(callback func(msg *ClientMessage) bool)
	//Add filter
	// Use(filter Filter)
	// Attach an event handler function
	On(subject string, handler Handler)
	OnWs(subject string, handler HandlerWs)
	// OnLocal(subject string, handler HandlerLocal)
	//simulate client send msg
	// Emit(msg *ClientMessage)
	//Dettach an event handler function
	Off(subject string, handler Handler)
	OffWs(subject string, handler HandlerWs)
	SendRedisRaw(msg *MessageIn)
	SendRedis(subject string, data interface{})
	//Send message to all clients
	SendWsAll(subject string, message interface{})
	SendWs(subject string, message interface{}, receivers ...IClient)
	EchoWs(msg *ClientMessage)
	Close()
	// CloseMessageLoop()
	// SetSelf(self IHub)
	Run()
	UnregisterChan() chan IClient
	RegisterChan() chan IClient
	MessageChan() chan *ClientMessage
	// MessageLocalChan() chan<- MessageLocal
	CloseChan() chan struct{}
	Clients() map[IClient]bool

	OnTick(func(int))
	GetSeconds() int
	SendWsClient(client IClient, subject string, message interface{})
	SendWsBytes(client IClient, bs []byte)
}

type IRoute interface {
	Route(subject string) []Handler
	// Attach an event handler function
	On(subject string, handler Handler)
	//Dettach an event handler function
	Off(subject string, handler Handler)
}

type MessageIn struct {
	Subject string
	Data    *json.RawMessage
}

type MessageLocal struct {
	Subject string
	Data    interface{}
	Error   error
}

type MessageOut struct {
	Subject string
	Data    interface{}
}

type User struct {
	Name string
}

type WsConfig struct {
	WriteWait, PongWait time.Duration
	MaxMessageSize      int64
	// contains filtered or unexported fields
}