protocols

type JSONMetricsResponse struct {
	ServiceName string                 `json:"service_name"`
	Timestamp   string                 `json:"timestamp"`
	Metrics     map[string]interface{} `json:"metrics"`
	Labels      map[string]string      `json:"labels,omitempty"`
}

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

type OTelAttribute struct {
	Key   string      `json:"key"`
	Value interface{} `json:"value"`
}

type OTelMetric struct {
	Name        string      `json:"name"`
	Description string      `json:"description"`
	Unit        string      `json:"unit"`
	Data        interface{} `json:"data"`
}

type OTelMetricsResponse struct {
	ResourceMetrics []OTelResourceMetrics `json:"resourceMetrics"`
}

type OTelResourceMetrics struct {
	Resource struct {
		Attributes []OTelAttribute `json:"attributes"`
	} `json:"resource"`
	ScopeMetrics []OTelScopeMetrics `json:"scopeMetrics"`
}

type OTelScopeMetrics struct {
	Scope struct {
		Name string `json:"name"`
	} `json:"scope"`
	Metrics []OTelMetric `json:"metrics"`
}

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

type PrometheusScraper 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 Scraper interface {
	// Scrape 从指定端点采集指标
	Scrape(ctx context.Context, endpoint string) ([]*dto.MetricFamily, error)

	// Validate 验证端点配置是否有效
	Validate(endpoint string) error

	// Protocol 返回协议名称
	Protocol() string
}

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

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