flow

type ApprovalGate interface {
	Check(ctx context.Context, actionName, argsJSON, token string) error
}

type BranchMode string

type CapabilitySpec struct {
	Name         string         `json:"name"`
	Description  string         `json:"description"`
	Route        string         `json:"route,omitempty"`
	Method       string         `json:"method,omitempty"`
	InputSchema  map[string]any `json:"input_schema"`
	OutputSchema map[string]any `json:"output_schema"`
	Tags         []string       `json:"tags,omitempty"`
	IsSystem     bool           `json:"is_system"`
}

type CompiledEdge struct {
	From      string
	To        string
	When      string
	Otherwise bool
	Priority  int
}

type CompiledGraph struct {
	Definition GraphDefinition
	Layers     [][]string
	NodeByID   map[string]NodeSpec
	Edges      []CompiledEdge
	Outgoing   map[string][]CompiledEdge
	EdgeKeys   []string
}

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

type DynamicPolicy struct {
	RetryCount  int
	Timeout     time.Duration
	CacheTTL    time.Duration
	Idempotent  bool
	Breaker     bool
	Debug       bool
	Validate    bool
	Coalesce    bool
	Dedup       bool
	HTTPMethod  string
	HTTPPath    string
	StatusCode  int
	CLICommand  string
	CLIDesc     string
	A2ARole     string
	CustomName  string
	Description string
}

type EdgeSpec struct {
	From      string `json:"from" yaml:"from"`
	To        string `json:"to" yaml:"to"`
	When      string `json:"when,omitempty" yaml:"when,omitempty"`
	Otherwise bool   `json:"otherwise,omitempty" yaml:"otherwise,omitempty"`
	Priority  int    `json:"priority,omitempty" yaml:"priority,omitempty"`
}

type EffectClass string

type FanInPolicy struct {
	RequireAll   bool
	AllowPartial bool
	FailOnEmpty  bool
}

type GraphDefinition struct {
	APIVersion string      `json:"apiVersion" yaml:"apiVersion"`
	Kind       string      `json:"kind" yaml:"kind"`
	Metadata   Metadata    `json:"metadata" yaml:"metadata"`
	Policy     GraphPolicy `json:"policy,omitempty" yaml:"policy,omitempty"`
	Nodes      []NodeSpec  `json:"nodes" yaml:"nodes"`
	Edges      []EdgeSpec  `json:"edges" yaml:"edges"`
}

type GraphExecReq struct {
	DSL            string         `json:"dsl,omitempty" cli:"dsl,d" usage:"Compact arrow pipeline expression"`
	YAML           string         `json:"yaml,omitempty" cli:"yaml,y" usage:"Declarative YAML graph manifest"`
	InitialPayload map[string]any `json:"initial_payload,omitempty" usage:"Initial state values passed to root nodes"`
}

type GraphExecRes struct {
	GraphName  string         `json:"graph_name"`
	Outputs    map[string]any `json:"outputs"`
	LayersRun  int            `json:"layers_run"`
	DurationMS int64          `json:"duration_ms"`
}

type GraphPolicy struct {
	MaxParallelNodes    int            `json:"max_parallel_nodes,omitempty" yaml:"max_parallel_nodes,omitempty"`
	MaxContextBytes     int64          `json:"max_context_bytes,omitempty" yaml:"max_context_bytes,omitempty"`
	BudgetMicros        int64          `json:"budget_micros,omitempty" yaml:"budget_micros,omitempty"`
	ApprovalRequiredFor []EffectClass  `json:"approval_required_for,omitempty" yaml:"approval_required_for,omitempty"`
	FanInRecovery       RecoveryPolicy `json:"fan_in_recovery,omitempty" yaml:"fan_in_recovery,omitempty"`
}

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

type Metadata struct {
	Name        string `json:"name" yaml:"name"`
	Version     string `json:"version" yaml:"version"`
	Description string `json:"description,omitempty" yaml:"description,omitempty"`
}

type NodeKind string

type NodeResult[Res any] struct {
	Spawned SpawnedNode `json:"spawned"`
	Value   Res         `json:"value"`
	Err     error       `json:"error,omitempty"`
}

type NodeSpec struct {
	ID             string            `json:"id" yaml:"id"`
	Kind           NodeKind          `json:"kind" yaml:"kind"`
	Capability     string            `json:"capability" yaml:"capability"`
	Params         map[string]any    `json:"params,omitempty" yaml:"params,omitempty"`
	InputBindings  map[string]string `json:"inputs,omitempty" yaml:"inputs,omitempty"`
	InputSchema    string            `json:"input_schema,omitempty" yaml:"input_schema,omitempty"`
	OutputSchema   string            `json:"output_schema,omitempty" yaml:"output_schema,omitempty"`
	Prompt         string            `json:"prompt,omitempty" yaml:"prompt,omitempty"`
	Retry          RetryPolicy       `json:"retry,omitempty" yaml:"retry,omitempty"`
	TimeoutMS      int64             `json:"timeout_ms,omitempty" yaml:"timeout_ms,omitempty"`
	MaxAttempts    int               `json:"max_attempts,omitempty" yaml:"max_attempts,omitempty"`
	EstimateMicros int64             `json:"estimate_micros,omitempty" yaml:"estimate_micros,omitempty"`
	Effect         EffectClass       `json:"effect,omitempty" yaml:"effect,omitempty"`
	Approval       bool              `json:"approval_required,omitempty" yaml:"approval_required,omitempty"`
	BranchMode     BranchMode        `json:"branch_mode,omitempty" yaml:"branch_mode,omitempty"`
}

type RecoveryPolicy struct {
	Strategy           RecoveryStrategy `json:"strategy,omitempty" yaml:"strategy,omitempty"`
	MaxAttempts        int              `json:"max_attempts,omitempty" yaml:"max_attempts,omitempty"`
	BackoffMS          int64            `json:"backoff_ms,omitempty" yaml:"backoff_ms,omitempty"`
	MaxBackoffMS       int64            `json:"max_backoff_ms,omitempty" yaml:"max_backoff_ms,omitempty"`
	RetryTransientOnly bool             `json:"retry_transient_only,omitempty" yaml:"retry_transient_only,omitempty"`
}

type RecoveryStrategy string

type Registry interface {
	Get(name string) (action.AnyAction, bool)
	Actions() []action.AnyAction
}

type RetryPolicy struct {
	MaxAttempts int    `json:"max_attempts,omitempty" yaml:"max_attempts,omitempty"`
	Backoff     string `json:"backoff,omitempty" yaml:"backoff,omitempty"`
}

type SpawnedNode struct {
	RunID      string       `json:"run_id"`
	SourceNode string       `json:"source_node"`
	Edge       CompiledEdge `json:"edge"`
	TargetNode string       `json:"target_node"`
	Input      *State       `json:"input"`
	SpawnIndex int          `json:"spawn_index"`
}

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

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

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

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