biz

Apr 17, 2024

Changes in this version

+ const ExecCancel

+ const ExecFail

+ const ExecRunning

+ const ExecSuccess

+ const ExecTypeGroup

+ const WorkerDisabled

+ const WorkerEnabled

+ const WorkerRunning

+ var TaskDisabled = proto.Bool(false)

+ var TaskEnabled = proto.Bool(true)

+ type Log struct

+ Content string

+ End int64

+ ID uint32

+ Start int64

+ Status string

+ TaskId uint32

+ TaskSnapshot string

+ Uuid string

+ WorkerId uint32

+ WorkerSnapshot string

+ type LogRepo interface

+ AddLog func(ctx kratosx.Context, in *Log) (uint32, error)

+ AppendLogContent func(ctx kratosx.Context, uuid string, c string) error

+ GetLog func(ctx kratosx.Context, id uint32) (*Log, error)

+ PageLog func(ctx kratosx.Context, req *PageLogRequest) ([]*Log, uint32, error)

+ TaskIsRunning func(ctx kratosx.Context, uuid string) bool

+ UpdateLogStatus func(ctx kratosx.Context, uuid string, err error) error

+ type LogUseCase struct

+ func NewLogUseCase(config *conf.Config, repo LogRepo) *LogUseCase

+ func (u *LogUseCase) GetLog(ctx kratosx.Context, id uint32) (*Log, error)

+ func (u *LogUseCase) PageLog(ctx kratosx.Context, req *PageLogRequest) ([]*Log, uint32, error)

+ type PageLogRequest struct

+ Page uint32

+ PageSize uint32

+ TaskId uint32

+ type PageTaskRequest struct

+ Name *string

+ Page uint32

+ PageSize uint32

+ Status *string

+ Tag *string

+ type PageWorkerGroupRequest struct

+ Page uint32

+ PageSize uint32

+ type PageWorkerRequest struct

+ GroupId *uint32

+ Name *string

+ Page uint32

+ PageSize uint32

+ type Task struct

+ Description string

+ ExecType string

+ ExecValue string

+ ExpectCode *uint32

+ Group *TaskGroup

+ GroupId uint32

+ MaxExecTime *uint32

+ Name string

+ RetryCount *uint32

+ RetryWaitTime *uint32

+ SelectType string

+ Spec string

+ Status *bool

+ Tag string

+ Version string

+ WorkerGroupId *uint32

+ WorkerId *uint32

+ type TaskFactory interface

+ AddCron func(id uint32, spec string) error

+ DrySpec func(s string) bool

+ RemoveCron func(id uint32) error

+ Scheduler func(id uint32) error

+ UpdateCron func(id uint32, spec string) error

+ type TaskGroup struct

+ Description string

+ Name string

+ type TaskRepo interface

+ AddTask func(ctx kratosx.Context, in *Task) (uint32, error)

+ AddTaskGroup func(ctx kratosx.Context, in *TaskGroup) (uint32, error)

+ AllTaskGroup func(ctx kratosx.Context) ([]*TaskGroup, error)

+ CancelTask func(ctx kratosx.Context, uuid string) error

+ DeleteTask func(ctx kratosx.Context, id uint32) error

+ DeleteTaskGroup func(ctx kratosx.Context, id uint32) error

+ GetSpecs func(ctx kratosx.Context) map[uint32]string

+ GetTask func(ctx kratosx.Context, id uint32) (*Task, error)

+ GetWorkerByUuid func(ctx kratosx.Context, uuid string) (*Worker, error)

+ PageTask func(ctx kratosx.Context, req *PageTaskRequest) ([]*Task, uint32, error)

+ UpdateTask func(ctx kratosx.Context, c *Task) error

+ UpdateTaskGroup func(ctx kratosx.Context, c *TaskGroup) error

+ UpdateTaskStatus func(ctx kratosx.Context, id uint32, status *bool) error

+ type TaskUseCase struct

+ func NewTaskUseCase(config *conf.Config, repo TaskRepo, factory TaskFactory) *TaskUseCase

+ func (u *TaskUseCase) AddTask(ctx kratosx.Context, task *Task) (uint32, error)

+ func (u *TaskUseCase) AddTaskGroup(ctx kratosx.Context, tg *TaskGroup) (uint32, error)

+ func (u *TaskUseCase) AllTaskGroup(ctx kratosx.Context) ([]*TaskGroup, error)

+ func (u *TaskUseCase) CancelTask(ctx kratosx.Context, uuid string) error

+ func (u *TaskUseCase) DeleteTask(ctx kratosx.Context, id uint32) error

+ func (u *TaskUseCase) DeleteTaskGroup(ctx kratosx.Context, id uint32) error

+ func (u *TaskUseCase) DisableTask(ctx kratosx.Context, id uint32) error

+ func (u *TaskUseCase) EnableTask(ctx kratosx.Context, id uint32) error

+ func (u *TaskUseCase) ExecTask(ctx kratosx.Context, id uint32) error

+ func (u *TaskUseCase) PageTask(ctx kratosx.Context, req *PageTaskRequest) ([]*Task, uint32, error)

+ func (u *TaskUseCase) UpdateTask(ctx kratosx.Context, task *Task) error

+ func (u *TaskUseCase) UpdateTaskGroup(ctx kratosx.Context, tg *TaskGroup) error

+ type Worker struct

+ Description string

+ Group *WorkerGroup

+ GroupId *uint32

+ IP string

+ Name string

+ Status *bool

+ type WorkerFactory interface

+ CheckIP func(ctx kratosx.Context, ip string) error

+ type WorkerGroup struct

+ Description string

+ Name string

+ type WorkerRepo interface

+ AddWorker func(ctx kratosx.Context, in *Worker) (uint32, error)

+ AddWorkerGroup func(ctx kratosx.Context, in *WorkerGroup) (uint32, error)

+ AllWorkerGroup func(ctx kratosx.Context) ([]*WorkerGroup, error)

+ DeleteWorker func(ctx kratosx.Context, id uint32) error

+ DeleteWorkerGroup func(ctx kratosx.Context, id uint32) error

+ DisableWorker func(ctx kratosx.Context, id uint32) error

+ EnableWorker func(ctx kratosx.Context, id uint32) error

+ GetWorker func(ctx kratosx.Context, id uint32) (*Worker, error)

+ GetWorkerByGroupId func(ctx kratosx.Context, id uint32) (*Worker, error)

+ PageWorker func(ctx kratosx.Context, req *PageWorkerRequest) ([]*Worker, uint32, error)

+ UpdateWorker func(ctx kratosx.Context, c *Worker) error

+ UpdateWorkerGroup func(ctx kratosx.Context, c *WorkerGroup) error

+ type WorkerUseCase struct

+ func NewWorkerUseCase(config *conf.Config, repo WorkerRepo, factory WorkerFactory) *WorkerUseCase

+ func (u *WorkerUseCase) AddWorker(ctx kratosx.Context, worker *Worker) (uint32, error)

+ func (u *WorkerUseCase) AddWorkerGroup(ctx kratosx.Context, tg *WorkerGroup) (uint32, error)

+ func (u *WorkerUseCase) AllWorkerGroup(ctx kratosx.Context) ([]*WorkerGroup, error)

+ func (u *WorkerUseCase) DeleteWorker(ctx kratosx.Context, id uint32) error

+ func (u *WorkerUseCase) DeleteWorkerGroup(ctx kratosx.Context, id uint32) error

+ func (u *WorkerUseCase) DisableWorker(ctx kratosx.Context, id uint32) error

+ func (u *WorkerUseCase) EnableWorker(ctx kratosx.Context, id uint32) error

+ func (u *WorkerUseCase) PageWorker(ctx kratosx.Context, req *PageWorkerRequest) ([]*Worker, uint32, error)

+ func (u *WorkerUseCase) UpdateWorker(ctx kratosx.Context, worker *Worker) error

+ func (u *WorkerUseCase) UpdateWorkerGroup(ctx kratosx.Context, tg *WorkerGroup) error