service

package

v0.3.1 Latest Latest Go to latest Published: Feb 26, 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 PipelineService struct {
	// contains filtered or unexported fields
}

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

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)