service

Documentation

Index

• func HandleWsConn(ctx context.Context, c *websocket.Conn, uid string)
• func PushMessage(ww *wrapper.WebsocketWrapper, req *messagev1.PushMessageReq) error
• type PushMessager
  • func GetPushMessager() *PushMessager
  • func (p *PushMessager) PushMessage(ctx context.Context, req *messagev1.PushMessageReq) (resp *responsepb.BaseResponse, err error)

Functions

func HandleWsConn

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

func PushMessage

func PushMessage(ww *wrapper.WebsocketWrapper, req *messagev1.PushMessageReq) error

Types

type PushMessager

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

func GetPushMessager

func GetPushMessager() *PushMessager

func (*PushMessager) PushMessage

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