scheduler

package

v0.82.2 Latest Latest Go to latest Published: Feb 25, 2026 License: MIT Imports: 6 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type Graph[T analyzer.BaseAnalyzer] struct {
	// contains filtered or unexported fields
}

Graph stores analyzers and their execution layers in dependency order.

func New[T analyzer.BaseAnalyzer](analyzers []T) (*Graph[T], error)

New validates analyzers and creates a dependency graph.

func (g *Graph[T]) Levels() [][]string

Levels returns analyzer IDs grouped by dependency level.

func (g *Graph[T]) Run(ctx context.Context, run RunFunc[T]) error

Run executes analyzers in dependency order and in parallel per level.

Execution is best-effort:

type RunFunc[T analyzer.BaseAnalyzer] func(ctx context.Context, analyzer T) error

RunFunc is invoked for each analyzer when Graph.Run executes.