executor

Documentation

Index

• type BlueprintLookup
• type FKBinding
• type InsertFunc
• type LogEntry
• type NodeResult
• type Result
  • func Execute(ctx context.Context, db any, g *graph.Graph, lookup BlueprintLookup, ...) (*Result, error)

Types

type BlueprintLookup

type BlueprintLookup interface {
	LookupByName(name string) (*planner.BlueprintDef, error)
}

BlueprintLookup resolves blueprint definitions by name.

type FKBinding

type FKBinding struct {
	ChildField      string
	ParentBlueprint string
	ParentTable     string
	ParentField     string
	Value           any
}

FKBinding describes a single FK assignment made before an insert.

type InsertFunc

type InsertFunc = func(ctx context.Context, db, v any) (any, error)

InsertFunc is the type-erased insert function stored in BlueprintDef.

type LogEntry

type LogEntry struct {
	Step       int
	Blueprint  string
	Table      string
	Provided   bool
	FKBindings []FKBinding
}

LogEntry holds information about a single insert operation.

type NodeResult

type NodeResult struct {
	Name  string
	Value any
}

NodeResult holds the result of a single inserted node.

type Result

type Result struct {
	Root  any
	Nodes map[string]NodeResult
	Graph *graph.Graph
}

Result holds the inserted nodes after execution.

func Execute

func Execute(ctx context.Context, db any, g *graph.Graph, lookup BlueprintLookup, logFn func(LogEntry)) (*Result, error)

Execute inserts all nodes in topological order, assigning parent PKs to child FKs. If logFn is non-nil, it is called for each step in the execution order.