func NewEventBridgeBus()

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,
	}
}