logic

Documentation

Index

• type BroadcastGroupLogic
  • func NewBroadcastGroupLogic(ctx context.Context, svcCtx *svc.ServiceContext) *BroadcastGroupLogic
  • func (l *BroadcastGroupLogic) BroadcastGroup(in *comet.BroadcastGroupReq) (*comet.BroadcastGroupReply, error)
• type BroadcastLogic
  • func NewBroadcastLogic(ctx context.Context, svcCtx *svc.ServiceContext) *BroadcastLogic
  • func (l *BroadcastLogic) Broadcast(in *comet.BroadcastReq) (*comet.BroadcastReply, error)
• type DelGroupsLogic
  • func NewDelGroupsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DelGroupsLogic
  • func (l *DelGroupsLogic) DelGroups(in *comet.DelGroupsReq) (*comet.DelGroupsReply, error)
• type JoinGroupsLogic
  • func NewJoinGroupsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *JoinGroupsLogic
  • func (l *JoinGroupsLogic) JoinGroups(in *comet.JoinGroupsReq) (*comet.JoinGroupsReply, error)
• type LeaveGroupsLogic
  • func NewLeaveGroupsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LeaveGroupsLogic
  • func (l *LeaveGroupsLogic) LeaveGroups(in *comet.LeaveGroupsReq) (*comet.LeaveGroupsReply, error)
• type PushMsgLogic
  • func NewPushMsgLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PushMsgLogic
  • func (l *PushMsgLogic) PushMsg(in *comet.PushMsgReq) (*comet.PushMsgReply, error)

Types

type BroadcastGroupLogic

type BroadcastGroupLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewBroadcastGroupLogic

func NewBroadcastGroupLogic(ctx context.Context, svcCtx *svc.ServiceContext) *BroadcastGroupLogic

func (*BroadcastGroupLogic) BroadcastGroup

func (l *BroadcastGroupLogic) BroadcastGroup(in *comet.BroadcastGroupReq) (*comet.BroadcastGroupReply, error)

type BroadcastLogic

type BroadcastLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewBroadcastLogic

func NewBroadcastLogic(ctx context.Context, svcCtx *svc.ServiceContext) *BroadcastLogic

func (*BroadcastLogic) Broadcast

func (l *BroadcastLogic) Broadcast(in *comet.BroadcastReq) (*comet.BroadcastReply, error)

type DelGroupsLogic

type DelGroupsLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewDelGroupsLogic

func NewDelGroupsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DelGroupsLogic

func (*DelGroupsLogic) DelGroups

func (l *DelGroupsLogic) DelGroups(in *comet.DelGroupsReq) (*comet.DelGroupsReply, error)

type JoinGroupsLogic

type JoinGroupsLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewJoinGroupsLogic

func NewJoinGroupsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *JoinGroupsLogic

func (*JoinGroupsLogic) JoinGroups

func (l *JoinGroupsLogic) JoinGroups(in *comet.JoinGroupsReq) (*comet.JoinGroupsReply, error)

type LeaveGroupsLogic

type LeaveGroupsLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewLeaveGroupsLogic

func NewLeaveGroupsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LeaveGroupsLogic

func (*LeaveGroupsLogic) LeaveGroups

func (l *LeaveGroupsLogic) LeaveGroups(in *comet.LeaveGroupsReq) (*comet.LeaveGroupsReply, error)

type PushMsgLogic

type PushMsgLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewPushMsgLogic

func NewPushMsgLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PushMsgLogic

func (*PushMsgLogic) PushMsg

func (l *PushMsgLogic) PushMsg(in *comet.PushMsgReq) (*comet.PushMsgReply, error)