chat

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 Hub
  • func (h *Hub) OnConfigReloaded()
  • func (h *Hub) OnMessageSaveDone(msg proto.Message)
• 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)

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 Hub

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

func (*Hub) OnConfigReloaded

func (h *Hub) OnConfigReloaded()

func (*Hub) OnMessageSaveDone

func (h *Hub) OnMessageSaveDone(msg proto.Message)

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)