We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a92b853 commit efd0729Copy full SHA for efd0729
1 file changed
src/gateways/event.py
@@ -1,3 +1,4 @@
1
+import httpx
2
from cloudevents_pydantic.events import CloudEvent
3
from structlog import get_logger
4
@@ -11,3 +12,17 @@ async def emit(
11
12
"Event emitted",
13
cloudevent=event.model_dump(),
14
)
15
+
16
17
+class HttpEventGateway:
18
+ def __init__(self):
19
+ self.client = httpx.AsyncClient()
20
21
+ async def emit(
22
+ self, event: CloudEvent
23
+ ) -> None:
24
+ logger = get_logger()
25
+ await logger.ainfo(
26
+ "Event emitted via HTTP request",
27
+ cloudevent=event.model_dump(),
28
+ )
0 commit comments