core

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

type CPUProfiler struct{}

type ConfigProvider interface {
	// GetTasks 返回当前性能分析任务
	GetTasks(ctx context.Context) ([]ProfilingTask, error)
	// Subscribe 订阅配置变更
	Subscribe(ctx context.Context, callback func([]ProfilingTask)) error
	// Close 关闭提供程序并释放资源
	Close() error
}

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

type GoroutineProfiler struct{}

type HTTPContext interface {
	// GetPath 返回路由模板（例如："/users/:id"）
	GetPath() string
	// GetMethod 返回HTTP方法
	GetMethod() string
	// GetHeaders 返回请求头
	GetHeaders() map[string]string
	// SetContext 在上下文中设置键值对
	SetContext(key, value interface{})
	// GetContext 通过键从上下文获取值
	GetContext(key interface{}) interface{}
	// GetRequestPath 返回实际请求路径
	GetRequestPath() string
}

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

type HeapProfiler struct{}

type Logger interface {
	// Info 记录信息消息
	Info(msg string, fields map[string]interface{})
	// Warn 记录警告消息
	Warn(msg string, fields map[string]interface{})
	// Error 记录错误消息
	Error(msg string, fields map[string]interface{})
	// Debug 记录调试消息
	Debug(msg string, fields map[string]interface{})
}

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

type Options struct {
	// MaxConcurrent is the maximum number of concurrent profiling sessions
	MaxConcurrent int `yaml:"max_concurrent" json:"max_concurrent"`

	// DefaultDuration is the default profiling duration
	DefaultDuration time.Duration `yaml:"default_duration" json:"default_duration"`

	// CleanupInterval is the interval for cleaning up old profiles
	CleanupInterval time.Duration `yaml:"cleanup_interval" json:"cleanup_interval"`

	// MaxFileAge is the maximum age for profile files before cleanup
	MaxFileAge time.Duration `yaml:"max_file_age" json:"max_file_age"`

	// Enabled controls whether profiling is enabled
	Enabled bool `yaml:"enabled" json:"enabled"`

	// ProfileDir is the directory to store profile files (for file storage)
	ProfileDir string `yaml:"profile_dir" json:"profile_dir"`

	// DefaultSampleRate is the default sample rate for profiling
	DefaultSampleRate int `yaml:"default_sample_rate" json:"default_sample_rate"`
}

type PathMatcher interface {
	// Match 检查实际路径是否匹配模板
	Match(template, actual string) bool
	// ExtractParams 使用模板从实际路径提取参数
	ExtractParams(template, actual string) map[string]string
}

type ProfileSession interface {
	// Stop 停止性能分析会话并返回结果
	Stop() ([]byte, error)
	// GetStartTime 返回会话开始时间
	GetStartTime() time.Time
	// IsRunning 如果会话仍处于活跃状态则返回true
	IsRunning() bool
}

type Profiler interface {
	// StartProfiling 使用给定配置开始性能分析
	StartProfiling(ctx context.Context, task ProfilingTask) (ProfileSession, error)
	// GetProfileType 返回此分析器处理的性能分析类型
	GetProfileType() string
}

type ProfilingResult struct {
	Path        string        `json:"path"`            // 路径
	StartTime   time.Time     `json:"start_time"`      // 开始时间
	Duration    time.Duration `json:"duration"`        // 持续时间
	Filename    string        `json:"filename"`        // 文件名
	FileSize    int64         `json:"file_size"`       // 文件大小
	ProfileType string        `json:"profile_type"`    // 分析类型
	Success     bool          `json:"success"`         // 是否成功
	Error       string        `json:"error,omitempty"` // 错误信息
}

type ProfilingStats struct {
	TotalRequests  int64     `json:"total_requests"`  // 总请求数
	ProfiledCount  int64     `json:"profiled_count"`  // 已分析数量
	FailedCount    int64     `json:"failed_count"`    // 失败数量
	ActiveProfiles int64     `json:"active_profiles"` // 活跃分析数
	LastUpdate     time.Time `json:"last_update"`     // 最后更新时间
}

type ProfilingTask struct {
	Path        string    `yaml:"path" json:"path"`                 // 路径
	Methods     []string  `yaml:"methods" json:"methods"`           // HTTP方法数组，支持多个方法或使用"*"表示常用方法
	ExpiresAt   time.Time `yaml:"expires_at" json:"expires_at"`     // 过期时间
	Duration    int       `yaml:"duration" json:"duration"`         // 最大分析持续时间(秒)
	SampleRate  int       `yaml:"sample_rate" json:"sample_rate"`   // 每N个请求进行采样
	ProfileType string    `yaml:"profile_type" json:"profile_type"` // cpu, heap, goroutine等
}

type Storage interface {
	// Save 将性能分析数据保存到存储
	Save(ctx context.Context, filename string, data []byte) error
	// List 列出匹配给定模式的文件
	List(ctx context.Context, pattern string) ([]string, error)
	// Delete 从存储中删除文件
	Delete(ctx context.Context, filename string) error
	// Clean 删除超过maxAge的文件
	Clean(ctx context.Context, maxAge time.Duration) error
}