repository

type JobRepository interface {
	Play(ctx context.Context, projectID, jobID int) (*entity.Job, error)
	Retry(ctx context.Context, projectID, jobID int) (*entity.Job, error)
	Cancel(ctx context.Context, projectID, jobID int) (*entity.Job, error)
	GetLog(ctx context.Context, projectID, jobID int) (io.ReadCloser, error)
}

type PipelineRepository interface {
	ListJobs(ctx context.Context, projectID, pipelineID int) ([]entity.Job, error)
	LoadAllPipelines(ctx context.Context, projectPaths []string, perProject int) ([]entity.Pipeline, error)
}

type ProjectRepository interface {
	GetByPath(ctx context.Context, pathWithNS string) (*entity.Project, error)
	Search(ctx context.Context, query string) ([]entity.Project, error)
	ListPipelines(ctx context.Context, projectID int) ([]entity.Pipeline, error)
}