repository

type CommitRepository interface {
	ListByRef(ctx context.Context, projectID int, ref string) ([]entity.Commit, error)
}

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 MergeRequestRepository interface {
	List(ctx context.Context, projectID int, state string) ([]entity.MergeRequest, error)
	Get(ctx context.Context, projectID, mrIID int) (*entity.MergeRequest, error)
	ListNotes(ctx context.Context, projectID, mrIID int) ([]entity.MRNote, error)
	GetDiffs(ctx context.Context, projectID, mrIID int) ([]entity.MRDiff, error)
	Create(ctx context.Context, projectID int, opts entity.CreateMROptions) (*entity.MergeRequest, error)
	Approve(ctx context.Context, projectID, mrIID int) error
	Merge(ctx context.Context, projectID, mrIID int) (*entity.MergeRequest, 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)
	ListBranches(ctx context.Context, projectID int, search string) ([]string, error)
}