service

Documentation

Index

• func HandleWsConn(ctx context.Context, c *websocket.Conn, uid types.ID)
• func PushMessage(wc *ws.WebsocketConn, req *messagev1.PushMessageReq) error
• type PushMessager
  • func GetPushMessager() *PushMessager
  • func (p *PushMessager) PushMessage(ctx context.Context, req *messagev1.PushMessageReq) (resp *messagev1.PushMessageResp, err error)

Functions

func HandleWsConn

func HandleWsConn(ctx context.Context, c *websocket.Conn, uid types.ID)

func PushMessage

func PushMessage(wc *ws.WebsocketConn, req *messagev1.PushMessageReq) error

Types

type PushMessager

type PushMessager struct {
	messagev1.UnimplementedPushMessageServiceServer
	// contains filtered or unexported fields
}

func GetPushMessager

func GetPushMessager() *PushMessager

func (*PushMessager) PushMessage

func (p *PushMessager) PushMessage(ctx context.Context, req *messagev1.PushMessageReq) (resp *messagev1.PushMessageResp, err error)