[exporters] fix: allow source parameter propagation during fetching

Author: AndreyMarkinPPC

libs/exporters/garf_exporter/__init__.py

@@ -11,11 +11,12 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+"""Prometheus exporter for garf."""
 
 from garf_exporter.exporter import GarfExporter
 
 __all__ = [
   'GarfExporter',
 ]
 
-__version__ = '0.0.1'
+__version__ = '0.0.2'

libs/exporters/garf_exporter/collector.py

@@ -12,6 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+"""Collectors serves as a wrapper on top garf query."""
 
 import os
 import pathlib

libs/exporters/garf_exporter/exporter.py

@@ -126,7 +126,9 @@ def export(
       labelnames=('collector',),
       namespace=namespace,
     )
-    api_requests_counter = self._define_counter(name='api_requests_count')
+    api_requests_counter = self._define_counter(
+      namespace=namespace, name='api_requests_count'
+    )
     metrics = self._define_metrics(
       report.query_specification, suffix, namespace
     )
@@ -245,16 +247,19 @@ def _define_gauge(
       registry=self.registry,
     )
 
-  def _define_counter(self, name: str) -> prometheus_client.Counter:
+  def _define_counter(
+    self, namespace: str, name: str
+  ) -> prometheus_client.Counter:
     """Define Counter metric based on provided name.
 
     Args:
+      namespace: Global prefix for all Prometheus metrics.
       name: Name of the metric to be exposed to Prometheus (without prefix).
 
     Returns:
       An instance of Counter that associated with registry.
     """
-    counter_name = f'garf_core_{name}'
+    counter_name = f'{namespace}_{name}'
     if counter_name in self.registry._names_to_collectors:
       return self.registry._names_to_collectors.get(counter_name)
     return prometheus_client.Counter(

libs/exporters/garf_exporter/exporter_service.py

@@ -130,7 +130,7 @@ def generate_metrics(
     for col in collectors:
       logging.info('Exporting from collector: %s', col.title)
       start = time()
-      report = self.fetcher.fetch(col.query)
+      report = self.fetcher.fetch(col.query, **self.source_parameters)
       end = time()
       exporter.report_fetcher_gauge.labels(collector=col.title).set(end - start)
       exporter.export(