opentelemetry: add consumer and producer

automon/integrations/openTelemetryWrapper/client.py

@@ -23,6 +23,18 @@ async def is_ready(self):
     async def get_finished_spans(self):
         return await self.config.get_finished_spans()
 
+    async def start_consumer(self):
+        """adds spans from memory to queue"""
+        while True:
+            pass
+        return
+
+    async def start_producer(self):
+        """"""
+        while True:
+            pass
+        return
+
     async def to_dict(self):
         return [
             json.loads(span.to_json())

automon/integrations/openTelemetryWrapper/config.py

@@ -1,3 +1,5 @@
+import asyncio
+
 from opentelemetry import trace
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import SimpleSpanProcessor
@@ -20,6 +22,9 @@ def __init__(self):
 
         self.tracer = trace.get_tracer(__name__)
 
+        self.queue_consumer = asyncio.Queue()
+        self.queue_producer = asyncio.Queue()
+
     async def clear(self):
         return self.memory_processor.clear()