orchestrator

type Observer interface {
	// OnExpand 报告展开后的总步数与清单；startIndex 为本次实际开跑的起始下标（Run 恒为 0，Resume 为
	// trace 推断出的重入点），供人类进度区分「整趟展开」与「从中断处恢复、共剩几步」，避免把 resume
	// 误显为整趟 N 步。
	OnExpand(steps []workflow.ExecutionStep, startIndex int)
	OnStepStart(info StepInfo)       // 某步开跑前
	OnStepDone(entry run.TraceEntry) // 某步落定（成功或失败），trace 已落盘
}

type Orchestrator struct {
	Store   *store.Store
	Engines func(name string) (engine.Engine, error)
	Now     func() time.Time
}

type StepInfo struct {
	StepIndex   int
	Type        string // agent | evaluator
	NodeID      string
	DisplayName string
	Iteration   int
	Engine      string
	Model       string // 解析后的模型；空串＝用引擎默认
}