task

Documentation

Index

• func ToGroupPb(in *types.TimedTaskGroup) *timedmanage.TaskGroup
• func ToGroupTypes(in *timedmanage.TaskGroup) *types.TimedTaskGroup
• func ToSendDelayReqPb(in *types.TimedTaskSendReq) *timedmanage.TaskSendReq
• func ToTaskGroupsTypes(in []*timedmanage.TaskGroup) (ret []*types.TimedTaskGroup)
• func ToTaskInfoPb(in *types.TimedTaskInfo) *timedmanage.TaskInfo
• func ToTaskInfoTypes(in *timedmanage.TaskInfo) *types.TimedTaskInfo
• func ToTaskInfosTypes(in []*timedmanage.TaskInfo) (ret []*types.TimedTaskInfo)
• func ToTaskLog(pb *timedjob.TaskLog) *types.TimedTaskLog
• type CancelLogic
  • func NewCancelLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CancelLogic
  • func (l *CancelLogic) Cancel(req *types.TimedTaskWithTaskID) error
• type GroupCreateLogic
  • func NewGroupCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupCreateLogic
  • func (l *GroupCreateLogic) GroupCreate(req *types.TimedTaskGroup) error
• type GroupDeleteLogic
  • func NewGroupDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupDeleteLogic
  • func (l *GroupDeleteLogic) GroupDelete(req *types.WithCode) error
• type GroupIndexLogic
  • func NewGroupIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupIndexLogic
  • func (l *GroupIndexLogic) GroupIndex(req *types.TimedTaskGroupIndexReq) (resp *types.TimedTaskGroupIndexResp, err error)
• type GroupReadLogic
  • func NewGroupReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupReadLogic
  • func (l *GroupReadLogic) GroupRead(req *types.WithCode) (resp *types.TimedTaskGroup, err error)
• type GroupUpdateLogic
  • func NewGroupUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupUpdateLogic
  • func (l *GroupUpdateLogic) GroupUpdate(req *types.TimedTaskGroup) error
• type InfoCreateLogic
  • func NewInfoCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoCreateLogic
  • func (l *InfoCreateLogic) InfoCreate(req *types.TimedTaskInfo) error
• type InfoDeleteLogic
  • func NewInfoDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoDeleteLogic
  • func (l *InfoDeleteLogic) InfoDelete(req *types.WithGroupCode) error
• type InfoIndexLogic
  • func NewInfoIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoIndexLogic
  • func (l *InfoIndexLogic) InfoIndex(req *types.TimedTaskInfoIndexReq) (resp *types.TimedTaskInfoIndexResp, err error)
• type InfoReadLogic
  • func NewInfoReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoReadLogic
  • func (l *InfoReadLogic) InfoRead(req *types.WithGroupCode) (resp *types.TimedTaskInfo, err error)
• type InfoUpdateLogic
  • func NewInfoUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoUpdateLogic
  • func (l *InfoUpdateLogic) InfoUpdate(req *types.TimedTaskInfo) error
• type LogIndexLogic
  • func NewLogIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LogIndexLogic
  • func (l *LogIndexLogic) LogIndex(req *types.TimedTaskLogIndexReq) (resp *types.TimedTaskLogIndexResp, err error)
• type SendLogic
  • func NewSendLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SendLogic
  • func (l *SendLogic) Send(req *types.TimedTaskSendReq) (*types.TimedTaskWithTaskID, error)

Functions

func ToGroupPb

func ToGroupPb(in *types.TimedTaskGroup) *timedmanage.TaskGroup

func ToGroupTypes

func ToGroupTypes(in *timedmanage.TaskGroup) *types.TimedTaskGroup

func ToSendDelayReqPb

func ToSendDelayReqPb(in *types.TimedTaskSendReq) *timedmanage.TaskSendReq

func ToTaskGroupsTypes

func ToTaskGroupsTypes(in []*timedmanage.TaskGroup) (ret []*types.TimedTaskGroup)

func ToTaskInfoPb

func ToTaskInfoPb(in *types.TimedTaskInfo) *timedmanage.TaskInfo

func ToTaskInfoTypes

func ToTaskInfoTypes(in *timedmanage.TaskInfo) *types.TimedTaskInfo

func ToTaskInfosTypes

func ToTaskInfosTypes(in []*timedmanage.TaskInfo) (ret []*types.TimedTaskInfo)

func ToTaskLog

func ToTaskLog(pb *timedjob.TaskLog) *types.TimedTaskLog

Types

type CancelLogic

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

func NewCancelLogic

func NewCancelLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CancelLogic

func (*CancelLogic) Cancel

func (l *CancelLogic) Cancel(req *types.TimedTaskWithTaskID) error

type GroupCreateLogic

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

func NewGroupCreateLogic

func NewGroupCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupCreateLogic

func (*GroupCreateLogic) GroupCreate

func (l *GroupCreateLogic) GroupCreate(req *types.TimedTaskGroup) error

type GroupDeleteLogic

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

func NewGroupDeleteLogic

func NewGroupDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupDeleteLogic

func (*GroupDeleteLogic) GroupDelete

func (l *GroupDeleteLogic) GroupDelete(req *types.WithCode) error

type GroupIndexLogic

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

func NewGroupIndexLogic

func NewGroupIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupIndexLogic

func (*GroupIndexLogic) GroupIndex

func (l *GroupIndexLogic) GroupIndex(req *types.TimedTaskGroupIndexReq) (resp *types.TimedTaskGroupIndexResp, err error)

type GroupReadLogic

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

func NewGroupReadLogic

func NewGroupReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupReadLogic

func (*GroupReadLogic) GroupRead

func (l *GroupReadLogic) GroupRead(req *types.WithCode) (resp *types.TimedTaskGroup, err error)

type GroupUpdateLogic

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

func NewGroupUpdateLogic

func NewGroupUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupUpdateLogic

func (*GroupUpdateLogic) GroupUpdate

func (l *GroupUpdateLogic) GroupUpdate(req *types.TimedTaskGroup) error

type InfoCreateLogic

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

func NewInfoCreateLogic

func NewInfoCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoCreateLogic

func (*InfoCreateLogic) InfoCreate

func (l *InfoCreateLogic) InfoCreate(req *types.TimedTaskInfo) error

type InfoDeleteLogic

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

func NewInfoDeleteLogic

func NewInfoDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoDeleteLogic

func (*InfoDeleteLogic) InfoDelete

func (l *InfoDeleteLogic) InfoDelete(req *types.WithGroupCode) error

type InfoIndexLogic

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

func NewInfoIndexLogic

func NewInfoIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoIndexLogic

func (*InfoIndexLogic) InfoIndex

func (l *InfoIndexLogic) InfoIndex(req *types.TimedTaskInfoIndexReq) (resp *types.TimedTaskInfoIndexResp, err error)

type InfoReadLogic

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

func NewInfoReadLogic

func NewInfoReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoReadLogic

func (*InfoReadLogic) InfoRead

func (l *InfoReadLogic) InfoRead(req *types.WithGroupCode) (resp *types.TimedTaskInfo, err error)

type InfoUpdateLogic

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

func NewInfoUpdateLogic

func NewInfoUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoUpdateLogic

func (*InfoUpdateLogic) InfoUpdate

func (l *InfoUpdateLogic) InfoUpdate(req *types.TimedTaskInfo) error

type LogIndexLogic

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

func NewLogIndexLogic

func NewLogIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LogIndexLogic

func (*LogIndexLogic) LogIndex

func (l *LogIndexLogic) LogIndex(req *types.TimedTaskLogIndexReq) (resp *types.TimedTaskLogIndexResp, err error)

type SendLogic

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

func NewSendLogic

func NewSendLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SendLogic

func (*SendLogic) Send

func (l *SendLogic) Send(req *types.TimedTaskSendReq) (*types.TimedTaskWithTaskID, error)