looprunner

type LoopConfig struct {
	MaxIterations int                 `json:"max_iterations"`
	RosterFile    string              `json:"roster_file,omitempty"`
	Pre           []phaseconfig.Phase `json:"pre"`
	Loop          []phaseconfig.Phase `json:"loop"`
	Post          []phaseconfig.Phase `json:"post"`
}

type NestedResult struct {
	ExitCode   int
	StopReason string
	SessionID  string
	Reason     string
}

type PhaseAttemptResult struct {
	ExitCode      int
	SessionID     string
	StopReason    string
	LoopDirective string
	LoopLabel     string
	BrokerRunID   string
}

type RunOptions struct {
	WorkDir      string
	RunID        string
	EventSink    phaseconfig.EventWriter
	Config       *LoopConfig
	MaxRetries   int
	Broker       *broker.Broker
	SeedMessage  *broker.AgentMessage // pushed to the attempt's brokerRunID after creation
	PhaseAttempt func(ctx context.Context, phase phaseconfig.Phase, attemptNum int, iteration int, prevSessionID string) (PhaseAttemptResult, error)
	NestedRun    func(ctx context.Context, configPath string, runType string) (NestedResult, error)
	ConfigDir    string
	Roster       *rosterconfig.Config
}

type RunResult struct {
	ExitCode   int
	StopReason string
	SessionID  string
	Reason     string
}