Method Start

src/go/plugin/framework/jobruntime/job_v1.go:315–346

Start starts job main loop.

()

// Start starts job main loop.
func (j *Job) Start() {
	j.stopCtrl.markStarted()
	j.running.Store(true)
	if j.functionOnly {
		j.Info("started in function-only mode")
	} else {
		j.Infof("started, data collection interval %ds", j.updateEvery)
	}
	defer func() {
		j.running.Store(false)
		j.stopCtrl.markStopped()
		j.Info("stopped")
	}()

LOOP:
	for {
		select {
		case <-j.stopCtrl.stopCh:
			break LOOP
		case t := <-j.tick:
			if !j.functionOnly && j.shouldCollect(t) {
				markRunStartWithResumeLog(&j.skipTracker, j.Logger)

				j.runOnce()

				j.skipTracker.MarkRunStop(time.Now())
			}
		}
	}
	j.module.Cleanup(context.TODO())
	j.Cleanup()
}

// Stop stops job main loop. It blocks until the job is stopped.
func (j *Job) Stop() {