ws

Documentation

Index

• func SetMaxMessageSize(n int)
• func StartHub()
• func StopHub()
• func WsHandler(c echo.Context) error
• func WsPublicHandler(c echo.Context) error
• type BinaryMsg
• type TextMsg
• type WsClient
  • func NewWsClient(conn *websocket.Conn, uid uint64, did, token string, userAgent string, ...) *WsClient
  • func (c *WsClient) Close()
  • func (c *WsClient) PostBinaryMsg(message []byte)
• type WsHub
  • func (h *WsHub) OnConfigReloaded()

Functions

func SetMaxMessageSize

func SetMaxMessageSize(n int)

func StartHub

func StartHub()

func StopHub

func StopHub()

func WsHandler

func WsHandler(c echo.Context) error

func WsPublicHandler

func WsPublicHandler(c echo.Context) error

Types

type BinaryMsg

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

type TextMsg

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

type WsClient

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

每个 Client 代表一个具体的 IM 用户的具体的某一登录设备

func NewWsClient

func NewWsClient(conn *websocket.Conn, uid uint64, did, token string, userAgent string, cookies []*http.Cookie, registerIt bool) *WsClient

func (*WsClient) Close

func (c *WsClient) Close()

func (*WsClient) PostBinaryMsg

func (c *WsClient) PostBinaryMsg(message []byte)

type WsHub

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

func (*WsHub) OnConfigReloaded

func (h *WsHub) OnConfigReloaded()