AnalyticsEventMonitor.java

public AnalyticsEventMonitor(final Construct scope, final String id, final AnalyticsEventMonitorProps props) {
  super(scope, id);
 
  lambdaExecutionRole = props.getLambdaExecutionRole();
  dlqTopics = props.getDlqTopics();
  infraLambda = props.getInfraLambda();
  getProperties();
 
  monitoringAlarms.addAll(props.getKinesisPipelines().stream()
      .map(pipeline ->
          KinesisAlarmSystem.Builder.create(this, String.format("%sAlarmSystem", pipeline.getNode().getId()))
              .kinesisPipeline(pipeline)
              .build()
              .getMonitoringAlarms())
      .flatMap(Collection::stream)
      .collect(Collectors.toList()));
 
  monitoringAlarms.addAll(
      ApiGatewayAlarmSystem.Builder.create(this, String.format("%sAlarmSystem", props.getApi().getNode().getId()))
          .api(props.getApi())
          .build()
          .getMonitoringAlarms()
  );
 
  monitoringTopic = createCloudwatchAlarmTopic();
  monitoringLambda = createAnalyticsInfraMonitoringLambda();
  createMonitoringSubscriptions();
  createAlarmEventBridge();
}