feat: add ECSContainerInstanceEvent

[wafuwafu13]

Issue #, if available:

Description of changes:
ref: https://docs.aws.amazon.com/AmazonECS/latest/developerguide/ecs_cwe_events.html#ecs_container_instance_events

I verified in my environment.

Lambda code

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"time"

	"github.com/aws/aws-lambda-go/lambda"
)

type ECSContainerInstanceEvent struct {
	Version    string                              `json:"version"`
	ID         string                              `json:"id"`
	DetailType string                              `json:"detail-type"`
	Source     string                              `json:"source"`
	Account    string                              `json:"account"`
	Time       time.Time                           `json:"time"`
	Region     string                              `json:"region"`
	Resources  []string                            `json:"resources"`
	Detail     ECSContainerInstanceEventDetailType `json:"detail"`
}

type ECSContainerInstanceEventDetailType struct {
	AgentConnected       bool        `json:"agentConnected"`
	Attributes           []Attribute `json:"attributes"`
	ClusterArn           string      `json:"clusterArn"`
	ContainerInstanceArn string      `json:"containerInstanceArn"`
	EC2InstanceID        string      `json:"ec2InstanceId"`
	RegisteredResources  []Resource  `json:"registeredResources"`
	RemainingResources   []Resource  `json:"remainingResources"`
	Status               string      `json:"status"`
	Version              int         `json:"version"`
	VersionInfo          VersionInfo `json:"versionInfo"`
	UpdatedAt            time.Time   `json:"updatedAt"`
}

type Attribute struct {
	Name string `json:"name"`
}

type Resource struct {
	Name           string    `json:"name"`
	Type           string    `json:"type"`
	IntegerValue   int       `json:"integerValue,omitempty"`
	StringSetValue []*string `json:"stringSetValue,omitempty"`
}

type VersionInfo struct {
	AgentHash     string `json:"agentHash"`
	AgentVersion  string `json:"agentVersion"`
	DockerVersion string `json:"dockerVersion"`
}

func (r Resource) MarshalJSON() ([]byte, error) {
	type Alias Resource
	aux := struct {
		StringSetValue json.RawMessage `json:"stringSetValue,omitempty"`
		Alias
	}{
		Alias: (Alias)(r),
	}

	if r.StringSetValue != nil {
		b, err := json.Marshal(r.StringSetValue)
		if err != nil {
			return nil, err
		}
		aux.StringSetValue = b
	}

	return json.Marshal(&aux)
}

func handler(ctx context.Context, ecsEvent ECSContainerInstanceEvent) {
	outputJSON, _ := json.MarshalIndent(ecsEvent, "", " ")
	fmt.Printf("output: %s", outputJSON)
}

func main() {
	lambda.Start(handler)
}

Change status to DRAINING

Cloudwatch Logs

  | 2023-04-16T12:59:37.095+01:00 | START RequestId: <START RequestId> Version: $LATEST
  | 2023-04-16T12:59:37.096+01:00 | err: <nil>
  | 2023-04-16T12:59:37.096+01:00 | output: {
  | 2023-04-16T12:59:37.096+01:00 | "version": "0",
  | 2023-04-16T12:59:37.096+01:00 | "id": "<id>",
  | 2023-04-16T12:59:37.096+01:00 | "detail-type": "ECS Container Instance State Change",
  | 2023-04-16T12:59:37.096+01:00 | "source": "aws.ecs",
  | 2023-04-16T12:59:37.096+01:00 | "account": "<account>",
  | 2023-04-16T12:59:37.096+01:00 | "time": "2023-04-16T11:59:36Z",
  | 2023-04-16T12:59:37.096+01:00 | "region": "eu-west-1",
  | 2023-04-16T12:59:37.096+01:00 | "resources": [
  | 2023-04-16T12:59:37.096+01:00 | "<resources>"
  | 2023-04-16T12:59:37.096+01:00 | ],
  | 2023-04-16T12:59:37.096+01:00 | "detail": {
  | 2023-04-16T12:59:37.096+01:00 | "agentConnected": false,
  | 2023-04-16T12:59:37.096+01:00 | "attributes": [
  | 2023-04-16T12:59:37.096+01:00 | {
  | 2023-04-16T12:59:37.096+01:00 | "name": "ecs.capability.secrets.asm.environment-variables"
  | 2023-04-16T12:59:37.096+01:00 | },
...
  | 2023-04-16T12:59:37.096+01:00 | {
  | 2023-04-16T12:59:37.096+01:00 | "name": "com.amazonaws.ecs.capability.task-iam-role"
  | 2023-04-16T12:59:37.096+01:00 | }
  | 2023-04-16T12:59:37.096+01:00 | ],
  | 2023-04-16T12:59:37.096+01:00 | "clusterArn": "<clusterArn>",
  | 2023-04-16T12:59:37.096+01:00 | "containerInstanceArn": "<containerInstanceArn>",
  | 2023-04-16T12:59:37.096+01:00 | "ec2InstanceId": "<ec2InstanceId>",
  | 2023-04-16T12:59:37.096+01:00 | "registeredResources": [
  | 2023-04-16T12:59:37.096+01:00 | {
  | 2023-04-16T12:59:37.096+01:00 | "name": "CPU",
  | 2023-04-16T12:59:37.096+01:00 | "type": "INTEGER",
  | 2023-04-16T12:59:37.096+01:00 | "integerValue": 1024
  | 2023-04-16T12:59:37.096+01:00 | },
  | 2023-04-16T12:59:37.096+01:00 | {
  | 2023-04-16T12:59:37.096+01:00 | "name": "MEMORY",
  | 2023-04-16T12:59:37.096+01:00 | "type": "INTEGER",
  | 2023-04-16T12:59:37.096+01:00 | "integerValue": 970
  | 2023-04-16T12:59:37.096+01:00 | },
  | 2023-04-16T12:59:37.096+01:00 | {
  | 2023-04-16T12:59:37.096+01:00 | "stringSetValue": [
  | 2023-04-16T12:59:37.096+01:00 | "22",
  | 2023-04-16T12:59:37.096+01:00 | "2376",
  | 2023-04-16T12:59:37.096+01:00 | "2375",
  | 2023-04-16T12:59:37.096+01:00 | "51678",
  | 2023-04-16T12:59:37.096+01:00 | "51679"
  | 2023-04-16T12:59:37.096+01:00 | ],
  | 2023-04-16T12:59:37.096+01:00 | "name": "PORTS",
  | 2023-04-16T12:59:37.096+01:00 | "type": "STRINGSET"
  | 2023-04-16T12:59:37.096+01:00 | },
  | 2023-04-16T12:59:37.096+01:00 | {
  | 2023-04-16T12:59:37.096+01:00 | "stringSetValue": [],
  | 2023-04-16T12:59:37.096+01:00 | "name": "PORTS_UDP",
  | 2023-04-16T12:59:37.096+01:00 | "type": "STRINGSET"
  | 2023-04-16T12:59:37.096+01:00 | }
  | 2023-04-16T12:59:37.096+01:00 | ],
  | 2023-04-16T12:59:37.096+01:00 | "remainingResources": [
  | 2023-04-16T12:59:37.096+01:00 | {
  | 2023-04-16T12:59:37.096+01:00 | "name": "CPU",
  | 2023-04-16T12:59:37.096+01:00 | "type": "INTEGER",
  | 2023-04-16T12:59:37.096+01:00 | "integerValue": 1024
  | 2023-04-16T12:59:37.096+01:00 | },
  | 2023-04-16T12:59:37.096+01:00 | {
  | 2023-04-16T12:59:37.096+01:00 | "name": "MEMORY",
  | 2023-04-16T12:59:37.096+01:00 | "type": "INTEGER",
  | 2023-04-16T12:59:37.096+01:00 | "integerValue": 970
  | 2023-04-16T12:59:37.096+01:00 | },
  | 2023-04-16T12:59:37.096+01:00 | {
  | 2023-04-16T12:59:37.096+01:00 | "stringSetValue": [
  | 2023-04-16T12:59:37.096+01:00 | "22",
  | 2023-04-16T12:59:37.096+01:00 | "2376",
  | 2023-04-16T12:59:37.096+01:00 | "2375",
  | 2023-04-16T12:59:37.096+01:00 | "51678",
  | 2023-04-16T12:59:37.096+01:00 | "51679"
  | 2023-04-16T12:59:37.096+01:00 | ],
  | 2023-04-16T12:59:37.096+01:00 | "name": "PORTS",
  | 2023-04-16T12:59:37.096+01:00 | "type": "STRINGSET"
  | 2023-04-16T12:59:37.096+01:00 | },
  | 2023-04-16T12:59:37.096+01:00 | {
  | 2023-04-16T12:59:37.096+01:00 | "stringSetValue": [],
  | 2023-04-16T12:59:37.096+01:00 | "name": "PORTS_UDP",
  | 2023-04-16T12:59:37.096+01:00 | "type": "STRINGSET"
  | 2023-04-16T12:59:37.096+01:00 | }
  | 2023-04-16T12:59:37.096+01:00 | ],
  | 2023-04-16T12:59:37.096+01:00 | "status": "DRAINING",
  | 2023-04-16T12:59:37.096+01:00 | "version": 36,
  | 2023-04-16T12:59:37.096+01:00 | "versionInfo": {
  | 2023-04-16T12:59:37.096+01:00 | "agentHash": "<agentHash>",
  | 2023-04-16T12:59:37.096+01:00 | "agentVersion": "1.70.0",
  | 2023-04-16T12:59:37.096+01:00 | "dockerVersion": "DockerVersion: 20.10.17"
  | 2023-04-16T12:59:37.096+01:00 | },
  | 2023-04-16T12:59:37.096+01:00 | "updatedAt": "2023-04-16T11:59:36.836Z"
  | 2023-04-16T12:59:37.096+01:00 | }
  | 2023-04-16T12:59:37.097+01:00 | END RequestId: <END RequestId>
  | 2023-04-16T12:59:37.097+01:00 | REPORT RequestId: <REPORT RequestId> Duration: 1.65 ms Billed Duration: 2 ms Memory Size: 128 MB Max Memory Used: 31 MB

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.

[codecov-commenter]

Codecov Report

Merging #502 (8dbfe7b) into main (81d63bd) will increase coverage by 1.15%.
The diff coverage is 81.25%.

@@            Coverage Diff             @@
##             main     #502      +/-   ##
==========================================
+ Coverage   71.38%   72.53%   +1.15%     
==========================================
  Files          22       25       +3     
  Lines        1307     1391      +84     
==========================================
+ Hits          933     1009      +76     
- Misses        306      312       +6     
- Partials       68       70       +2     

Impacted Files	Coverage Δ
events/ecs_container_instance.go	81.25% <81.25%> (ø)

... and 2 files with indirect coverage changes

Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here.

[bmoffatt]

should it be []string? []*string implies the array is expected to contain nulls

[bmoffatt]

see other comment: #502 (comment) I think schema say []*string was the correct way

[bmoffatt]

I think the schema says you got this right the first time around :) #502 (comment)

[wafuwafu13]

👍 git reset 7316ef1