forked from minotar/imgd
-
Notifications
You must be signed in to change notification settings - Fork 0
/
metrics.go
127 lines (112 loc) · 3.68 KB
/
metrics.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
package main
import "github.com/prometheus/client_golang/prometheus"
const namespace = "imgd"
var (
inFlightGauge = prometheus.NewGauge(prometheus.GaugeOpts{
Namespace: namespace,
Subsystem: "http",
Name: "in_flight_requests",
Help: "A gauge of requests currently being served.",
})
requestDuration = prometheus.NewHistogramVec(prometheus.HistogramOpts{
Namespace: namespace,
Subsystem: "http",
Name: "request_duration_seconds",
Help: "Histogram of the time (in seconds) each HTTP request took.",
Buckets: []float64{.001, .005, 0.0075, .01, .025, .1, .5, 1, 5},
}, []string{"code"})
// Is this useful? Maybe if another datapoint of type of request??
responseSize = prometheus.NewHistogramVec(prometheus.HistogramOpts{
Namespace: namespace,
Subsystem: "http",
Name: "response_size_bytes",
Help: "A histogram of response sizes (in bytes) for requests.",
Buckets: []float64{100, 500, 1000, 2500, 5000},
}, []string{})
processingDuration = prometheus.NewHistogramVec(prometheus.HistogramOpts{
Namespace: namespace,
Subsystem: "image",
Name: "processing_duration_seconds",
Help: "Histogram of the time (in seconds) image processing took.",
Buckets: []float64{.00025, .0005, 0.001, 0.0025, .005},
}, []string{"resource"})
// Todo: Is label name okay?
getDuration = prometheus.NewHistogramVec(prometheus.HistogramOpts{
Namespace: namespace,
Subsystem: "status",
Name: "get_duration_seconds",
Help: "Histogram of the time (in seconds) external API Requests took.",
Buckets: []float64{.05, .1, .25, .5, 1},
}, []string{"source"})
cacheDuration = prometheus.NewHistogramVec(prometheus.HistogramOpts{
Namespace: namespace,
Subsystem: "cache",
Name: "operation_duration_seconds",
Help: "Histogram of the time (in seconds) each cache operation took.",
Buckets: []float64{.0005, .001, 0.0025, .005, 0.0075, 0.01, 0.1},
}, []string{"cache", "operation"})
errorCounter = prometheus.NewCounterVec(
prometheus.CounterOpts{
Namespace: namespace,
Subsystem: "status",
Name: "errors",
Help: "Error events",
},
[]string{"event"},
)
cacheCounter = prometheus.NewCounterVec(
prometheus.CounterOpts{
Namespace: namespace,
Subsystem: "status",
Name: "cache",
Help: "Cache status",
},
[]string{"cache", "status"},
)
requestCounter = prometheus.NewCounterVec(
prometheus.CounterOpts{
Namespace: namespace,
Subsystem: "status",
Name: "requests",
Help: "Resource requests",
},
[]string{"resource"},
)
apiCounter = prometheus.NewCounterVec(
prometheus.CounterOpts{
Namespace: namespace,
Subsystem: "status",
Name: "apirequests",
Help: "Requests to external APIs",
},
[]string{"call"},
)
userCounter = prometheus.NewCounterVec(
prometheus.CounterOpts{
Namespace: namespace,
Subsystem: "status",
Name: "userrequests",
Help: "Type of user request received",
},
[]string{"type"},
)
// Latency on Get (source of skin) :tick:
// Total latency for HTTP request (response code) :tick:
// Latency on cache (has, puul or add) :tick:
// Gauge for cache hit, miss :tick:
// Gauge for request (type) :tick:
// Latency for processing (type) :tick:
)
func init() {
prometheus.MustRegister(inFlightGauge)
prometheus.MustRegister(requestDuration)
prometheus.MustRegister(responseSize)
prometheus.MustRegister(processingDuration)
prometheus.MustRegister(getDuration)
prometheus.MustRegister(cacheDuration)
prometheus.MustRegister(errorCounter)
prometheus.MustRegister(cacheCounter)
prometheus.MustRegister(requestCounter)
prometheus.MustRegister(apiCounter)
prometheus.MustRegister(userCounter)
}