add prometheus_client dependency

navikt · Jun 15, 2021 · 3e925dc · 3e925dc
1 parent 3a5d2e1
commit 3e925dc
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/kafka_producer/kafka_producer.py b/kafka_producer/kafka_producer.py
@@ -4,7 +4,7 @@
 from kafka.errors import KafkaError
 
 
-class IngressRetrieverKafkaProducer:
+class CollectorKafkaProducer:
 
     def __init__(self):
         self.producer = KafkaProducer(bootstrap_servers=os.environ["KAFKA_BROKERS"],

diff --git a/main.py b/main.py
@@ -10,14 +10,14 @@
 from collector.nais_stream import NaisStream, TooOldResourceVersionError
 from collector.utils import init_app_logging, get_logger
 from kubernetes import client, config, watch
-from kafka_producer.kafka_producer import IngressRetrieverKafkaProducer
+from kafka_producer.kafka_producer import CollectorKafkaProducer
 
 init_app_logging()
 logger = get_logger(__name__)
 app = FastAPI()
 is_alive = True
 
-producer = IngressRetrieverKafkaProducer()
+producer = CollectorKafkaProducer()
 
 
 def init_kube_client():

diff --git a/pyproject.toml b/pyproject.toml
@@ -15,6 +15,7 @@ requests = "^2.24.0"
 uvicorn = "^0.11.8"
 responses = "^0.12.0"
 kafka-python = "^2.0.1"
+prometheus_client = "^0.9.0"
 
 [tool.poetry.dev-dependencies]
 fastapi = "^0.61.1"