biz

type Log struct {
	ID             uint32 `json:"id"`
	Uuid           string `json:"uuid"`
	WorkerId       uint32 `json:"worker_id"`
	WorkerSnapshot string `json:"worker_snapshot"`
	TaskId         uint32 `json:"task_id"`
	TaskSnapshot   string `json:"task_snapshot"`
	Start          int64  `json:"start"`
	End            int64  `json:"end"`
	Content        string `json:"content"`
	Status         string `json:"status"`
}

type LogRepo interface {
	AddLog(ctx kratosx.Context, in *Log) (uint32, error)
	GetLog(ctx kratosx.Context, id uint32) (*Log, error)
	PageLog(ctx kratosx.Context, req *PageLogRequest) ([]*Log, uint32, error)
	AppendLogContent(ctx kratosx.Context, uuid string, c string) error
	UpdateLogStatus(ctx kratosx.Context, uuid string, err error) error
	TaskIsRunning(ctx kratosx.Context, uuid string) bool
}

type LogUseCase struct {
	// contains filtered or unexported fields
}

type PageLogRequest struct {
	Page     uint32 `json:"page"`
	PageSize uint32 `json:"page_size"`
	TaskId   uint32 `json:"task_id"`
}

type PageTaskRequest struct {
	Page     uint32  `json:"page"`
	PageSize uint32  `json:"page_size"`
	Tag      *string `json:"tag"`
	Status   *string `json:"status"`
	Name     *string `json:"name"`
}

type PageWorkerGroupRequest struct {
	Page     uint32 `json:"page"`
	PageSize uint32 `json:"page_size"`
}

type PageWorkerRequest struct {
	Page     uint32  `json:"page"`
	PageSize uint32  `json:"page_size"`
	Name     *string `json:"name"`
	GroupId  *uint32 `json:"group_id"`
}

type Task struct {
	ktypes.BaseModel
	GroupId       uint32     `json:"group_id"`
	Name          string     `json:"name"`
	Tag           string     `json:"tag"`
	Spec          string     `json:"spec"`
	SelectType    string     `json:"select_type"`
	WorkerGroupId *uint32    `json:"worker_group_id"`
	WorkerId      *uint32    `json:"worker_id"`
	ExecType      string     `json:"exec_type"`
	ExecValue     string     `json:"exec_value"`
	ExpectCode    *uint32    `json:"expect_code"`
	RetryCount    *uint32    `json:"retry_count"`
	RetryWaitTime *uint32    `json:"retry_wait_time"`
	MaxExecTime   *uint32    `json:"max_exec_time"`
	Status        *bool      `json:"status"`
	Version       string     `json:"version"`
	Description   string     `json:"description"`
	Group         *TaskGroup `json:"group"`
}

type TaskFactory interface {
	DrySpec(s string) bool
	AddCron(id uint32, spec string) error
	UpdateCron(id uint32, spec string) error
	RemoveCron(id uint32) error
	Scheduler(id uint32) error
}

type TaskGroup struct {
	ktypes.BaseModel
	Name        string `json:"name"`
	Description string `json:"description"`
}

type TaskRepo interface {
	AddTaskGroup(ctx kratosx.Context, in *TaskGroup) (uint32, error)
	AllTaskGroup(ctx kratosx.Context) ([]*TaskGroup, error)
	UpdateTaskGroup(ctx kratosx.Context, c *TaskGroup) error
	DeleteTaskGroup(ctx kratosx.Context, id uint32) error

	GetSpecs(ctx kratosx.Context) map[uint32]string
	AddTask(ctx kratosx.Context, in *Task) (uint32, error)
	GetTask(ctx kratosx.Context, id uint32) (*Task, error)
	GetWorkerByUuid(ctx kratosx.Context, uuid string) (*Worker, error)
	PageTask(ctx kratosx.Context, req *PageTaskRequest) ([]*Task, uint32, error)
	UpdateTask(ctx kratosx.Context, c *Task) error
	DeleteTask(ctx kratosx.Context, id uint32) error
	CancelTask(ctx kratosx.Context, uuid string) error
	UpdateTaskStatus(ctx kratosx.Context, id uint32, status *bool) error
}

type TaskUseCase struct {
	// contains filtered or unexported fields
}

type Worker struct {
	ktypes.BaseModel
	GroupId     *uint32      `json:"group_id"`
	Name        string       `json:"name"`
	IP          string       `json:"ip"`
	Status      *bool        `json:"status"`
	Description string       `json:"description"`
	Group       *WorkerGroup `json:"group"`
}

type WorkerFactory interface {
	CheckIP(ctx kratosx.Context, ip string) error
}

type WorkerGroup struct {
	ktypes.BaseModel
	Name        string `json:"name"`
	Description string `json:"description"`
}

type WorkerRepo interface {
	AddWorkerGroup(ctx kratosx.Context, in *WorkerGroup) (uint32, error)
	AllWorkerGroup(ctx kratosx.Context) ([]*WorkerGroup, error)
	UpdateWorkerGroup(ctx kratosx.Context, c *WorkerGroup) error
	DeleteWorkerGroup(ctx kratosx.Context, id uint32) error

	GetWorkerByGroupId(ctx kratosx.Context, id uint32) (*Worker, error)
	AddWorker(ctx kratosx.Context, in *Worker) (uint32, error)
	GetWorker(ctx kratosx.Context, id uint32) (*Worker, error)
	PageWorker(ctx kratosx.Context, req *PageWorkerRequest) ([]*Worker, uint32, error)
	UpdateWorker(ctx kratosx.Context, c *Worker) error
	DeleteWorker(ctx kratosx.Context, id uint32) error
	EnableWorker(ctx kratosx.Context, id uint32) error
	DisableWorker(ctx kratosx.Context, id uint32) error
}

type WorkerUseCase struct {
	// contains filtered or unexported fields
}