@@ -100,21 +100,6 @@ def increment_counter(self, name, labels, description=""):
100
100
logger .debug (f"Incrementing counter '{ name } ' with labels: { labels } " )
101
101
self .prometheus_metrics [name ].labels (* labels .values ()).inc ()
102
102
103
- def _create_gauge_if_not_exist (self , name , labels , value , description ):
104
- if not self .enabled :
105
- return
106
-
107
- # create the gauge if it doesn't already exist
108
- if name not in self .prometheus_metrics :
109
- logger .info (
110
- f"Creating gauge '{ name } ' with description '{ description } ' and labels: { labels } "
111
- )
112
- self .prometheus_metrics [name ] = Gauge (name , description , [* labels .keys ()])
113
- elif type (self .prometheus_metrics [name ]) is not Gauge :
114
- raise ValueError (
115
- f"Trying to create gauge '{ name } ' but a { type (self .prometheus_metrics [name ])} with this name already exists"
116
- )
117
-
118
103
def dec_gauge (self , name , labels , value , description = "" ):
119
104
"""
120
105
Decrement a Prometheus gauge metric.
@@ -126,6 +111,9 @@ def dec_gauge(self, name, labels, value, description=""):
126
111
value (int): Value to set the metric to
127
112
description (str): describing the gauge in case it doesn't already exist
128
113
"""
114
+ if not self .enabled :
115
+ return
116
+
129
117
self ._create_gauge_if_not_exist (name , labels , value , description )
130
118
logger .debug (f"Decrementing gauge '{ name } ' by '{ value } ' with labels: { labels } " )
131
119
self .prometheus_metrics [name ].labels (* labels .values ()).dec (value )
@@ -141,6 +129,9 @@ def inc_gauge(self, name, labels, value, description=""):
141
129
value (int): Value to set the metric to
142
130
description (str): describing the gauge in case it doesn't already exist
143
131
"""
132
+ if not self .enabled :
133
+ return
134
+
144
135
self ._create_gauge_if_not_exist (name , labels , value , description )
145
136
logger .debug (f"Incrementing gauge '{ name } ' by '{ value } ' with labels: { labels } " )
146
137
self .prometheus_metrics [name ].labels (* labels .values ()).inc (value )
@@ -155,6 +146,21 @@ def set_gauge(self, name, labels, value, description=""):
155
146
labels (dict): Dictionary of labels for the metric
156
147
value (int): Value to set the metric to
157
148
"""
149
+ if not self .enabled :
150
+ return
151
+
158
152
self ._create_gauge_if_not_exist (name , labels , value , description )
159
153
logger .debug (f"Setting gauge '{ name } ' with '{ value } ' with labels: { labels } " )
160
154
self .prometheus_metrics [name ].labels (* labels .values ()).set (value )
155
+
156
+ def _create_gauge_if_not_exist (self , name , labels , value , description ):
157
+ # create the gauge if it doesn't already exist
158
+ if name not in self .prometheus_metrics :
159
+ logger .info (
160
+ f"Creating gauge '{ name } ' with description '{ description } ' and labels: { labels } "
161
+ )
162
+ self .prometheus_metrics [name ] = Gauge (name , description , [* labels .keys ()])
163
+ elif type (self .prometheus_metrics [name ]) is not Gauge :
164
+ raise ValueError (
165
+ f"Trying to create gauge '{ name } ' but a { type (self .prometheus_metrics [name ])} with this name already exists"
166
+ )
0 commit comments