core

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

type CaptureEventIn struct {
	EventType     string          `json:"event_type"`
	EventName     string          `json:"event_name"`
	InputPayload  json.RawMessage `json:"input_payload"`
	OutputPayload json.RawMessage `json:"output_payload"`
	Metadata      json.RawMessage `json:"metadata"`
	Status        string          `json:"status"`
}

type CaptureFilter struct {
	AgentID   *string
	SessionID *string
	EventType *models.CaptureEventType
	Limit     int
	Offset    int
}

type Change struct {
	Op   DeltaOp `json:"op"`
	Path string  `json:"path"`
	From any     `json:"from,omitempty"`
	To   any     `json:"to,omitempty"`
}

type CreateParams struct {
	AgentID       string
	Title         string
	ActionPayload json.RawMessage
	Description   string
	SessionID     string
	Framework     string
	RiskLevel     models.RiskLevel
	Priority      int
	PolicyID      *string
	Requester     string
	Metadata      json.RawMessage
}

type DecisionFilter struct {
	Source    *models.DecisionSource
	Agreement *bool
	Q         *string
	Limit     int
	Offset    int
}

type DeltaOp string

type Event struct {
	Topic string `json:"topic"`
	Data  any    `json:"data"`
}

type Feedback struct {
	ApprovedWithFeedback int `json:"approved_with_feedback"`
	NegativeOutcomes     int `json:"negative_outcomes"`
}

type Governance struct {
	EscalationRate    float64 `json:"escalation_rate"`
	TimeoutRate       float64 `json:"timeout_rate"`
	CorrectionRate    float64 `json:"correction_rate"`
	ReviewerAgreement float64 `json:"reviewer_agreement"`
	ErrorEscapeRate   float64 `json:"error_escape_rate"`
	SLAComplianceRate float64 `json:"sla_compliance_rate"`
}

type Latency struct {
	HumanReviews int     `json:"human_reviews"`
	AvgSeconds   float64 `json:"avg_seconds"`
	P50Seconds   float64 `json:"p50_seconds"`
	P95Seconds   float64 `json:"p95_seconds"`
}

type MetricsResult struct {
	Window     WindowInfo `json:"window"`
	Totals     TotalsInfo `json:"totals"`
	Governance Governance `json:"governance"`
	Latency    Latency    `json:"latency"`
	Risk       RiskInfo   `json:"risk"`
	Feedback   Feedback   `json:"feedback"`
}

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

type PolicyPatch struct {
	Description          *string
	RiskLevels           *[]models.RiskLevel
	TimeoutSeconds       *int
	OnTimeout            *models.TimeoutAction
	AutoApproveBelowRisk *bool
	MinReviewers         *int
	Enabled              *bool
}

type RequestFilter struct {
	Status    *models.RequestStatus
	Framework *string
	AgentID   *string
	Escalated *bool
	Risk      *models.RiskLevel
	Q         *string
	Limit     int
	Offset    int
}

type ResolveParams struct {
	Approved        bool
	DecisionPayload json.RawMessage // nil => keep the agent payload
	Source          models.DecisionSource
	ReviewerID      string
	Note            string
	Amend           bool
	RecordDecision  bool
}

type RiskBucket struct {
	Created   int `json:"created"`
	Escalated int `json:"escalated"`
}

type RiskInfo map[string]RiskBucket

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

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

type TotalsInfo struct {
	Requests  int            `json:"requests"`
	ByStatus  map[string]int `json:"by_status"`
	Escalated int            `json:"escalated"`
	Pending   int            `json:"pending"`
}

type WindowInfo struct {
	SinceDays   *int   `json:"since_days"`
	GeneratedAt string `json:"generated_at"`
}