timedmanagelogic

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Oct 10, 2024 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ToPageInfo 

func ToPageInfo(info *timedjob.PageInfo, defaultOrders ...stores.OrderBy) *stores.PageInfo

func ToPageInfoWithDefault 

func ToPageInfoWithDefault(info *timedjob.PageInfo, defau *stores.PageInfo) *stores.PageInfo

func ToTaskGroupPb 

func ToTaskGroupPb(in *relationDB.TimedTaskGroup) *timedjob.TaskGroup

func ToTaskGroupPbs 

func ToTaskGroupPbs(in []*relationDB.TimedTaskGroup) (ret []*timedjob.TaskGroup)

func ToTaskGroupPo 

func ToTaskGroupPo(in *timedjob.TaskGroup) *relationDB.TimedTaskGroup

func ToTaskInfoPb 

func ToTaskInfoPb(in *relationDB.TimedTaskInfo) *timedjob.TaskInfo

func ToTaskInfoPbs 

func ToTaskInfoPbs(in []*relationDB.TimedTaskInfo) (ret []*timedjob.TaskInfo)

func ToTaskInfoPo 

func ToTaskInfoPo(in *timedjob.TaskInfo) *relationDB.TimedTaskInfo

func ToTaskLog 

func ToTaskLog(po *relationDB.TimedTaskLog) *timedjob.TaskLog

Types

type TaskCancelLogic 

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

func NewTaskCancelLogic 

func NewTaskCancelLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskCancelLogic

func (*TaskCancelLogic) TaskCancel 

func (l *TaskCancelLogic) TaskCancel(in *timedjob.TaskWithTaskID) (*timedjob.Response, error)

type TaskGroupCreateLogic 

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

func NewTaskGroupCreateLogic 

func NewTaskGroupCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskGroupCreateLogic

func (*TaskGroupCreateLogic) TaskGroupCreate 

func (l *TaskGroupCreateLogic) TaskGroupCreate(in *timedjob.TaskGroup) (*timedjob.Response, error)

type TaskGroupDeleteLogic 

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

func NewTaskGroupDeleteLogic 

func NewTaskGroupDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskGroupDeleteLogic

func (*TaskGroupDeleteLogic) TaskGroupDelete 

func (l *TaskGroupDeleteLogic) TaskGroupDelete(in *timedjob.WithCode) (*timedjob.Response, error)

type TaskGroupIndexLogic 

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

func NewTaskGroupIndexLogic 

func NewTaskGroupIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskGroupIndexLogic

func (*TaskGroupIndexLogic) TaskGroupIndex 

func (l *TaskGroupIndexLogic) TaskGroupIndex(in *timedjob.TaskGroupIndexReq) (*timedjob.TaskGroupIndexResp, error)

type TaskGroupReadLogic 

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

func NewTaskGroupReadLogic 

func NewTaskGroupReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskGroupReadLogic

func (*TaskGroupReadLogic) TaskGroupRead 

func (l *TaskGroupReadLogic) TaskGroupRead(in *timedjob.WithCode) (*timedjob.TaskGroup, error)

type TaskGroupUpdateLogic 

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

func NewTaskGroupUpdateLogic 

func NewTaskGroupUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskGroupUpdateLogic

func (*TaskGroupUpdateLogic) TaskGroupUpdate 

func (l *TaskGroupUpdateLogic) TaskGroupUpdate(in *timedjob.TaskGroup) (*timedjob.Response, error)

type TaskInfoCreateLogic 

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

func NewTaskInfoCreateLogic 

func NewTaskInfoCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskInfoCreateLogic

func (*TaskInfoCreateLogic) TaskInfoCreate 

func (l *TaskInfoCreateLogic) TaskInfoCreate(in *timedjob.TaskInfo) (*timedjob.Response, error)

type TaskInfoDeleteLogic 

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

func NewTaskInfoDeleteLogic 

func NewTaskInfoDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskInfoDeleteLogic

func (*TaskInfoDeleteLogic) TaskInfoDelete 

func (l *TaskInfoDeleteLogic) TaskInfoDelete(in *timedjob.WithGroupCode) (*timedjob.Response, error)

type TaskInfoIndexLogic 

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

func NewTaskInfoIndexLogic 

func NewTaskInfoIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskInfoIndexLogic

func (*TaskInfoIndexLogic) TaskInfoIndex 

func (l *TaskInfoIndexLogic) TaskInfoIndex(in *timedjob.TaskInfoIndexReq) (*timedjob.TaskInfoIndexResp, error)

type TaskInfoReadLogic 

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

func NewTaskInfoReadLogic 

func NewTaskInfoReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskInfoReadLogic

func (*TaskInfoReadLogic) TaskInfoRead 

func (l *TaskInfoReadLogic) TaskInfoRead(in *timedjob.WithGroupCode) (*timedjob.TaskInfo, error)

type TaskInfoUpdateLogic 

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

func NewTaskInfoUpdateLogic 

func NewTaskInfoUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskInfoUpdateLogic

func (*TaskInfoUpdateLogic) TaskInfoUpdate 

func (l *TaskInfoUpdateLogic) TaskInfoUpdate(in *timedjob.TaskInfo) (*timedjob.Response, error)

type TaskLogIndexLogic 

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

func NewTaskLogIndexLogic 

func NewTaskLogIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskLogIndexLogic

func (*TaskLogIndexLogic) TaskLogIndex 

func (l *TaskLogIndexLogic) TaskLogIndex(in *timedjob.TaskLogIndexReq) (*timedjob.TaskLogIndexResp, error)

type TaskSendLogic 

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

func NewTaskSendLogic 

func NewTaskSendLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskSendLogic

func (*TaskSendLogic) TaskSend 

func (l *TaskSendLogic) TaskSend(in *timedjob.TaskSendReq) (*timedjob.TaskWithTaskID, error)

发送延时请求,如果任务不存在,则会自动创建,但是自动创建的需要填写param

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.