Method preparePlan

src/go/plugin/framework/chartengine/planner.go:119–254

(reader metrix.Reader)

}

func (e *Engine) preparePlan(reader metrix.Reader) (Plan, materializedState, uint64, uint64, uint64, bool, error) {
	if e == nil {
		return Plan{}, materializedState{}, 0, 0, 0, false, fmt.Errorf("chartengine: nil engine")
	}
	if reader == nil {
		return Plan{}, materializedState{}, 0, 0, 0, false, fmt.Errorf("chartengine: nil metrics reader")
	}
	sample := planRuntimeSample{startedAt: time.Now()}
	defer func() { e.observeBuildSample(sample) }()

	out := Plan{
		Actions:            make([]EngineAction, 0),
		InferredDimensions: make([]InferredDimension, 0),
	}
	collectMeta := reader.CollectMeta()

	e.mu.Lock()
	defer e.mu.Unlock()
	if e.state.outstanding != 0 {
		return Plan{}, materializedState{}, 0, 0, 0, false, ErrOutstandingPlanAttempt
	}
	// Failed attempt must not trigger lifecycle transitions.
	if collectMeta.LastAttemptStatus != metrix.CollectStatusSuccess {
		sample.skippedFailed = true
		e.logDebugf("chartengine build skipped: collect status=%d", collectMeta.LastAttemptStatus)
		return out, materializedState{}, 0, 0, 0, false, nil
	}

	obs := e.observeBuildSuccessSeq(collectMeta.LastSuccessSeq)
	buildCycle := e.nextBuildCycle(collectMeta.LastSuccessSeq)
	sample.buildSeqViolation = e.state.buildSeq.violating
	sample.buildSeqObserved = true
	switch obs.transition {
	case buildSeqTransitionBroken:
		sample.buildSeqBroken = true
		e.logWarningf(
			"chartengine build sequence is non-monotonic: current=%d previous=%d (suppressing repeats until recovery)",
			collectMeta.LastSuccessSeq,
			obs.previous,
		)
	case buildSeqTransitionRecovered:
		sample.buildSeqRecovered = true
		e.logInfof(
			"chartengine build sequence monotonicity recovered: current=%d previous=%d",
			collectMeta.LastSuccessSeq,
			obs.previous,
		)
	}

	phaseStartedAt := time.Now()
	staged := e.state.materialized.clone()
	ctx, err := e.preparePlanBuildContext(reader, &out, collectMeta, buildCycle, &staged)
	sample.phasePrepareSeconds = time.Since(phaseStartedAt).Seconds()
	if err != nil {
		sample.buildErr = true
		e.logWarningf("chartengine build prepare failed: %v", err)
		return Plan{}, materializedState{}, 0, 0, 0, false, err
	}