server

Documentation

Index

• type LogicsServer
  • func NewLogicsServer(svcCtx *svc.ServiceContext) *LogicsServer
  • func (s *LogicsServer) Push(ctx context.Context, in *pb.Send) (*pb.LGSuccessReply, error)
• type TaskServer
  • func NewTaskServer(svcCtx *svc.ServiceContext) *TaskServer
  • func (s *TaskServer) PushSingleToConnect(ctx context.Context, in *pb.TaskSend) (*pb.TaskSuccessReply, error)
• type WsServer
  • func NewWsServer(svcCtx *svc.ServiceContext) *WsServer
  • func (s *WsServer) Connect(ctx context.Context, in *pb.ConnectRequest) (*pb.ConnectReply, error)
  • func (s *WsServer) DisConnect(ctx context.Context, in *pb.DisConnectRequest) (*pb.DisConnectReply, error)
  • func (s *WsServer) PushSingleMsg(ctx context.Context, in *pb.PushRoomMsgRequest) (*pb.SuccessReply, error)

Types

type LogicsServer

type LogicsServer struct {
	pb.UnimplementedLogicsServer
	// contains filtered or unexported fields
}

func NewLogicsServer

func NewLogicsServer(svcCtx *svc.ServiceContext) *LogicsServer

func (*LogicsServer) Push

func (s *LogicsServer) Push(ctx context.Context, in *pb.Send) (*pb.LGSuccessReply, error)

返送单条消息

type TaskServer

type TaskServer struct {
	pb.UnimplementedTaskServer
	// contains filtered or unexported fields
}

func NewTaskServer

func NewTaskServer(svcCtx *svc.ServiceContext) *TaskServer

func (*TaskServer) PushSingleToConnect

func (s *TaskServer) PushSingleToConnect(ctx context.Context, in *pb.TaskSend) (*pb.TaskSuccessReply, error)

返送单条消息

type WsServer

type WsServer struct {
	pb.UnimplementedWsServer
	// contains filtered or unexported fields
}

func NewWsServer

func NewWsServer(svcCtx *svc.ServiceContext) *WsServer

func (*WsServer) Connect

func (s *WsServer) Connect(ctx context.Context, in *pb.ConnectRequest) (*pb.ConnectReply, error)

func (*WsServer) DisConnect

func (s *WsServer) DisConnect(ctx context.Context, in *pb.DisConnectRequest) (*pb.DisConnectReply, error)

func (*WsServer) PushSingleMsg

func (s *WsServer) PushSingleMsg(ctx context.Context, in *pb.PushRoomMsgRequest) (*pb.SuccessReply, error)

返送单条消息