feat(ECS): Added support for fargate service

src/aspect.ts

@@ -1,7 +1,9 @@
 import { IAspect } from 'aws-cdk-lib';
 import * as apigw from 'aws-cdk-lib/aws-apigateway';
 import * as dynamodb from 'aws-cdk-lib/aws-dynamodb';
+import * as ecs from 'aws-cdk-lib/aws-ecs';
 import * as ecs_patterns from 'aws-cdk-lib/aws-ecs-patterns';
+import * as elasticLoadBalancing from 'aws-cdk-lib/aws-elasticloadbalancingv2';
 import * as lambda from 'aws-cdk-lib/aws-lambda';
 import * as rds from 'aws-cdk-lib/aws-rds';
 import * as stepfunctions from 'aws-cdk-lib/aws-stepfunctions';
@@ -99,9 +101,17 @@ export class WatchfulAspect implements IAspect {
       this.watchful.watchFargateEcs(node.node.path, node.service, node.targetGroup);
     }
 
+    if (watchFargateEcs && node instanceof ecs.FargateService) {
+      this.watchful.watchFargateService(node.node.path, node);
+    }
+
     if (watchEc2Ecs && node instanceof ecs_patterns.ApplicationLoadBalancedEc2Service) {
       this.watchful.watchEc2Ecs(node.node.path, node.service, node.targetGroup);
     }
+
+    if (watchEc2Ecs && node instanceof elasticLoadBalancing.ApplicationTargetGroup) {
+      this.watchful.watchApplicationTargetGroup(node.node.path, node);
+    }
   }
 }
 

src/ecs/index.ts

@@ -0,0 +1,92 @@
+import { Names } from 'aws-cdk-lib';
+import * as ecs from 'aws-cdk-lib/aws-ecs';
+import { ApplicationTargetGroup } from 'aws-cdk-lib/aws-elasticloadbalancingv2';
+import { Construct } from 'constructs';
+import { IWatchful } from '../api';
+import { linkForEcsService, WatchService } from './service';
+import { WatchTargetGroup } from './target-group';
+
+export * from './target-group';
+export * from './service';
+
+
+export interface WatchEcsServiceOptions {
+  /**
+     * Threshold for the Cpu Maximum utilization
+     *
+     * @default 80
+     */
+  readonly cpuMaximumThresholdPercent?: number;
+
+  /**
+   * Threshold for the Memory Maximum utilization.
+   *
+   * @default - 0.
+   */
+  readonly memoryMaximumThresholdPercent?: number;
+
+  /**
+   * Threshold for the Target Response Time.
+   *
+   * @default - 0.
+   */
+  readonly targetResponseTimeThreshold?: number;
+
+  /**
+   * Threshold for the Number of Requests.
+   *
+   * @default - 0.
+   */
+  readonly requestsThreshold?: number;
+
+  /**
+   * Threshold for the Number of Request Errors.
+   *
+   * @default - 0.
+   */
+  readonly requestsErrorRateThreshold?: number;
+}
+
+export interface WatchEcsServiceProps extends WatchEcsServiceOptions {
+  readonly title: string;
+  readonly watchful: IWatchful;
+  readonly fargateService?: ecs.FargateService;
+  readonly ec2Service?: ecs.Ec2Service;
+  readonly targetGroup: ApplicationTargetGroup;
+}
+
+export class WatchEcsService extends Construct {
+
+  private readonly watchful: IWatchful;
+  private readonly ecsService: ecs.BaseService;
+
+  constructor(scope: Construct, id: string, props: WatchEcsServiceProps) {
+    super(scope, id);
+
+    this.watchful = props.watchful;
+
+    if (!props.ec2Service || !props.fargateService) {
+      throw new Error('No service provided to monitor.');
+    };
+
+    this.ecsService = props.ec2Service ?? props.fargateService;
+
+    this.watchful.addSection(props.title, {
+      links: [
+        { title: 'ECS Service', url: linkForEcsService(this.ecsService) },
+      ],
+    });
+
+    new WatchService(this, Names.uniqueId(this.ecsService), {
+      ...props,
+      service: this.ecsService,
+      skipLinkSection: true,
+    });
+
+    new WatchTargetGroup(this, Names.uniqueId(props.targetGroup), {
+      ...props,
+      skipLinkSection: true,
+    });
+  }
+
+}