Documentation
¶
Index ¶
- type Service
- func (service *Service) CreateArchiveUpgrade(userID uint, packageCount uint) (*models.ArchiveUpgrade, error)
- func (service *Service) CreateArchiveUpgradeRepositoryJob(archiveUpgradeID uint) (*models.Job, error)
- func (service *Service) CreateAutopkgtestJobFromBuildJob(buildJob *models.Job) (*models.Job, error)
- func (service *Service) CreateBuildUploadJob(uploadID uint) (*models.Job, error)
- func (service *Service) CreateForwardJob(uploadID uint) (*models.Job, error)
- func (service *Service) CreateJob(jobType models.JobType, input string, buildJobID uint, ...) (*models.Job, error)
- func (service *Service) GetAllArchiveUpgrades() ([]*models.ArchiveUpgrade, error)
- func (service *Service) GetAllArchiveUpgradesByUserID(userID uint) ([]*models.ArchiveUpgrade, error)
- func (service *Service) GetAllArchiveUpgradesPageLimit(page, limit int) ([]*models.ArchiveUpgrade, error)
- func (service *Service) GetAllFailedJobsByUploadID(uploadID uint) ([]*models.Job, error)
- func (service *Service) GetAllJobs() ([]*models.Job, error)
- func (service *Service) GetAllJobsByArchiveUpgradeID(id uint) ([]*models.Job, error)
- func (service *Service) GetAllJobsByArchiveUpgradeIDPageLimit(id uint, page, limit int) ([]*models.Job, error)
- func (service *Service) GetAllJobsByUploadID(uploadID uint) ([]*models.Job, error)
- func (service *Service) GetAllJobsPageLimit(page, limit int) ([]*models.Job, error)
- func (service *Service) GetAllUncompletedJobsByArchiveUpgradeID(archiveRebuildID uint) ([]*models.Job, error)
- func (service *Service) GetAllUncompletedJobsByUploadID(uploadID uint) ([]*models.Job, error)
- func (service *Service) GetArchiveUpgrade(id uint) (*models.ArchiveUpgrade, error)
- func (service *Service) GetJob(id uint) (*models.Job, error)
- func (service *Service) GetJobLog(jobID uint) (io.ReadCloser, error)
- func (service *Service) ProcessJobStatus(jobID uint, status models.JobStatus) error
- func (service *Service) SaveJobLog(jobID uint, content io.Reader) error
- func (service *Service) UnqueueNextJob() (*models.Job, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service manages jobs
func (*Service) CreateArchiveUpgrade ¶ added in v0.11.0
func (service *Service) CreateArchiveUpgrade(userID uint, packageCount uint) (*models.ArchiveUpgrade, error)
CreateArchiveUpgrade creates a new ArchiveUpgrade
func (*Service) CreateArchiveUpgradeRepositoryJob ¶ added in v0.12.0
func (service *Service) CreateArchiveUpgradeRepositoryJob(archiveUpgradeID uint) (*models.Job, error)
CreateArchiveUpgradeRepositoryJob creates a CreateArchiveUpgradeRepository job
func (*Service) CreateAutopkgtestJobFromBuildJob ¶ added in v0.12.0
CreateAutopkgtestJobFromBuildJob creates an autopkgtest job from the build job
func (*Service) CreateBuildUploadJob ¶ added in v0.12.0
CreateBuildUploadJob creates a build job
func (*Service) CreateForwardJob ¶ added in v0.10.0
CreateForwardJob creates an upload forward job
func (*Service) CreateJob ¶ added in v0.11.0
func (service *Service) CreateJob(jobType models.JobType, input string, buildJobID uint, parentType models.JobParentType, parentID uint) (*models.Job, error)
CreateJob creates a new job
func (*Service) GetAllArchiveUpgrades ¶ added in v0.11.0
func (service *Service) GetAllArchiveUpgrades() ([]*models.ArchiveUpgrade, error)
GetAllArchiveUpgrades returns all ArchiveUpgrades
func (*Service) GetAllArchiveUpgradesByUserID ¶ added in v0.11.0
func (service *Service) GetAllArchiveUpgradesByUserID(userID uint) ([]*models.ArchiveUpgrade, error)
GetAllArchiveUpgradesByUserID returns all ArchiveUpgrades for a User ID
func (*Service) GetAllArchiveUpgradesPageLimit ¶ added in v0.12.0
func (service *Service) GetAllArchiveUpgradesPageLimit(page, limit int) ([]*models.ArchiveUpgrade, error)
GetAllArchiveUpgradesPageLimit returns all ArchiveUpgrades with pagination
func (*Service) GetAllFailedJobsByUploadID ¶ added in v0.10.0
GetAllFailedJobsByUploadID returns all failed jobs for a given upload
func (*Service) GetAllJobs ¶
GetAllJobs returns all jobs
func (*Service) GetAllJobsByArchiveUpgradeID ¶ added in v0.11.0
GetAllJobsByArchiveUpgradeID returns all jobs for an ArchiveUpgrade
func (*Service) GetAllJobsByArchiveUpgradeIDPageLimit ¶ added in v0.12.0
func (service *Service) GetAllJobsByArchiveUpgradeIDPageLimit(id uint, page, limit int) ([]*models.Job, error)
GetAllJobsByArchiveUpgradeIDPageLimit returns all jobs for an ArchiveUpgrade
func (*Service) GetAllJobsByUploadID ¶ added in v0.8.0
GetAllJobsByUploadID returns all jobs for a given upload
func (*Service) GetAllJobsPageLimit ¶ added in v0.12.0
GetAllJobsPageLimit returns all jobs with pagination
func (*Service) GetAllUncompletedJobsByArchiveUpgradeID ¶ added in v0.12.0
func (service *Service) GetAllUncompletedJobsByArchiveUpgradeID(archiveRebuildID uint) ([]*models.Job, error)
GetAllUncompletedJobsByArchiveUpgradeID returns all uncompleted jobs for a given archive rebuild
func (*Service) GetAllUncompletedJobsByUploadID ¶ added in v0.10.0
GetAllUncompletedJobsByUploadID returns all uncompleted jobs for a given upload
func (*Service) GetArchiveUpgrade ¶ added in v0.11.0
func (service *Service) GetArchiveUpgrade(id uint) (*models.ArchiveUpgrade, error)
GetArchiveUpgrade returns the ArchiveUpgrade with a matching ID
func (*Service) GetJobLog ¶
func (service *Service) GetJobLog(jobID uint) (io.ReadCloser, error)
GetJobLog returns the log of a job
func (*Service) ProcessJobStatus ¶ added in v0.10.0
ProcessJobStatus will change the status of a job and proceed with creating the follow-up jobs depending on the related upload configuration
func (*Service) SaveJobLog ¶
SaveJobLog will save logs for a job
Source Files