@@ -11,7 +11,7 @@ import (
11
11
"github.com/prometheus/client_golang/prometheus"
12
12
)
13
13
14
- // LabelUpdater updates the labels of upstream server and server zone metrics
14
+ // LabelUpdater updates the labels of upstream server and server zone metrics.
15
15
type LabelUpdater interface {
16
16
UpdateUpstreamServerPeerLabels (upstreamServerPeerLabels map [string ][]string )
17
17
DeleteUpstreamServerPeerLabels (peers []string )
@@ -64,7 +64,7 @@ type NginxPlusCollector struct {
64
64
mutex sync.Mutex
65
65
}
66
66
67
- // UpdateUpstreamServerPeerLabels updates the Upstream Server Peer Labels
67
+ // UpdateUpstreamServerPeerLabels updates the Upstream Server Peer Labels.
68
68
func (c * NginxPlusCollector ) UpdateUpstreamServerPeerLabels (upstreamServerPeerLabels map [string ][]string ) {
69
69
c .variableLabelsMutex .Lock ()
70
70
for k , v := range upstreamServerPeerLabels {
@@ -73,7 +73,7 @@ func (c *NginxPlusCollector) UpdateUpstreamServerPeerLabels(upstreamServerPeerLa
73
73
c .variableLabelsMutex .Unlock ()
74
74
}
75
75
76
- // DeleteUpstreamServerPeerLabels deletes the Upstream Server Peer Labels
76
+ // DeleteUpstreamServerPeerLabels deletes the Upstream Server Peer Labels.
77
77
func (c * NginxPlusCollector ) DeleteUpstreamServerPeerLabels (peers []string ) {
78
78
c .variableLabelsMutex .Lock ()
79
79
for _ , k := range peers {
@@ -82,7 +82,7 @@ func (c *NginxPlusCollector) DeleteUpstreamServerPeerLabels(peers []string) {
82
82
c .variableLabelsMutex .Unlock ()
83
83
}
84
84
85
- // UpdateStreamUpstreamServerPeerLabels updates the Upstream Server Peer Labels
85
+ // UpdateStreamUpstreamServerPeerLabels updates the Upstream Server Peer Labels.
86
86
func (c * NginxPlusCollector ) UpdateStreamUpstreamServerPeerLabels (streamUpstreamServerPeerLabels map [string ][]string ) {
87
87
c .variableLabelsMutex .Lock ()
88
88
for k , v := range streamUpstreamServerPeerLabels {
@@ -91,7 +91,7 @@ func (c *NginxPlusCollector) UpdateStreamUpstreamServerPeerLabels(streamUpstream
91
91
c .variableLabelsMutex .Unlock ()
92
92
}
93
93
94
- // DeleteStreamUpstreamServerPeerLabels deletes the Upstream Server Peer Labels
94
+ // DeleteStreamUpstreamServerPeerLabels deletes the Upstream Server Peer Labels.
95
95
func (c * NginxPlusCollector ) DeleteStreamUpstreamServerPeerLabels (peers []string ) {
96
96
c .variableLabelsMutex .Lock ()
97
97
for _ , k := range peers {
@@ -100,7 +100,7 @@ func (c *NginxPlusCollector) DeleteStreamUpstreamServerPeerLabels(peers []string
100
100
c .variableLabelsMutex .Unlock ()
101
101
}
102
102
103
- // UpdateUpstreamServerLabels updates the Upstream Server Labels
103
+ // UpdateUpstreamServerLabels updates the Upstream Server Labels.
104
104
func (c * NginxPlusCollector ) UpdateUpstreamServerLabels (upstreamServerLabelValues map [string ][]string ) {
105
105
c .variableLabelsMutex .Lock ()
106
106
for k , v := range upstreamServerLabelValues {
@@ -109,7 +109,7 @@ func (c *NginxPlusCollector) UpdateUpstreamServerLabels(upstreamServerLabelValue
109
109
c .variableLabelsMutex .Unlock ()
110
110
}
111
111
112
- // DeleteUpstreamServerLabels deletes the Upstream Server Labels
112
+ // DeleteUpstreamServerLabels deletes the Upstream Server Labels.
113
113
func (c * NginxPlusCollector ) DeleteUpstreamServerLabels (upstreamNames []string ) {
114
114
c .variableLabelsMutex .Lock ()
115
115
for _ , k := range upstreamNames {
@@ -118,7 +118,7 @@ func (c *NginxPlusCollector) DeleteUpstreamServerLabels(upstreamNames []string)
118
118
c .variableLabelsMutex .Unlock ()
119
119
}
120
120
121
- // UpdateStreamUpstreamServerLabels updates the Upstream Server Labels
121
+ // UpdateStreamUpstreamServerLabels updates the Upstream Server Labels.
122
122
func (c * NginxPlusCollector ) UpdateStreamUpstreamServerLabels (streamUpstreamServerLabelValues map [string ][]string ) {
123
123
c .variableLabelsMutex .Lock ()
124
124
for k , v := range streamUpstreamServerLabelValues {
@@ -127,7 +127,7 @@ func (c *NginxPlusCollector) UpdateStreamUpstreamServerLabels(streamUpstreamServ
127
127
c .variableLabelsMutex .Unlock ()
128
128
}
129
129
130
- // DeleteStreamUpstreamServerLabels deletes the Upstream Server Labels
130
+ // DeleteStreamUpstreamServerLabels deletes the Upstream Server Labels.
131
131
func (c * NginxPlusCollector ) DeleteStreamUpstreamServerLabels (streamUpstreamNames []string ) {
132
132
c .variableLabelsMutex .Lock ()
133
133
for _ , k := range streamUpstreamNames {
@@ -136,7 +136,7 @@ func (c *NginxPlusCollector) DeleteStreamUpstreamServerLabels(streamUpstreamName
136
136
c .variableLabelsMutex .Unlock ()
137
137
}
138
138
139
- // UpdateServerZoneLabels updates the Server Zone Labels
139
+ // UpdateServerZoneLabels updates the Server Zone Labels.
140
140
func (c * NginxPlusCollector ) UpdateServerZoneLabels (serverZoneLabelValues map [string ][]string ) {
141
141
c .variableLabelsMutex .Lock ()
142
142
for k , v := range serverZoneLabelValues {
@@ -145,7 +145,7 @@ func (c *NginxPlusCollector) UpdateServerZoneLabels(serverZoneLabelValues map[st
145
145
c .variableLabelsMutex .Unlock ()
146
146
}
147
147
148
- // DeleteServerZoneLabels deletes the Server Zone Labels
148
+ // DeleteServerZoneLabels deletes the Server Zone Labels.
149
149
func (c * NginxPlusCollector ) DeleteServerZoneLabels (zoneNames []string ) {
150
150
c .variableLabelsMutex .Lock ()
151
151
for _ , k := range zoneNames {
@@ -154,7 +154,7 @@ func (c *NginxPlusCollector) DeleteServerZoneLabels(zoneNames []string) {
154
154
c .variableLabelsMutex .Unlock ()
155
155
}
156
156
157
- // UpdateStreamServerZoneLabels updates the Stream Server Zone Labels
157
+ // UpdateStreamServerZoneLabels updates the Stream Server Zone Labels.
158
158
func (c * NginxPlusCollector ) UpdateStreamServerZoneLabels (streamServerZoneLabelValues map [string ][]string ) {
159
159
c .variableLabelsMutex .Lock ()
160
160
for k , v := range streamServerZoneLabelValues {
@@ -163,7 +163,7 @@ func (c *NginxPlusCollector) UpdateStreamServerZoneLabels(streamServerZoneLabelV
163
163
c .variableLabelsMutex .Unlock ()
164
164
}
165
165
166
- // DeleteStreamServerZoneLabels deletes the Stream Server Zone Labels
166
+ // DeleteStreamServerZoneLabels deletes the Stream Server Zone Labels.
167
167
func (c * NginxPlusCollector ) DeleteStreamServerZoneLabels (zoneNames []string ) {
168
168
c .variableLabelsMutex .Lock ()
169
169
for _ , k := range zoneNames {
@@ -172,7 +172,7 @@ func (c *NginxPlusCollector) DeleteStreamServerZoneLabels(zoneNames []string) {
172
172
c .variableLabelsMutex .Unlock ()
173
173
}
174
174
175
- // UpdateCacheZoneLabels updates the Upstream Cache Zone labels
175
+ // UpdateCacheZoneLabels updates the Upstream Cache Zone labels.
176
176
func (c * NginxPlusCollector ) UpdateCacheZoneLabels (cacheZoneLabelValues map [string ][]string ) {
177
177
c .variableLabelsMutex .Lock ()
178
178
for k , v := range cacheZoneLabelValues {
@@ -181,7 +181,7 @@ func (c *NginxPlusCollector) UpdateCacheZoneLabels(cacheZoneLabelValues map[stri
181
181
c .variableLabelsMutex .Unlock ()
182
182
}
183
183
184
- // DeleteCacheZoneLabels deletes the Cache Zone Labels
184
+ // DeleteCacheZoneLabels deletes the Cache Zone Labels.
185
185
func (c * NginxPlusCollector ) DeleteCacheZoneLabels (cacheZoneNames []string ) {
186
186
c .variableLabelsMutex .Lock ()
187
187
for _ , k := range cacheZoneNames {
@@ -226,7 +226,7 @@ func (c *NginxPlusCollector) getStreamUpstreamServerPeerLabelValues(peer string)
226
226
return c .streamUpstreamServerPeerLabels [peer ]
227
227
}
228
228
229
- // UpdateWorkerLabels updates the Worker Labels
229
+ // UpdateWorkerLabels updates the Worker Labels.
230
230
func (c * NginxPlusCollector ) UpdateWorkerLabels (workerLabelValues map [string ][]string ) {
231
231
c .variableLabelsMutex .Lock ()
232
232
for k , v := range workerLabelValues {
@@ -235,7 +235,7 @@ func (c *NginxPlusCollector) UpdateWorkerLabels(workerLabelValues map[string][]s
235
235
c .variableLabelsMutex .Unlock ()
236
236
}
237
237
238
- // DeleteWorkerLabels deletes the Worker Labels
238
+ // DeleteWorkerLabels deletes the Worker Labels.
239
239
func (c * NginxPlusCollector ) DeleteWorkerLabels (id []string ) {
240
240
c .variableLabelsMutex .Lock ()
241
241
for _ , k := range id {
@@ -250,7 +250,7 @@ func (c *NginxPlusCollector) getWorkerLabelValues(id string) []string {
250
250
return c .workerLabels [id ]
251
251
}
252
252
253
- // VariableLabelNames holds all the variable label names for the different metrics
253
+ // VariableLabelNames holds all the variable label names for the different metrics.
254
254
type VariableLabelNames struct {
255
255
UpstreamServerVariableLabelNames []string
256
256
ServerZoneVariableLabelNames []string
@@ -262,7 +262,7 @@ type VariableLabelNames struct {
262
262
WorkerPIDVariableLabelNames []string
263
263
}
264
264
265
- // NewVariableLabelNames NewVariableLabels creates a new struct for VariableNames for the collector
265
+ // NewVariableLabelNames NewVariableLabels creates a new struct for VariableNames for the collector.
266
266
func NewVariableLabelNames (upstreamServerVariableLabelNames []string , serverZoneVariableLabelNames []string , upstreamServerPeerVariableLabelNames []string ,
267
267
streamUpstreamServerVariableLabelNames []string , streamServerZoneLabels []string , streamUpstreamServerPeerVariableLabelNames []string , cacheZoneLabelNames []string , workerPIDVariableLabelNames []string ,
268
268
) VariableLabelNames {
@@ -1219,7 +1219,6 @@ func (c *NginxPlusCollector) Collect(ch chan<- prometheus.Metric) {
1219
1219
}
1220
1220
1221
1221
for name , zone := range stats .Caches {
1222
-
1223
1222
var cold float64
1224
1223
if zone .Cold {
1225
1224
cold = 1.0
0 commit comments