Skip to content

Commit efd0729

Browse files
committed
Stub HTTP Event Emitter
1 parent a92b853 commit efd0729

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

src/gateways/event.py

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
import httpx
12
from cloudevents_pydantic.events import CloudEvent
23
from structlog import get_logger
34

@@ -11,3 +12,17 @@ async def emit(
1112
"Event emitted",
1213
cloudevent=event.model_dump(),
1314
)
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

Comments
 (0)