delegation

type ApprovedQuestionDecision struct {
	Matched      bool   `json:"matched"`
	PolicySHA256 string `json:"policy_sha256,omitempty"`
}

type ApprovedQuestionSet struct {
	ReadOnly          bool              `json:"read_only"`
	Revision          string            `json:"revision"`
	Intent            string            `json:"intent"`
	Bindings          map[string]string `json:"bindings,omitempty"`
	CanonicalQuestion string            `json:"canonical_question"`
	Forms             []string          `json:"forms"`
}

type Attempt struct {
	BudgetDiagnostic *inference.BudgetDiagnostic `json:"budget_diagnostic,omitempty"`
	TierID           string                      `json:"tier_id"`
	Result           inference.Result            `json:"result"` // Response.Text is always stripped.
	Checks           []evaluation.CheckResult    `json:"checks"`
	QualityPassed    bool                        `json:"quality_passed"`
	OutputSHA256     string                      `json:"output_sha256,omitempty"`
	ErrorCategory    string                      `json:"error_category,omitempty"`
}

type ControlledReuser struct {
	Broker          inference.Broker
	Index           semantic.Index
	EmbedderFactory func(context.Context, semantic.Config) (semantic.Embedder, error)
	VerifierFactory func(context.Context, semantic.ReuseConfig) (semantic.Verifier, error)
	Resources       admission.Source
	// contains filtered or unexported fields
}

type LocalVerifier struct {
	DailyTokenBudget *inference.TokenBudget
	// contains filtered or unexported fields
}

type OutcomeTracking struct {
	Status        string            `json:"status"` // recorded or failed
	ErrorCategory string            `json:"error_category,omitempty"`
	RunID         string            `json:"run_id"`
	Task          outcomes.Task     `json:"task"`
	Receipt       *outcomes.Receipt `json:"receipt,omitempty"`
	Record        *outcomes.Run     `json:"record,omitempty"`
}

type Policy struct {
	Local      Tier  `json:"local"`
	Escalation *Tier `json:"escalation,omitempty"`
}

type Request struct {
	TrackOutcome   bool                  `json:"track_outcome,omitempty"` // Opt-in shared accounting; excluded from generation identity.
	Spec           inference.Spec        `json:"spec"`
	Policy         Policy                `json:"policy"`
	Checks         []evaluation.Check    `json:"checks"`
	SemanticShadow *semantic.Config      `json:"semantic_shadow,omitempty"` // Advisory observation; excluded from generation identity.
	SemanticReuse  *semantic.ReuseConfig `json:"semantic_reuse,omitempty"`  // Explicit controlled answer reuse; excluded from generation identity.
}

type Result struct {
	SemanticReuse    *ReuseObservation           `json:"semantic_reuse,omitempty"`
	SemanticShadow   *semantic.Observation       `json:"semantic_shadow,omitempty"`
	BudgetDiagnostic *inference.BudgetDiagnostic `json:"budget_diagnostic,omitempty"`
	OutcomeTracking  *OutcomeTracking            `json:"outcome_tracking,omitempty"`
	RequestSHA256    string                      `json:"request_sha256"`
	Attempts         []Attempt                   `json:"attempts"`
	SelectedTier     string                      `json:"selected_tier,omitempty"`
	Response         *inference.Response         `json:"response,omitempty"` // Only a passing answer is exposed.
	Status           string                      `json:"status"`             // completed, quality_failed, stopped
}

type ReuseObservation struct {
	Mode                   string                    `json:"mode"`
	Status                 string                    `json:"status"`
	ResourceAdmission      *ReuseResourceAdmission   `json:"resource_admission,omitempty"`
	Partition              string                    `json:"partition,omitempty"`
	Source                 *semantic.Source          `json:"source,omitempty"`
	Similarity             float64                   `json:"similarity,omitempty"`
	EmbeddingInputTokens   *int64                    `json:"embedding_input_tokens"`
	EmbeddingMS            float64                   `json:"embedding_ms,omitempty"`
	Searches               int                       `json:"searches"`
	WaitMS                 float64                   `json:"wait_ms"`
	Verifications          []semantic.ValidityResult `json:"verifications"`
	Rejections             []string                  `json:"rejections"`
	Indexed                bool                      `json:"indexed"`
	GenerationAvoided      bool                      `json:"generation_avoided"`
	HistoricalUsageIsProxy bool                      `json:"historical_usage_is_proxy"`
}

type ReuseResourceAdmission struct {
	Reason               string             `json:"reason"`
	MemoryPressure       admission.Pressure `json:"memory_pressure,omitempty"`
	AvailableMemoryBytes *int64             `json:"available_memory_bytes"`
}

type Router struct {
	Factory   RunnerFactory
	AllowPaid bool // Caller permission, never read from request JSON or environment.
	Shadow    *ShadowObserver
	Reuse     *ControlledReuser
}

type Runner interface {
	Run(context.Context, inference.Spec) (inference.Result, error)
}

type RunnerFactory func(Tier) (Runner, error)

type ShadowObserver struct {
	Broker          inference.Broker
	Index           semantic.Index
	EmbedderFactory func(context.Context, semantic.Config) (semantic.Embedder, error)
	Resources       admission.Source // nil lets a Go caller provide its own admission.
	// contains filtered or unexported fields
}

type Tier struct {
	ID   string         `json:"id"`
	Spec inference.Spec `json:"spec"`
}