in functions/products-stream/main.go [14:24]
func main() {
eventBusName, ok := os.LookupEnv("EVENT_BUS_NAME")
if !ok {
panic("Need EVENT_BUS_NAME environment variable")
}
store := bus.NewEventBridgeBus(context.TODO(), eventBusName)
domain := domain.NewProductsStream(store)
handler := handlers.NewDynamoDBEventHandler(domain)
lambda.Start(handler.StreamHandler)
}