ws

package

v0.0.0-...-74afdde Latest Latest Go to latest Published: Mar 15, 2021 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var (
	GlobalHub *hub
)

func NewReceiveMessage(namespace string, clientID int64, body []byte) (*receiveMessage, error)

func NewSendMessage(namespace string, id, clientID, userSubscriptionID int64, typ string, data interface{}) (*sendMessage, error)

type WS struct {
	Hub *hub
}

func NewWS() *WS

func (n *WS) IsConnecting(namespace string, clientID int64) bool

func (n *WS) MustNotify(ctx context.Context, namespace string, id, clientID, userID int64, typ string, data interface{}) (interface{}, error)

func (n *WS) Notify(ctx context.Context, namespace string, id, clientID, userID int64, typ string, data interface{}) (msgID int64, errR error)

func (n *WS) Register(namespace string, id int64, conn *websocket.Conn)

func (n *WS) Run()

func (n *WS) ServeWebsocket(c echo.Context) error

func (n *WS) WaitResponse(ctx context.Context, msgID int64) (data interface{}, errR error)