planner

package

v1.7.0 Latest Latest Go to latest Published: May 1, 2026 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CompositionInfo struct {
	Type       string
	DefaultJob *model.JobSpec
}

CompositionInfo holds the default job for a composition

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

JobGraph represents the DAG of job instances with cycle detection and topological sorting

func NewJobGraph(jobs map[string]*model.JobInstance) *JobGraph

NewJobGraph creates a new job graph from job instances

func (g *JobGraph) DetectCycles() error

DetectCycles performs cycle detection on the job dependency graph using DFS

func (g *JobGraph) TopologicalSort() ([]string, error)

TopologicalSort performs topological sorting of jobs using Kahn's algorithm Returns sorted job IDs in execution order

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

JobPlanner binds components to jobs and creates instances

func NewJobPlanner(compositions map[string]*CompositionInfo) *JobPlanner

NewJobPlanner creates a new job planner from a composition registry

func (jp *JobPlanner) PlanJobs(instances map[string][]*model.ComponentInstance) (map[string]*model.JobInstance, error)

PlanJobs creates job instances from component instances