server

Documentation

Index

• type CometServer
  • func NewCometServer(svcCtx *svc.ServiceContext) *CometServer
  • func (s *CometServer) Broadcast(ctx context.Context, in *comet.BroadcastReq) (*comet.BroadcastReply, error)
  • func (s *CometServer) BroadcastGroup(ctx context.Context, in *comet.BroadcastGroupReq) (*comet.BroadcastGroupReply, error)
  • func (s *CometServer) DelGroups(ctx context.Context, in *comet.DelGroupsReq) (*comet.DelGroupsReply, error)
  • func (s *CometServer) JoinGroups(ctx context.Context, in *comet.JoinGroupsReq) (*comet.JoinGroupsReply, error)
  • func (s *CometServer) LeaveGroups(ctx context.Context, in *comet.LeaveGroupsReq) (*comet.LeaveGroupsReply, error)
  • func (s *CometServer) PushMsg(ctx context.Context, in *comet.PushMsgReq) (*comet.PushMsgReply, error)

Types

type CometServer

type CometServer struct {
	comet.UnimplementedCometServer
	// contains filtered or unexported fields
}

func NewCometServer

func NewCometServer(svcCtx *svc.ServiceContext) *CometServer

func (*CometServer) Broadcast

func (s *CometServer) Broadcast(ctx context.Context, in *comet.BroadcastReq) (*comet.BroadcastReply, error)

func (*CometServer) BroadcastGroup

func (s *CometServer) BroadcastGroup(ctx context.Context, in *comet.BroadcastGroupReq) (*comet.BroadcastGroupReply, error)

func (*CometServer) DelGroups

func (s *CometServer) DelGroups(ctx context.Context, in *comet.DelGroupsReq) (*comet.DelGroupsReply, error)

func (*CometServer) JoinGroups

func (s *CometServer) JoinGroups(ctx context.Context, in *comet.JoinGroupsReq) (*comet.JoinGroupsReply, error)

func (*CometServer) LeaveGroups

func (s *CometServer) LeaveGroups(ctx context.Context, in *comet.LeaveGroupsReq) (*comet.LeaveGroupsReply, error)

func (*CometServer) PushMsg

func (s *CometServer) PushMsg(ctx context.Context, in *comet.PushMsgReq) (*comet.PushMsgReply, error)