atc/db/job.go

123 type job struct {  struct
124 	pipelineRef
126 	id                    int
127 	name                  string
128 	paused                bool
129 	public                bool
130 	firstLoggedBuildID    int
131 	teamID                int
132 	teamName              string
133 	tags                  []string
134 	hasNewInputs          bool
135 	scheduleRequestedTime time.Time
136 	maxInFlight           int
137 	disableManualTrigger  bool
139 	config    *atc.JobConfig
140 	rawConfig *string
141 	nonce     *string
148 func (j *job) SetHasNewInputs(hasNewInputs bool) error {
187 func (j *job) ID() int                          { return j.id }
188 func (j *job) Name() string                     { return j.name }
189 func (j *job) Paused() bool                     { return j.paused }
190 func (j *job) Public() bool                     { return j.public }
191 func (j *job) FirstLoggedBuildID() int          { return j.firstLoggedBuildID }
192 func (j *job) TeamID() int                      { return j.teamID }
193 func (j *job) TeamName() string                 { return j.teamName }
194 func (j *job) Tags() []string                   { return j.tags }
195 func (j *job) HasNewInputs() bool               { return j.hasNewInputs }
196 func (j *job) ScheduleRequestedTime() time.Time { return j.scheduleRequestedTime }
197 func (j *job) MaxInFlight() int                 { return j.maxInFlight }
198 func (j *job) DisableManualTrigger() bool       { return j.disableManualTrigger }
200 func (j *job) Config() (atc.JobConfig, error) {
226 func (j *job) AlgorithmInputs() (InputConfigs, error) {
299 func (j *job) Inputs() ([]atc.JobInput, error) {
358 func (j *job) Outputs() ([]atc.JobOutput, error) {
389 func (j *job) Reload() (bool, error) {
405 func (j *job) Pause() error {
409 func (j *job) Unpause() error {
413 func (j *job) FinishedAndNextBuild() (Build, Build, error) {
449 func (j *job) UpdateFirstLoggedBuildID(newFirstLoggedBuildID int) error {
479 func (j *job) BuildsWithTime(page Page) ([]Build, Pagination, error) {
490 func (j *job) Builds(page Page) ([]Build, Pagination, error) {
502 func (j *job) Build(name string) (Build, bool, error) {
532 func (j *job) ScheduleBuild(build Build) (bool, error) {
609 func (j *job) GetFullNextBuildInputs() ([]BuildInput, bool, error) {
647 func (j *job) GetNextBuildInputs() ([]BuildInput, error) {
668 func (j *job) EnsurePendingBuildExists(ctx context.Context) error {
733 func (j *job) GetPendingBuilds() ([]Build, error) {
775 func (j *job) CreateBuild() (Build, error) {
824 func (j *job) RerunBuild(buildToRerun Build) (Build, error) {
839 func (j *job) tryRerunBuild(buildToRerun Build) (Build, error) {
894 func (j *job) ClearTaskCache(stepName string, cachePath string) (int64, error) {
929 func (j *job) AcquireSchedulingLock(logger lager.Logger) (lock.Lock, bool, error) {
939 func (j *job) isMaxInFlightReached(tx Tx, buildID int) (bool, error) {
974 func (j *job) getSerialGroups(tx Tx) ([]string, error) {
1000 func (j *job) RequestSchedule() error {
1016 func (j *job) UpdateLastScheduled(requestedTime time.Time) error {
1028 func (j *job) getRunningBuildsBySerialGroup(tx Tx, serialGroups []string) ([]Build, error) {
1059 func (j *job) getNextPendingBuildBySerialGroup(tx Tx, serialGroups []string) (Build, bool, error) {
1090 func (j *job) updatePausedJob(pause bool) error {
1119 func (j *job) getNewBuildName(tx Tx) (string, error) {
1135 func (j *job) SaveNextInputMapping(inputMapping InputMapping, inputsDetermined bool) error {
1218 func (j *job) nextBuild(tx Tx) (Build, error) {
1238 func (j *job) finishedBuild(tx Tx) (Build, error) {
1258 func (j *job) getNewRerunBuildName(tx Tx, buildID int) (string, int, error) {
1279 func (j *job) getNextBuildInputs(tx Tx) ([]BuildInput, error) {
1356 func (j *job) isPipelineOrJobPaused(tx Tx) (bool, error) {
1375 func scanJob(j *job, row scannable) error {