service

package

v0.4.4 Latest Latest Go to latest Published: Mar 4, 2026 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewJobService(jr repository.JobRepository) *JobService

func (s *JobService) CancelJob(ctx context.Context, projectID, jobID int) (*entity.Job, error)

func (s *JobService) GetJobLog(ctx context.Context, projectID, jobID int) (io.ReadCloser, error)

func (s *JobService) PlayJob(ctx context.Context, projectID, jobID int) (*entity.Job, error)

func (s *JobService) RetryJob(ctx context.Context, projectID, jobID int) (*entity.Job, error)

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

func NewMergeRequestService(mr repository.MergeRequestRepository, cr repository.CommitRepository) *MergeRequestService

func (s *MergeRequestService) ApproveMR(ctx context.Context, projectID, mrIID int) error

func (s *MergeRequestService) CreateMR(ctx context.Context, projectID int, opts entity.CreateMROptions) (*entity.MergeRequest, error)

func (s *MergeRequestService) GetDiffs(ctx context.Context, projectID, mrIID int) ([]entity.MRDiff, error)

func (s *MergeRequestService) GetMR(ctx context.Context, projectID, mrIID int) (*entity.MergeRequest, error)

func (s *MergeRequestService) ListCommits(ctx context.Context, projectID int, ref string) ([]entity.Commit, error)

func (s *MergeRequestService) ListMRs(ctx context.Context, projectID int, state string) ([]entity.MergeRequest, error)

func (s *MergeRequestService) ListNotes(ctx context.Context, projectID, mrIID int) ([]entity.MRNote, error)

func (s *MergeRequestService) MergeMR(ctx context.Context, projectID, mrIID int) (*entity.MergeRequest, error)

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

func NewPipelineService(pr repository.ProjectRepository, plr repository.PipelineRepository) *PipelineService

func (s *PipelineService) ListBranches(ctx context.Context, projectID int, search string) ([]string, error)

func (s *PipelineService) ListJobs(ctx context.Context, projectID, pipelineID int) ([]entity.Job, error)

func (s *PipelineService) ListPipelines(ctx context.Context, projectID int) ([]entity.Pipeline, error)

func (s *PipelineService) LoadAllPipelines(ctx context.Context, paths []string, limit int) ([]entity.Pipeline, error)

LoadAllPipelines loads pipelines for all projects via the pipeline repository.

func (s *PipelineService) LoadProjects(ctx context.Context, paths []string) ([]entity.Project, error)

func (s *PipelineService) SearchProjects(ctx context.Context, query string) ([]entity.Project, error)