executor

type Checkpoint struct {
	GraphName string               `json:"graph_name"`
	RunID     string               `json:"run_id,omitempty"`
	NodeID    string               `json:"node_id"`
	Iteration int                  `json:"iteration"`
	Board     *graph.BoardSnapshot `json:"board"`
	Timestamp time.Time            `json:"timestamp"`
}

type CheckpointCleaner interface {
	Cleanup(opts CleanupOptions) (deleted int, err error)
}

type CheckpointManager interface {
	CheckpointStore
	List() ([]string, error)
	Delete(graphName string) error
}

type CheckpointStore interface {
	Save(cp Checkpoint) error
	// Load retrieves the latest checkpoint. When runID is non-empty, only
	// checkpoints for that specific run are considered.
	Load(graphName, runID string) (*Checkpoint, error)
}

type CleanupOptions struct {
	MaxAge   time.Duration
	MaxCount int
}

type CloneableResolver interface {
	VariableResolver
	Clone() *variable.Resolver
}

type FileCheckpointConfig struct {
	Dir            string
	MaxCheckpoints int
}

type FileCheckpointStore struct {
	// contains filtered or unexported fields
}

type LocalExecutor struct{}

type MergeFunc func(board *graph.Board, snapshot *graph.BoardSnapshot, results []branchResult) error

type MergeStrategy string

type ParallelConfig struct {
	Enabled       bool          `json:"enabled"`
	MaxBranches   int           `json:"max_branches"`
	MaxNesting    int           `json:"max_nesting"`
	MergeStrategy MergeStrategy `json:"merge_strategy"`
}

type RunOption func(*runConfig)

type VariableResolver interface {
	ResolveMap(m map[string]any) (map[string]any, error)
	AddScope(name string, vars map[string]any)
}