flow

type Budget struct {
	Deadline  time.Duration
	HopBudget int
	CostCap   float64
}

type BudgetExceededPayload struct {
	events.SafeSealed
	FlowName string
	Axis     string
}

type ComposeOption func(*composeConfig)

type Definition struct {
	Name        string
	Description string
	Entry       NodeID
	Exit        NodeID
	Nodes       map[NodeID]NodeSpec
	Budget      Budget
	InSchema    json.RawMessage
	OutSchema   json.RawMessage
}

type Metadata struct {
	// Owner is the agent / team that registered the flow. May be empty.
	Owner string
	// Version is the flow's version string. May be empty.
	Version string
	// PlannerFamily is the graph-family planner the flow runs on —
	// "graph" / "workflow" / "deterministic". Empty defaults to "graph".
	PlannerFamily string
	// Source is the source-of-truth reference — a Go path or a YAML
	// descriptor path (D-023: Go-coded V1; YAML V1.1). A string
	// reference, never executable code.
	Source string
}

type NodeID string

type NodeRunRecord struct {
	// NodeID is the node's identifier within the flow.
	NodeID string
	// Status is the node's outcome within the run.
	Status string
	// Duration is the node's wall-clock duration.
	Duration time.Duration
	// Retries is the number of times the node was retried.
	Retries int
	// ErrorClass is a short classification of a node failure.
	ErrorClass string
}

type NodeSpec struct {
	Name   string
	Func   engine.NodeFunc
	Policy engine.NodePolicy
	To     []NodeID
}

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

type RunRecord struct {
	// RunID is the run's stable identifier.
	RunID string
	// FlowName is the registered flow this run executed.
	FlowName string
	// Identity is the (tenant, user, session) the run executed under.
	Identity identity.Identity
	// Trigger is what initiated the run — "user" / "planner" / "system".
	Trigger string
	// Status is the run's outcome — "running" / "succeeded" / "failed"
	// / "cancelled".
	Status string
	// StartedAt is the wall-clock time the run started.
	StartedAt time.Time
	// Duration is the run's wall-clock duration. Zero for an in-flight
	// run.
	Duration time.Duration
	// CostUSD is the run's recorded cost.
	CostUSD float64
	// ErrorClass is a short classification of a failure. Empty for a
	// non-failed run.
	ErrorClass string
	// NodeStates is the run's per-node execution timeline.
	NodeStates []NodeRunRecord
	// Output is the run's final output preview (post-redaction). The
	// Catalog applies the D-026 heavy-content bypass before shipping it.
	Output string
}