in bus/event_bridge.go [23:35]
func NewEventBridgeBus(ctx context.Context, busName string) *EventBridgeBus {
cfg, err := config.LoadDefaultConfig(ctx)
if err != nil {
log.Fatalf("unable to load SDK config, %v", err)
}
client := cloudwatchevents.NewFromConfig(cfg)
return &EventBridgeBus{
client: client,
busName: busName,
}
}