feat: Support ECS Managed Daemons

Author: guikcd

.github/workflows/publish-image.yml

@@ -21,7 +21,7 @@ jobs:
       packages: write
     steps:
       - name: Checkout repository
-        uses: actions/checkout@v4
+        uses: actions/checkout@v6
 
       # Uses the `docker/login-action` action to log in to the Container registry registry using the account and password that will publish the packages. Once published, the packages are scoped to the account defined here.
       - name: Log in to the Container registry

.github/workflows/release.yml

@@ -15,12 +15,12 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout code
-        uses: actions/checkout@v4
+        uses: actions/checkout@v6
         with:
           fetch-depth: 0
       # - run: git fetch --force --tags
       - name: Setup GO
-        uses: actions/setup-go@v5
+        uses: actions/setup-go@v6
         with:
           go-version-file: go.mod
       - name: Release

.github/workflows/test.yml

@@ -13,10 +13,10 @@ jobs:
     name: Test
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v4
+      - uses: actions/checkout@v6
 
       - name: Set up Go
-        uses: actions/setup-go@v5
+        uses: actions/setup-go@v6
         with:
           go-version-file: go.mod
 

go.mod

@@ -5,13 +5,13 @@ go 1.26
 require (
 	github.com/BurntSushi/toml v1.4.0
 	github.com/atotto/clipboard v0.1.4
-	github.com/aws/aws-sdk-go-v2 v1.41.7
+	github.com/aws/aws-sdk-go-v2 v1.42.0
 	github.com/aws/aws-sdk-go-v2/config v1.32.17
 	github.com/aws/aws-sdk-go-v2/service/account v1.31.0
 	github.com/aws/aws-sdk-go-v2/service/applicationautoscaling v1.41.13
 	github.com/aws/aws-sdk-go-v2/service/cloudwatch v1.55.2
 	github.com/aws/aws-sdk-go-v2/service/cloudwatchlogs v1.71.1
-	github.com/aws/aws-sdk-go-v2/service/ecs v1.74.0
+	github.com/aws/aws-sdk-go-v2/service/ecs v1.83.0
 	github.com/aws/aws-sdk-go-v2/service/ssm v1.68.3
 	github.com/gdamore/tcell/v2 v2.13.9
 	github.com/keidarcy/aws-regions/v3 v3.0.0-20260309105808-fbc1ba25ea42
@@ -26,16 +26,16 @@ require (
 	github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.7.10 // indirect
 	github.com/aws/aws-sdk-go-v2/credentials v1.19.16 // indirect
 	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.18.23 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.23 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.23 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.29 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.29 // indirect
 	github.com/aws/aws-sdk-go-v2/internal/v4a v1.4.24 // indirect
 	github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.13.9 // indirect
 	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.13.23 // indirect
 	github.com/aws/aws-sdk-go-v2/service/signin v1.0.11 // indirect
 	github.com/aws/aws-sdk-go-v2/service/sso v1.30.17 // indirect
 	github.com/aws/aws-sdk-go-v2/service/ssooidc v1.35.21 // indirect
 	github.com/aws/aws-sdk-go-v2/service/sts v1.42.1 // indirect
-	github.com/aws/smithy-go v1.25.1 // indirect
+	github.com/aws/smithy-go v1.27.1 // indirect
 	github.com/fsnotify/fsnotify v1.7.0 // indirect
 	github.com/gdamore/encoding v1.0.1 // indirect
 	github.com/hashicorp/hcl v1.0.0 // indirect

go.sum

@@ -2,8 +2,8 @@ github.com/BurntSushi/toml v1.4.0 h1:kuoIxZQy2WRRk1pttg9asf+WVv6tWQuBNVmK8+nqPr0
 github.com/BurntSushi/toml v1.4.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
 github.com/atotto/clipboard v0.1.4 h1:EH0zSVneZPSuFR11BlR9YppQTVDbh5+16AmcJi4g1z4=
 github.com/atotto/clipboard v0.1.4/go.mod h1:ZY9tmq7sm5xIbd9bOK4onWV4S6X0u6GY7Vn0Yu86PYI=
-github.com/aws/aws-sdk-go-v2 v1.41.7 h1:DWpAJt66FmnnaRIOT/8ASTucrvuDPZASqhhLey6tLY8=
-github.com/aws/aws-sdk-go-v2 v1.41.7/go.mod h1:4LAfZOPHNVNQEckOACQx60Y8pSRjIkNZQz1w92xpMJc=
+github.com/aws/aws-sdk-go-v2 v1.42.0 h1:XvXMJTkFQtpBKIWZnmr9ZEOc2InWM2yldjXEJ/bymhA=
+github.com/aws/aws-sdk-go-v2 v1.42.0/go.mod h1:27+ACypSLljLAEKsCYOmrjKh83vuTRkuAe9Uv/3A4bg=
 github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.7.10 h1:gx1AwW1Iyk9Z9dD9F4akX5gnN3QZwUB20GGKH/I+Rho=
 github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.7.10/go.mod h1:qqY157uZoqm5OXq/amuaBJyC9hgBCBQnsaWnPe905GY=
 github.com/aws/aws-sdk-go-v2/config v1.32.17 h1:FpL4/758/diKwqbytU0prpuiu60fgXKUWCpDJtApclU=
@@ -12,10 +12,10 @@ github.com/aws/aws-sdk-go-v2/credentials v1.19.16 h1:r3RJBuU7X9ibt8RHbMjWE6y60Qb
 github.com/aws/aws-sdk-go-v2/credentials v1.19.16/go.mod h1:6cx7zqDENJDbBIIWX6P8s0h6hqHC8Avbjh9Dseo27ug=
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.18.23 h1:UuSfcORqNSz/ey3VPRS8TcVH2Ikf0/sC+Hdj400QI6U=
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.18.23/go.mod h1:+G/OSGiOFnSOkYloKj/9M35s74LgVAdJBSD5lsFfqKg=
-github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.23 h1:GpT/TrnBYuE5gan2cZbTtvP+JlHsutdmlV2YfEyNde0=
-github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.23/go.mod h1:xYWD6BS9ywC5bS3sz9Xh04whO/hzK2plt2Zkyrp4JuA=
-github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.23 h1:bpd8vxhlQi2r1hiueOw02f/duEPTMK59Q4QMAoTTtTo=
-github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.23/go.mod h1:15DfR2nw+CRHIk0tqNyifu3G1YdAOy68RftkhMDDwYk=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.29 h1:f3vKqSo13fhTYb+JEcXwXefZQE26I1FB5eTSniU67ko=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.29/go.mod h1:MzoLFUArKGpGD+ukmPiTPG1X5x4o6M2kq4v2dr1FiEc=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.29 h1:RdwIf/CuUsvJX3RgJagbOyotl/cxoLY4xviKuE7p2GY=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.29/go.mod h1:71wt8W2EgswdZy9Mf9KNnzxZ3TiZlv4caKghPktDOkA=
 github.com/aws/aws-sdk-go-v2/internal/v4a v1.4.24 h1:OQqn11BtaYv1WLUowvcA30MpzIu8Ti4pcLPIIyoKZrA=
 github.com/aws/aws-sdk-go-v2/internal/v4a v1.4.24/go.mod h1:X5ZJyfwVrWA96GzPmUCWFQaEARPR7gCrpq2E92PJwAE=
 github.com/aws/aws-sdk-go-v2/service/account v1.31.0 h1:AdQH4Jtf/2gu8h1lyUpwJmhtW/3ppyj4emi/PThI9Zw=
@@ -26,8 +26,8 @@ github.com/aws/aws-sdk-go-v2/service/cloudwatch v1.55.2 h1:mleWBVIxwceEzyItUVoqM
 github.com/aws/aws-sdk-go-v2/service/cloudwatch v1.55.2/go.mod h1:cMApt548kNgu87UsBTNWVv+fpzjbUTFRSFjD1688SBs=
 github.com/aws/aws-sdk-go-v2/service/cloudwatchlogs v1.71.1 h1:p0A8HO2B++3LfOTRxQScOPc3QhFWgyAXQQ6W92RT7Yk=
 github.com/aws/aws-sdk-go-v2/service/cloudwatchlogs v1.71.1/go.mod h1:MLJu3PUd8fp5Qvj4CiLvyY5H8y7kxHKlTp060Wsd+Vc=
-github.com/aws/aws-sdk-go-v2/service/ecs v1.74.0 h1:YS5TXaEvzDb+sV+wdQFUtuCAk0GeFR9Ai6HFdxpz6q8=
-github.com/aws/aws-sdk-go-v2/service/ecs v1.74.0/go.mod h1:10kBgdaNJz0FO/+JWDUH+0rtSjkn5yafgavDDmmhFzs=
+github.com/aws/aws-sdk-go-v2/service/ecs v1.83.0 h1:LQKIHuVHqdbU9LUt5c2G9f+CcQAzolxQmAch3RTORMc=
+github.com/aws/aws-sdk-go-v2/service/ecs v1.83.0/go.mod h1:0vahPCh3slyORHbSuAP8YDyJKLEUQAMX7+bzYGxEnVI=
 github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.13.9 h1:FLudkZLt5ci0ozzgkVo8BJGwvqNaZbTWb3UcucAateA=
 github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.13.9/go.mod h1:w7wZ/s9qK7c8g4al+UyoF1Sp/Z45UwMGcqIzLWVQHWk=
 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.13.23 h1:pbrxO/kuIwgEsOPLkaHu0O+m4fNgLU8B3vxQ+72jTPw=
@@ -42,8 +42,8 @@ github.com/aws/aws-sdk-go-v2/service/ssooidc v1.35.21 h1:+1Kl1zx6bWi4X7cKi3VYh29
 github.com/aws/aws-sdk-go-v2/service/ssooidc v1.35.21/go.mod h1:4vIRDq+CJB2xFAXZ+YgGUTiEft7oAQlhIs71xcSeuVg=
 github.com/aws/aws-sdk-go-v2/service/sts v1.42.1 h1:F/M5Y9I3nwr2IEpshZgh1GeHpOItExNM9L1euNuh/fk=
 github.com/aws/aws-sdk-go-v2/service/sts v1.42.1/go.mod h1:mTNxImtovCOEEuD65mKW7DCsL+2gjEH+RPEAexAzAio=
-github.com/aws/smithy-go v1.25.1 h1:J8ERsGSU7d+aCmdQur5Txg6bVoYelvQJgtZehD12GkI=
-github.com/aws/smithy-go v1.25.1/go.mod h1:YE2RhdIuDbA5E5bTdciG9KrW3+TiEONeUWCqxX9i1Fc=
+github.com/aws/smithy-go v1.27.1 h1:4T340VFndXtADGF52gYa1POyL7s9E4Z1OeZ1hCscIw8=
+github.com/aws/smithy-go v1.27.1/go.mod h1:YE2RhdIuDbA5E5bTdciG9KrW3+TiEONeUWCqxX9i1Fc=
 github.com/cpuguy83/go-md2man/v2 v2.0.4/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=

internal/api/daemon.go

@@ -0,0 +1,112 @@
+package api
+
+import (
+	"context"
+	"log/slog"
+
+	"github.com/aws/aws-sdk-go-v2/service/ecs"
+	"github.com/aws/aws-sdk-go-v2/service/ecs/types"
+)
+
+// Equivalent to
+// aws ecs list-daemons --cluster ${cluster}
+func (store *Store) ListDaemons(clusterArn *string) ([]types.DaemonSummary, error) {
+	limit := int32(100)
+	params := &ecs.ListDaemonsInput{
+		ClusterArn: clusterArn,
+		MaxResults: &limit,
+	}
+
+	results := []types.DaemonSummary{}
+
+	for {
+		output, err := store.ecs.ListDaemons(context.Background(), params)
+		if err != nil {
+			slog.Warn("failed to run aws api to list daemons", "error", err)
+			if len(results) == 0 {
+				return nil, err
+			}
+			break
+		}
+
+		results = append(results, output.DaemonSummariesList...)
+
+		if output.NextToken != nil {
+			params.NextToken = output.NextToken
+		} else {
+			break
+		}
+	}
+
+	return results, nil
+}
+
+// Equivalent to
+// aws ecs describe-daemon --daemon-arn ${daemonArn}
+func (store *Store) DescribeDaemon(daemonArn *string) (*types.DaemonDetail, error) {
+	output, err := store.ecs.DescribeDaemon(context.Background(), &ecs.DescribeDaemonInput{
+		DaemonArn: daemonArn,
+	})
+	if err != nil {
+		slog.Warn("failed to run aws api to describe daemon", "error", err)
+		return nil, err
+	}
+	return output.Daemon, nil
+}
+
+// Equivalent to
+// aws ecs list-daemon-task-definitions --family ${family}
+// aws ecs describe-daemon-task-definition --daemon-task-definition ${arn}
+func (store *Store) ListDaemonTaskDefinitions(family *string) ([]types.DaemonTaskDefinition, error) {
+	limit := int32(20)
+	output, err := store.ecs.ListDaemonTaskDefinitions(context.Background(), &ecs.ListDaemonTaskDefinitionsInput{
+		Family:    family,
+		MaxResults: &limit,
+		Sort:      types.SortOrderDesc,
+	})
+	if err != nil {
+		slog.Warn("failed to run aws api to list daemon task definitions", "error", err)
+		return nil, err
+	}
+
+	results := []types.DaemonTaskDefinition{}
+	for _, summary := range output.DaemonTaskDefinitions {
+		if summary.Arn == nil {
+			continue
+		}
+		td, err := store.DescribeDaemonTaskDefinition(summary.Arn)
+		if err != nil {
+			slog.Warn("failed to describe daemon task definition", "arn", *summary.Arn, "error", err)
+			continue
+		}
+		results = append(results, *td)
+	}
+
+	return results, nil
+}
+
+// Equivalent to
+// aws ecs describe-daemon-task-definition --daemon-task-definition ${arn}
+func (store *Store) DescribeDaemonTaskDefinition(arn *string) (*types.DaemonTaskDefinition, error) {
+	output, err := store.ecs.DescribeDaemonTaskDefinition(context.Background(), &ecs.DescribeDaemonTaskDefinitionInput{
+		DaemonTaskDefinition: arn,
+	})
+	if err != nil {
+		slog.Warn("failed to run aws api to describe daemon task definition", "error", err)
+		return nil, err
+	}
+	return output.DaemonTaskDefinition, nil
+}
+
+// Equivalent to
+// aws ecs describe-daemon-revisions --daemon-revision-arns ${arns}
+func (store *Store) DescribeDaemonRevisions(arns []string) ([]types.DaemonRevision, error) {
+	output, err := store.ecs.DescribeDaemonRevisions(context.Background(), &ecs.DescribeDaemonRevisionsInput{
+		DaemonRevisionArns: arns,
+	})
+	if err != nil {
+		slog.Warn("failed to run aws api to describe daemon revisions", "error", err)
+		return nil, err
+	}
+	return output.DaemonRevisions, nil
+}

internal/view/app.go

@@ -26,20 +26,22 @@ var globalRegion string
 
 // Entity contains ECS resources to show, use uppercase to make items like app.cluster easy to access
 type Entity struct {
-	cluster           *types.Cluster
-	service           *types.Service
-	task              *types.Task
-	container         *types.Container
-	taskDefinition    *types.TaskDefinition
-	events            []types.ServiceEvent
-	metrics           *api.MetricsData
-	autoScaling       *api.AutoScalingData
-	instance          *types.ContainerInstance
-	serviceDeployment *types.ServiceDeployment
-	serviceRevision   *types.ServiceRevision
-	profile           string
-	region            *api.Region
-	entityName        string
+	cluster              *types.Cluster
+	service              *types.Service
+	task                 *types.Task
+	container            *types.Container
+	taskDefinition       *types.TaskDefinition
+	daemonSummary        *types.DaemonSummary
+	daemonTaskDefinition *types.DaemonTaskDefinition
+	events               []types.ServiceEvent
+	metrics              *api.MetricsData
+	autoScaling          *api.AutoScalingData
+	instance             *types.ContainerInstance
+	serviceDeployment    *types.ServiceDeployment
+	serviceRevision      *types.ServiceRevision
+	profile              string
+	region               *api.Region
+	entityName           string
 }
 
 type Option struct {
@@ -287,6 +289,12 @@ func (app *App) getPageHandle() string {
 	switch app.kind {
 	case ServiceKind:
 		name = *app.cluster.ClusterArn
+	case DaemonKind:
+		name = *app.cluster.ClusterArn
+	case DaemonTaskDefinitionKind:
+		if app.daemonSummary != nil && app.daemonSummary.DaemonArn != nil {
+			name = *app.daemonSummary.DaemonArn
+		}
 	case TaskKind, TaskDefinitionKind, ServiceDeploymentKind:
 		name = *app.service.ServiceArn
 	case ContainerKind:
@@ -347,7 +355,7 @@ func (app *App) start() error {
 // Show Primary kind page
 func (app *App) showPrimaryKindPage(k kind, reload bool) error {
 	var err error
-	if k == TaskDefinitionKind {
+	if k == TaskDefinitionKind || k == DaemonTaskDefinitionKind {
 		app.backKind = app.kind
 	}
 	app.kind = k
@@ -364,6 +372,10 @@ func (app *App) showPrimaryKindPage(k kind, reload bool) error {
 		err = app.showContainersPage(reload)
 	case TaskDefinitionKind:
 		err = app.showTaskDefinitionPage(reload)
+	case DaemonKind:
+		err = app.showDaemonsPage(reload)
+	case DaemonTaskDefinitionKind:
+		err = app.showDaemonTaskDefinitionPage(reload)
 	case ServiceDeploymentKind:
 		err = app.showServiceDeploymentPage(reload)
 	default:

internal/view/cluster.go

@@ -13,19 +13,22 @@ import (
 
 type clusterView struct {
 	view
-	clusters []types.Cluster
+	clusters     []types.Cluster
+	daemonCounts map[string]int
 }
 
-func newClusterView(clusters []types.Cluster, app *App) *clusterView {
+func newClusterView(clusters []types.Cluster, daemonCounts map[string]int, app *App) *clusterView {
 	keys := append(basicKeyInputs, []keyDescriptionPair{
 		hotKeyMap["n"],
 		hotKeyMap["N"],
+		hotKeyMap["M"],
 	}...)
 	return &clusterView{
 		view: *newView(app, keys, secondaryPageKeyMap{
 			DescriptionKind: describePageKeys,
 		}),
-		clusters: clusters,
+		clusters:     clusters,
+		daemonCounts: daemonCounts,
 	}
 }
 
@@ -44,7 +47,14 @@ func (app *App) showClustersPage(reload bool) error {
 		resources, err = app.Store.ListClusters()
 	}
 	err = buildResourcePage(resources, app, err, func() resourceViewBuilder {
-		return newClusterView(resources, app)
+		daemonCounts := make(map[string]int)
+		for _, c := range resources {
+			daemons, dErr := app.Store.ListDaemons(c.ClusterArn)
+			if dErr == nil {
+				daemonCounts[*c.ClusterArn] = len(daemons)
+			}
+		}
+		return newClusterView(resources, daemonCounts, app)
 	})
 	return err
 }
@@ -141,6 +151,7 @@ func (v *clusterView) tableParamsBuilder() (title string, headers []string, rows
 		"Name",
 		"Status",
 		"Services",
+		"Daemons",
 		"Tasks",
 		"Container instances",
 		"Capacity providers",
@@ -151,10 +162,13 @@ func (v *clusterView) tableParamsBuilder() (title string, headers []string, rows
 			// calculate tasks
 			tasks := fmt.Sprintf(color.TableClusterTasksFmt, c.PendingTasksCount, c.RunningTasksCount)
 
+			daemonCount := v.daemonCounts[*c.ClusterArn]
+
 			row := []string{}
 			row = append(row, utils.ShowString(c.ClusterName))
 			row = append(row, utils.ShowGreenGrey(c.Status, "active"))
 			row = append(row, utils.ShowInt(&c.ActiveServicesCount))
+			row = append(row, strconv.Itoa(daemonCount))
 			row = append(row, tasks)
 			row = append(row, utils.ShowInt(&c.RegisteredContainerInstancesCount)+" EC2")
 			row = append(row, utils.ShowArray(c.CapacityProviders))

internal/view/cluster_test.go

@@ -45,8 +45,8 @@ func getClusterViews() []clusterView {
 	cluster2.ActiveServicesCount = *clusterServices2
 
 	app, _ := newApp(Option{})
-	clusterView1 := newClusterView([]types.Cluster{cluster1}, app)
-	clusterView2 := newClusterView([]types.Cluster{cluster2}, app)
+	clusterView1 := newClusterView([]types.Cluster{cluster1}, map[string]int{}, app)
+	clusterView2 := newClusterView([]types.Cluster{cluster2}, map[string]int{}, app)
 
 	return []clusterView{*clusterView1, *clusterView2}
 }