Skip to content

Commit

Permalink
CL-508 Adding support for CloudWatch Insight Rules
Browse files Browse the repository at this point in the history
  • Loading branch information
swhite-oreilly committed Apr 24, 2024
1 parent 89f3f5f commit 244c173
Showing 1 changed file with 66 additions and 0 deletions.
66 changes: 66 additions & 0 deletions resources/cloudwatch-insight-rules.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,66 @@
package resources

import (
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/aws/session"
"github.com/aws/aws-sdk-go/service/cloudwatch"
"github.com/rebuy-de/aws-nuke/v2/pkg/types"
)

type CloudWatchInsightRule struct {
svc *cloudwatch.CloudWatch
name *string
}

func init() {
register("CloudWatchInsightRule", ListCloudWatchInsightRules)
}

func ListCloudWatchInsightRules(sess *session.Session) ([]Resource, error) {
svc := cloudwatch.New(sess)
resources := []Resource{}

params := &cloudwatch.DescribeInsightRulesInput{
MaxResults: aws.Int64(25),
}

for {
output, err := svc.DescribeInsightRules(params)
if err != nil {
return nil, err
}

for _, rules := range output.InsightRules {
resources = append(resources, &CloudWatchInsightRule{
svc: svc,
name: rules.Name,
})
}

if output.NextToken == nil {
break
}

params.NextToken = output.NextToken
}

return resources, nil
}

func (f *CloudWatchInsightRule) Remove() error {
_, err := f.svc.DeleteInsightRules(&cloudwatch.DeleteInsightRulesInput{
RuleNames: []*string{f.name},
})

return err
}

func (f *CloudWatchInsightRule) Properties() types.Properties {
properties := types.NewProperties()
properties.Set("Name", f.name)
return properties
}

func (f *CloudWatchInsightRule) String() string {
return *f.name
}

0 comments on commit 244c173

Please sign in to comment.