executor

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

type PlatformProvider interface {
	GetPlatformByID(ctx context.Context, id uint) (*model.Platform, error)
}

type RepoProvider interface {
	GetRepoByKey(key string) (*model.Repo, error)
}

type RunManager interface {
	CreateRun(task *model.SyncTask, trigger string, webhookEventID *uint) (*model.SyncRun, error)
	CreateRunStep(step *model.SyncRunStep) error
	UpdateRunStep(step *model.SyncRunStep) error
	CompleteRun(run *model.SyncRun) error
	UpdateTaskLastRun(task *model.SyncTask, run *model.SyncRun) error
	CompleteRunWithTaskUpdate(run *model.SyncRun, task *model.SyncTask) error
}

type S3Config struct {
	Endpoint  string `yaml:"endpoint"` // https://s3.amazonaws.com 或 https://oss-cn-hangzhou.aliyuncs.com
	Region    string `yaml:"region"`   // us-east-1 等
	Bucket    string `yaml:"bucket"`
	Prefix    string `yaml:"prefix"` // 对象 key 前缀
	AccessKey string `yaml:"access_key"`
	SecretKey string `yaml:"secret_key"`
	// PathStyle true=MinIO/部分兼容端点
	PathStyle bool `yaml:"path_style"`
}

type Service interface {
	GetTempDir(taskKey string) string
	GetConfig() *model.Config
	RunManager
	RepoProvider
	PlatformProvider
}