router

type ABMetrics struct {
	VariantName    string
	TotalRequests  int64
	SuccessCount   int64
	FailureCount   int64
	TotalLatencyMs int64
	TotalCost      float64
	QualityScores  []float64
	// contains filtered or unexported fields
}

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

type ABTestConfig struct {
	// 名称表示此测试 。
	Name string
	// 变体列出了测试变体.
	Variants []ABVariant
	// 粘接可以确定同一用户/会话的路径。
	StickyRouting bool
	// 粘接Key选择请求字段使用的:"user id","session id",或"tenant id".
	StickyKey string
	// 开始时间是测试开始的时候.
	StartTime time.Time
	// EndTime是测试结束的时候(零值表示无限期).
	EndTime time.Time
}

type ABVariant struct {
	// 名称是变体标识符(例如"control","experiment a").
	Name string
	// 提供方是这个变体所使用的LLM提供者.
	Provider llmpkg.Provider
	// 重量为交通重量(0-100). 所有变相权重必须相加为100.
	Weight int
	// 元数据为这个变体持有任意的密钥值对.
	Metadata map[string]string
}

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

type APIKeySelectionStrategy string

type APIKeyStats struct {
	KeyID          uint       `json:"key_id"`
	Label          string     `json:"label"`
	BaseURL        string     `json:"base_url"`
	Enabled        bool       `json:"enabled"`
	IsHealthy      bool       `json:"is_healthy"`
	TotalRequests  int64      `json:"total_requests"`
	FailedRequests int64      `json:"failed_requests"`
	SuccessRate    float64    `json:"success_rate"`
	CurrentRPM     int        `json:"current_rpm"`
	CurrentRPD     int        `json:"current_rpd"`
	LastUsedAt     *time.Time `json:"last_used_at"`
	LastErrorAt    *time.Time `json:"last_error_at"`
	LastError      string     `json:"last_error"`
}

type CanaryConfig = llmcore.CanaryConfig

type ChatChoice = llmcore.ChatChoice

type ChatRequest = llmcore.ChatRequest

type ChatResponse = llmcore.ChatResponse

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

type Error = llmcore.Error

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

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

type HealthStatus = llmcore.HealthStatus

type IntentClassification struct {
	Intent     IntentType        `json:"intent"`
	Confidence float64           `json:"confidence"`
	SubIntents []IntentType      `json:"sub_intents,omitempty"`
	Entities   map[string]string `json:"entities,omitempty"`
	Metadata   map[string]any    `json:"metadata,omitempty"`
}

type IntentType string

type LLMModel = llmcore.LLMModel

type LLMProvider = llmcore.LLMProvider

type LLMProviderAPIKey = llmcore.LLMProviderAPIKey

type LLMProviderModel = llmcore.LLMProviderModel

type Message = llmcore.Message

type Model = llmcore.Model

type ModelCandidate struct {
	ProviderCode   string
	ModelID        string
	ModelName      string
	Tags           []string
	PriceInput     float64
	PriceOutput    float64
	MaxTokens      int
	Weight         int
	CostWeight     float64
	LatencyWeight  float64
	QualityWeight  float64
	MaxCostPerReq  float64 // SLA: 单次请求最大成本
	MaxLatencyMs   int     // SLA: 最大延迟（毫秒）
	MinSuccessRate float64 // SLA: 最小成功率
	Health         *ModelHealth
	Enabled        bool
}

type ModelHealth struct {
	ModelID      string
	IsHealthy    bool
	SuccessRate  float64 // 成功率 (0-1)
	AvgLatencyMs int     // 平均延迟
	LastError    string
	LastErrorAt  *time.Time
	UpdatedAt    time.Time
}

type ModelRouter interface {
	// Select 选择最佳模型
	Select(ctx context.Context, req *RouteRequest) (*RouteResult, error)
	// UpdateHealth 更新模型健康状态
	UpdateHealth(modelID string, health *ModelHealth)
	// UpdateWeights 更新路由权重
	UpdateWeights(weights []config.RoutingWeight)
}

type ModelTier string

type MultiProviderRouter struct {
	*Router // 继承原有路由器
	// contains filtered or unexported fields
}

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

type PrefixRule struct {
	Prefix   string // 模型 ID 前缀（如 "gpt-4o", "claude-3-5-sonnet"）
	Provider string // Provider 代码（如 "openai", "anthropic"）
}

type Provider = llmcore.Provider

type ProviderEndpoints = llmcore.ProviderEndpoints

type ProviderFactory interface {
	CreateProvider(providerCode string, apiKey string, baseURL string) (Provider, error)
}

type ProviderHealthStats struct {
	ProviderCode string
	HealthScore  float64
	CurrentQPS   int
	ErrorRate    float64
	LatencyP95   time.Duration
	LastCheckAt  time.Time
}

type ProviderProbeResult struct {
	Healthy     bool
	Latency     time.Duration
	ErrorRate   float64
	LastError   string
	LastCheckAt time.Time
}

type ProviderSelection struct {
	Provider     Provider
	ProviderID   uint
	APIKeyID     uint
	ProviderCode string
	ModelID      uint
	ModelName    string
	RemoteModel  string
	IsCanary     bool
	Strategy     RoutingStrategy
}

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

type RouteConfig struct {
	Intent           IntentType `json:"intent"`
	PreferredModels  []string   `json:"preferred_models"`
	FallbackModels   []string   `json:"fallback_models,omitempty"`
	MaxTokens        int        `json:"max_tokens,omitempty"`
	Temperature      float32    `json:"temperature,omitempty"`
	RequiredFeatures []string   `json:"required_features,omitempty"` // e.g., "function_calling", "vision"
}

type RouteRequest struct {
	TaskType     string   // 任务类型：chat/completion/embedding
	TenantID     string   // 租户 ID
	Tags         []string // 期望的标签：jsonify/cheap/fast
	MaxCost      float64  // 最大成本预算
	MaxLatencyMs int      // 最大延迟要求
	PreferModel  string   // 优先模型（可选）
}

type RouteResult struct {
	ProviderCode string
	ModelName    string
	ModelID      string
	Score        float64
	Reason       string
}

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

type RoutedChatProviderOptions struct {
	DefaultStrategy RoutingStrategy
	Fallback        Provider
	Logger          *zap.Logger
	TierRouter      *TierRouter
}

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

type RouterOptions struct {
	HealthCheckInterval time.Duration
	HealthCheckTimeout  time.Duration
	Logger              *zap.Logger
}

type RoutingStrategy string

type ScoringWeights struct {
	MessageCount  int `json:"message_count" yaml:"message_count"`
	ContentLength int `json:"content_length" yaml:"content_length"`
	ToolCount     int `json:"tool_count" yaml:"tool_count"`
	SystemPrompt  int `json:"system_prompt" yaml:"system_prompt"`
}

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

type SemanticRouterConfig struct {
	ClassifierModel      string                     `json:"classifier_model"`
	DefaultRoute         RouteConfig                `json:"default_route"`
	Routes               map[IntentType]RouteConfig `json:"routes"`
	CacheClassifications bool                       `json:"cache_classifications"`
	CacheTTL             time.Duration              `json:"cache_ttl"`
}

type StreamChunk = llmcore.StreamChunk

type TierConfig struct {
	Enabled           bool           `json:"enabled" yaml:"enabled"`
	NanoModels        []string       `json:"nano_models" yaml:"nano_models"`
	StandardModels    []string       `json:"standard_models" yaml:"standard_models"`
	FrontierModels    []string       `json:"frontier_models" yaml:"frontier_models"`
	NanoThreshold     int            `json:"nano_threshold" yaml:"nano_threshold"`
	FrontierThreshold int            `json:"frontier_threshold" yaml:"frontier_threshold"`
	Weights           ScoringWeights `json:"weights" yaml:"weights"`
}

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

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