metrics

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

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

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

type MetricDesc struct {
	Name   string
	Type   MetricType
	Help   string
	Labels []string
}

type MetricSnapshot struct {
	ComponentName  string
	RecordsIn      int64
	RecordsOut     int64
	RecordsError   int64
	AvgDurationSec float64
	ProcessingTime time.Duration
}

type MetricType int

type PrometheusCollector interface {
	// AddCounter 增加计数器值
	AddCounter(name string, value float64, labels prometheus.Labels)
	// ObserveHistogram 观察 Histogram 值
	ObserveHistogram(name string, value float64, labels prometheus.Labels)
}

type Recorder interface {
	// RecordIn 记录进入组件的记录数
	RecordIn(count int64)
	// RecordOut 记录离开组件的记录数
	RecordOut(count int64)
	// RecordError 记录错误数
	RecordError(count int64)
	// RecordDuration 记录处理耗时
	RecordDuration(seconds float64)

	// AddCounter 增加自定义计数器指标
	AddCounter(name string, value float64, labels prometheus.Labels)
	// SetGauge 设置自定义 Gauge 指标
	SetGauge(name string, value float64, labels prometheus.Labels)
	// ObserveHistogram 观察自定义 Histogram 指标
	ObserveHistogram(name string, value float64, labels prometheus.Labels)
	// ObserveSummary 观察自定义 Summary 指标
	ObserveSummary(name string, value float64, labels prometheus.Labels)
}

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

type ServerConfig struct {
	// Addr 监听地址，默认 :9090
	Addr string `json:"addr"`
	// Path metrics 路径，默认 /metrics
	Path string `json:"path"`
	// Namespace 指标命名空间
	Namespace string `json:"namespace"`
}

type Summary struct {
	StartTime  time.Time
	EndTime    time.Time
	Duration   time.Duration
	TotalIn    int64
	TotalOut   int64
	TotalError int64
	Components []MetricSnapshot
}