runtime

type NodeFactory ¶

type NodeFactory interface {
	New(nuggit.Node) (any, error)
}

type Runner ¶

type Runner interface {
	Run(ctx context.Context) (any, error)
}

type StageCoordinator ¶

type StageCoordinator struct {
	context.Context
}

type StageRunner ¶

type StageRunner struct {
	NodeFactory NodeFactory
	Overrides   []map[string]any
	Coord       *StageCoordinator
	Graphs      []*graphs.Graph
	Results     []map[nuggit.NodeKey]json.RawMessage
	// contains filtered or unexported fields
}

StageRunner executes all the graphs in the current stage concurrently. Multiple graphs in a given stage are executed in parallel while Node-level paralelism is limited by MaxWorkers.

The StageCoordinator is used when the runner must exchange data outside the stage.

The zero StageRunner is ready to use.

TODO(wes): Implement the coordinator.

func (r *StageRunner) Run(ctx context.Context) error

type Validator ¶

type Validator interface {
	Validate() error
}

type VarBinder ¶

type VarBinder interface {
	Bind(data json.RawMessage, val any) (json.RawMessage, error)
}