task

package
v1.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 5, 2024 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.