collector.go 1.1 KB
Newer Older
Y
Your Name 已提交
1 2 3 4 5 6 7 8
package monitor

import (
	"github.com/eolinker/goku-api-gateway/diting"
	goku_labels "github.com/eolinker/goku-api-gateway/goku-labels"
)

var (
Y
Your Name 已提交
9
	//APIMonitor diting.APIMonitor
Y
Your Name 已提交
10
	APIMonitor diting.Histogram
Y
Your Name 已提交
11
	//ProxyMonitor diting.Histogram
Y
Your Name 已提交
12 13 14
	ProxyMonitor diting.Histogram
)

Y
Your Name 已提交
15
func initCollector(constLabels diting.Labels) {
Y
Your Name 已提交
16 17 18 19 20 21 22 23 24 25
	//apiLabelNames  := []string{
	//	goku_labels.Cluster,
	//	goku_labels.Instance,
	//	goku_labels.API,
	//	goku_labels.Strategy,
	//	goku_labels.Status,
	//}
	//apiCounterOpt:= diting.NewCounterOpts("goku","api","count","api 请求计数",constLabels,apiLabelNames)
	//APICount = diting.NewCounter(apiCounterOpt)

Y
Your Name 已提交
26
	apiHistogramOpt := diting.NewHistogramOpts(goku_labels.Namespace, goku_labels.Subsystem, goku_labels.APIName, "api整体请求统计", constLabels, goku_labels.APIDelayLabelNames, goku_labels.APIBuckets)
Y
Your Name 已提交
27 28
	APIMonitor = diting.NewHistogram(apiHistogramOpt)

Y
Your Name 已提交
29
	proxyMonitorOpt := diting.NewHistogramOpts(goku_labels.Namespace, goku_labels.Subsystem, goku_labels.ProxyName, "转发统计", constLabels, goku_labels.ProxyDelayLabelNames, goku_labels.ProxyBuckets)
Y
Your Name 已提交
30 31
	ProxyMonitor = diting.NewHistogram(proxyMonitorOpt)

Y
Your Name 已提交
32
}