metrics

type ApplicationMetrics struct {
	ServiceName string
	Metrics     map[string]float64
	Labels      map[string]string
	Timestamp   time.Time
}

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

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

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

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

type ApplicationTargetStrategy struct {
	ID              string       `json:"id"`
	DefaultInterval int          `json:"default_interval"`
	Targets         []PullTarget `json:"targets"`
	Version         int64        `json:"version"`
}

type CollectionTask struct {
	// 任务类型
	TaskType string `json:"task_type"` // system_metrics/application_metrics/log_collection/snmp_polling/snmp_trap/remote_collection

	// 是否启用
	Enabled bool `json:"enabled"`

	// 采集目标
	Target map[string]interface{} `json:"target,omitempty"`

	// 采集范围
	Scope map[string]interface{} `json:"scope,omitempty"`

	// 采集规则
	CollectionRules map[string]interface{} `json:"collection_rules"`

	// 处理规则（可选）
	ProcessingRules []map[string]interface{} `json:"processing_rules,omitempty"`

	// 输出规则（可选）
	OutputRules []map[string]interface{} `json:"output_rules,omitempty"`
}

type CollectionTaskExecutor interface {
	// ExecuteTask 执行采集任务
	ExecuteTask(ctx context.Context, task CollectionTask) error
	// StopTask 停止任务执行
	StopTask(ctx context.Context, task CollectionTask) error
	// GetTaskType 返回支持的任务类型
	GetTaskType() string
}

type CollectorConfig struct {
	Interval       time.Duration
	CollectSystem  bool
	CollectService bool
	// 增强型收集器配置（已废弃，不再使用，保留仅为了向后兼容）
	// Deprecated: 使用 TelegrafInputsEnabled 代替
	EnhancedEnabled bool
	// 历史缓存配置
	HistoryEnabled   bool
	HistoryMaxPoints int // 历史数据点最大数量，默认 360（1小时，10秒间隔）
	// Telegraf Input 插件配置
	TelegrafInputsEnabled  bool
	TelegrafInputsList     []string
	TelegrafInputsConfigs  map[string]interface{}
	TelegrafInputsInterval time.Duration
}

type ConfigStatus struct {
	Status       string    `json:"status"`                  // active, pending, failed
	Version      string    `json:"version"`                 // 配置版本号
	LastSync     time.Time `json:"last_sync"`               // 最后同步时间
	ErrorMessage string    `json:"error_message,omitempty"` // 错误信息
}

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

type CustomCollector interface {
	// Name 返回采集器名称
	Name() string
	// Collect 收集指标
	Collect(ctx context.Context) (map[string]interface{}, error)
	// Enabled 是否启用
	Enabled() bool
}

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

type GlobalMetricStrategy struct {
	ID              string           `json:"id"`
	DefaultPriority MetricPriority   `json:"default_priority"`
	DefaultInterval int              `json:"default_interval"`
	CollectionTasks []CollectionTask `json:"collection_tasks,omitempty"` // 采集任务列表
	StrategyVersion int              `json:"strategy_version,omitempty"` // 策略版本（固定为2，使用CollectionTasks）
	Version         int64            `json:"version"`
}

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

type InstanceMetricStrategy struct {
	ID              string           `json:"id"`
	AgentCode       string           `json:"agent_code"`
	CollectionTasks []CollectionTask `json:"collection_tasks,omitempty"` // 采集任务列表
	StrategyVersion int              `json:"strategy_version,omitempty"` // 策略版本（固定为2，使用CollectionTasks）
	InheritGlobal   bool             `json:"inherit_global"`
	Version         int64            `json:"version"`
}

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

type MetricHistoryPoint struct {
	Timestamp time.Time
	Metrics   *domain.SystemMetrics
}

type MetricMetadata struct {
	Name        string
	DisplayName string
	Type        string
	Unit        string
	Category    string
	Labels      map[string]string
}

type MetricMetadataServiceInterface interface {
	GetMetadata(ctx context.Context, name string) (*MetricMetadata, error)
}

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

type MetricPriority string

type MetricsCollector interface {
	CollectSystemMetrics(ctx context.Context) (*domain.SystemMetrics, error)
	CollectServiceMetrics(ctx context.Context, serviceID string) (*domain.ServiceMetrics, error)
	Start(ctx context.Context) error
	Stop() error
	GetSystemMetrics() *domain.SystemMetrics
	GetServiceMetrics(serviceID string) (*domain.ServiceMetrics, bool)
	GetAllServiceMetrics() map[string]*domain.ServiceMetrics
	// ReloadTelegrafConfig(config string) error    // 重新加载Telegraf配置（已废弃，保留用于向后兼容）
	GetPrometheusRegistry() *prometheus.Registry        // 获取 Prometheus Registry（用于导出指标）
	GetTelegrafInputCollector() *TelegrafInputCollector // 获取TelegrafInputCollector（用于任务执行器）
}

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

type MetricsReporter interface {
	Start(ctx context.Context) error
	Stop() error
	Report(ctx context.Context) error
}

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

type PullTarget struct {
	ServiceName string
	Protocol    string // prometheus/statsd/otel/json
	Endpoint    string // HTTP 端点或 UDP 地址
	Interval    int    // 采集间隔（秒）
	Enabled     bool
	Labels      map[string]string
	LastScrape  time.Time
	LastError   error
}

type QualityCheckResult struct {
	RuleID     string
	MetricName string
	Value      float64
	Timestamp  time.Time
	Passed     bool
	Level      string
	Message    string
	Details    map[string]interface{}
}

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

type QualityRule struct {
	ID            string
	MetricName    string
	Type          string
	Config        map[string]interface{}
	AlertLevel    string
	CheckInterval int
}

type QualityServiceInterface interface {
	GetRulesForMetric(ctx context.Context, metricName string) ([]QualityRule, error)
	ReportCheckResult(ctx context.Context, result QualityCheckResult) error
}

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

type ReportMetricRequest struct {
	ServiceName string            `json:"service_name"`
	MetricName  string            `json:"metric_name"`
	Value       float64           `json:"value"`
	Labels      map[string]string `json:"labels,omitempty"`
}

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

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

type ServiceMetricHistoryPoint struct {
	Timestamp time.Time
	Metrics   *domain.ServiceMetrics
}

type ServiceRegistry interface {
	Get(serviceID string) (*domain.Service, bool)
	List() []*domain.Service
}

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

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

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

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

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

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