tok

type Actor interface {
	BeforeReceive(dv *Device, data []byte) ([]byte, error) // is invoked before OnReceive
	OnReceive(dv *Device, data []byte)                     // is invoked every time the server receive valid payload
	BeforeSend(dv *Device, data []byte) ([]byte, error)    // is invoked before Send, if return value is nil, use raw data
	OnSent(dv *Device, data []byte)                        // is invoked if message is sent successfully. count mean copy quantity
	// OnClose is invoked after a connection has been closed
	// active, count of active connections for this user
	OnClose(dv *Device)
	Ping() []byte                                         // Build ping payload.  auto ping feature will be disabled if this method return nil
	Bye(kicker *Device, reason string, dv *Device) []byte // Build payload for different reason before connection is closed
}

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

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

type HubConfig struct {
	Actor Actor // Actor implement dispatch logic
	Q     Queue // Message Queue, if nil, message to offline user will not be cached
	Sso   bool  // Default true, if it's true, new connection  with same uid will kick off old ones
}

type HubConfigOption func(*HubConfig)

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

type Queue interface {
	Enq(ctx context.Context, uid interface{}, data []byte, ttl ...uint32) error
	Deq(ctx context.Context, uid interface{}) ([]byte, error)
	Len(ctx context.Context, uid interface{}) (int, error)
}

type TCPAuthFunc func([]byte) (*Device, error)

type WsAuthFunc func(*http.Request) (*Device, error)

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

type WsHandlerOption func(*WsHandler)