flow

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

type BranchJournal = journal.BranchJournal

type BranchMode string

type BranchRecord = journal.BranchRecord

type BranchStatus = journal.BranchStatus

type BudgetCheck = governance.BudgetCheck

type BudgetPolicy struct {
	MaxCostUSD          *float64 `json:"max_cost_usd,omitempty" yaml:"max_cost_usd,omitempty"`
	MaxCostUSDPerRun    *float64 `json:"max_cost_usd_per_run,omitempty" yaml:"max_cost_usd_per_run,omitempty"`
	MaxCostUSDPerDay    *float64 `json:"max_cost_usd_per_day,omitempty" yaml:"max_cost_usd_per_day,omitempty"`
	MaxCostUSDPerMonth  *float64 `json:"max_cost_usd_per_month,omitempty" yaml:"max_cost_usd_per_month,omitempty"`
	MaxCostUSDPerTenant *float64 `json:"max_cost_usd_per_tenant,omitempty" yaml:"max_cost_usd_per_tenant,omitempty"`
}

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 ChildResult = nodes.ChildResult

type ChildTask = nodes.ChildTask

type CompiledBudget struct {
	MaxCostMicrosPerRun    int64
	MaxCostMicrosPerDay    int64
	MaxCostMicrosPerMonth  int64
	MaxCostMicrosPerTenant int64
}

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

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

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

type CostEvent = governance.CostEvent

type CostLedger = governance.CostLedger

type CostReporter interface {
	CostMicros() int64
}

type CostUsage = governance.CostUsage

type DynamicPolicy struct {
	RetryCount int
	Timeout    time.Duration
	Idempotent bool
	Breaker    bool
}

type EdgeEventSlot struct {
	Seq        uint64
	LatencyNs  int64
	StatusCode uint16

	EdgeID [16]byte
	// contains filtered or unexported fields
}

type EdgeNodeReq struct {
	Region  LocationRegion `json:"region"`
	Payload map[string]any `json:"payload"`
}

type EdgeNodeRes struct {
	Region     LocationRegion `json:"region"`
	NodeID     string         `json:"node_id"`
	LatencyMs  int64          `json:"latency_ms"`
	Data       map[string]any `json:"data"`
	StatusCode uint16         `json:"status_code"`
}

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"`
	Budget    BudgetPolicy `json:"budget,omitempty" yaml:"budget,omitempty"`
}

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

type EffectClass string

type EventSlot = telemetry.EventSlot

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 {
	Budget              BudgetPolicy   `json:"budget,omitempty" yaml:"budget,omitempty"`
	MaxParallelNodes    int            `json:"max_parallel_nodes,omitempty" yaml:"max_parallel_nodes,omitempty"`
	MaxContextBytes     int64          `json:"max_context_bytes,omitempty" yaml:"max_context_bytes,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 HotPathExecutor = telemetry.HotPathExecutor

type LocationRegion string

type LockFreeRingBuffer = telemetry.LockFreeRingBuffer

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

type MemoryBranchJournal = journal.MemoryBranchJournal

type MemoryCostLedger = governance.MemoryCostLedger

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"`
	Usage   CostUsage   `json:"usage"`
}

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"`
	EstimatedCostMicros int64             `json:"estimated_cost_micros,omitempty" yaml:"estimated_cost_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 PromptConfig = nodes.PromptConfig

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 SQLBranchJournal = journal.SQLBranchJournal

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 SupervisorReq = nodes.SupervisorReq

type SupervisorRes = nodes.SupervisorRes