exec

type AgenticExecutor func(context.Context, Step, json.RawMessage) (AgenticResult, error)

type AgenticResult struct {
	Content          any
	Action           *tool.ActionReceipt
	ToolCalls        int
	ModelCalls       int
	PromptTokens     int
	CompletionTokens int
	TotalTokens      int
	PendingArguments json.RawMessage
}

type Approval struct {
	ToolID    string
	Arguments json.RawMessage
}

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

type Batch struct {
	Index int
	Steps []Step
}

type Binding = plan.InputBinding

type DeadlinePolicy struct {
	TargetLatency  time.Duration
	HardTimeout    time.Duration
	OptionalCutoff time.Duration
}

type Deterministic struct{}

type ExecutionPlan struct {
	Steps        []Step
	Batches      []Batch
	CriticalPath []string
}

type InputResolver func(Step) json.RawMessage

type Request struct {
	Input    string
	Step     any
	Tool     model.ToolSpec
	Evidence map[string]any
}

type Resolver interface {
	Resolve(context.Context, Request) (json.RawMessage, error)
}

type Scheduler struct {
	Registry    *tool.Registry
	MaxParallel int
	Policy      policy.Runner
	Guard       func(context.Context, tool.Tool) error
	// Confirm is called before a tool that declares a confirmation policy is
	// executed. Returning false produces a confirmation-required receipt and
	// leaves the external system untouched.
	Confirm  func(context.Context, tool.Spec, json.RawMessage) (bool, error)
	Deadline DeadlinePolicy
	Barrier  *Barrier
	Observe  func(policy.Event)
	// Completed replays successful checkpointed steps without executing them.
	Completed map[string]StepResult
	// Approvals bind resume authorization to an exact step, tool and arguments.
	Approvals map[string]Approval
	Agentic   AgenticExecutor
}

type Step struct {
	ID              string
	Kind            plan.StepKind
	Importance      plan.StepImportance
	Title           string
	Description     string
	Capability      string
	DependsOn       []string
	Optional        bool
	Input           map[string]any
	Bindings        []plan.InputBinding
	Condition       *plan.Condition
	Mode            plan.StepMode
	Goal            string
	SuccessCriteria string
	Capabilities    []string
	ToolBudget      plan.ToolCallBudget
	ApprovedToolID  string
	ApprovedInput   []byte
}

type StepResult struct {
	StepID              string
	RequestedCapability string
	Capability          string
	ToolID              string
	Content             any
	Receipt             bool
	Action              *tool.ActionReceipt
	Err                 error
	Duration            time.Duration
	Attempts            int
	Fallbacks           int
	Skipped             bool
	ConditionUnknown    bool
	Input               json.RawMessage
	ModelCalls          int
	PromptTokens        int
	CompletionTokens    int
	TotalTokens         int
}