executor

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

type Job struct {
	ID       int64 `gorm:"primaryKey;autoIncrement"`
	Status   entity.JobStatus
	Priority int64
	State    *entity.JobState

	CreateTime time.Time
	UpdateTime time.Time `gorm:"index:idx_update_time"`
}

type JobExecutor interface {
	Initialize(ctx context.Context, param *entity.JobParam) error
	Dispatch(ctx context.Context, param *entity.JobDispatchParam) error
	Display(ctx context.Context) (*entity.JobDisplay, error)
	Close(ctx context.Context) error

	Logger() *logrus.Logger
}

type JobType interface {
	GetExecutor(ctx context.Context, exe *Executor, job *Job) (JobExecutor, error)
}

type Paths struct {
	Work   string `yaml:"work"`
	Source string `yaml:"source"`
	Target string `yaml:"target"`
}

type Scripts struct {
	Encrypt  string `yaml:"encrypt"`
	Mkfs     string `yaml:"mkfs"`
	Mount    string `yaml:"mount"`
	Umount   string `yaml:"umount"`
	ReadInfo string `yaml:"read_info"`
}