✨ aws.sqs.queues resource

providers/aws/connection/clients.go

@@ -13,6 +13,7 @@ import (
 	"github.com/aws/aws-sdk-go-v2/service/autoscaling"
 	"github.com/aws/aws-sdk-go-v2/service/backup"
 	"github.com/aws/aws-sdk-go-v2/service/inspector2"
+	"github.com/aws/aws-sdk-go-v2/service/sqs"
 
 	"github.com/aws/aws-sdk-go-v2/service/cloudfront"
 	"github.com/aws/aws-sdk-go-v2/service/cloudtrail"
@@ -485,6 +486,30 @@ func (t *AwsConnection) Sns(region string) *sns.Client {
 	return client
 }
 
+func (t *AwsConnection) Sqs(region string) *sqs.Client {
+	// if no region value is sent in, use the configured region
+	if len(region) == 0 {
+		region = t.cfg.Region
+	}
+	cacheVal := "_sqs_" + region
+
+	// check for cached client and return it if it exists
+	c, ok := t.clientcache.Load(cacheVal)
+	if ok {
+		log.Debug().Msg("use cached sqs client")
+		return c.Data.(*sqs.Client)
+	}
+
+	// create the client
+	cfg := t.cfg.Copy()
+	cfg.Region = region
+	client := sqs.NewFromConfig(cfg)
+
+	// cache it
+	t.clientcache.Store(cacheVal, &CacheEntry{Data: client})
+	return client
+}
+
 func (t *AwsConnection) Ssm(region string) *ssm.Client {
 	// if no region value is sent in, use the configured region
 	if len(region) == 0 {

providers/aws/go.mod

@@ -51,6 +51,7 @@ require (
 	github.com/aws/aws-sdk-go-v2/service/secretsmanager v1.29.1
 	github.com/aws/aws-sdk-go-v2/service/securityhub v1.48.4
 	github.com/aws/aws-sdk-go-v2/service/sns v1.29.8
+	github.com/aws/aws-sdk-go-v2/service/sqs v1.32.3
 	github.com/aws/aws-sdk-go-v2/service/ssm v1.50.4
 	github.com/aws/aws-sdk-go-v2/service/sts v1.28.10
 	github.com/aws/aws-sdk-go-v2/service/wafv2 v1.49.1

providers/aws/go.sum

@@ -190,6 +190,8 @@ github.com/aws/aws-sdk-go-v2/service/securityhub v1.48.4 h1:J/5XSSUxCUIy6Ya/1qBe
 github.com/aws/aws-sdk-go-v2/service/securityhub v1.48.4/go.mod h1:Ypax6FsjjJFd0fojZ85aErP+hwfVaXW4gsInyTbwL6Q=
 github.com/aws/aws-sdk-go-v2/service/sns v1.29.8 h1:CQicXbvanE/nn+MJQVuDzBplQSFj7M+gLLtArzDVZS4=
 github.com/aws/aws-sdk-go-v2/service/sns v1.29.8/go.mod h1:oP1vkszM8xdAqHMdBstE5TF3xc+yHwQYrAvkNharymc=
+github.com/aws/aws-sdk-go-v2/service/sqs v1.32.3 h1:K0kIvRVzlVB/7onxMnRoqJkBqRdukIeaQ5GwGAmzggM=
+github.com/aws/aws-sdk-go-v2/service/sqs v1.32.3/go.mod h1:xPN9AEzpZ3Ny+HpzsyLBrdXoTFOz7tig6xuYOQ3A0bQ=
 github.com/aws/aws-sdk-go-v2/service/ssm v1.50.4 h1:SgDxM/2kJEeSavji5ob+oluTPo3CQOQmP56F3yUz/kE=
 github.com/aws/aws-sdk-go-v2/service/ssm v1.50.4/go.mod h1:uRCbiDLweN10yl6W80fLygiLUDTIonz8/RpH+6lsEnY=
 github.com/aws/aws-sdk-go-v2/service/sso v1.20.9 h1:aD7AGQhvPuAxlSUfo0CWU7s6FpkbyykMhGYMvlqTjVs=

providers/aws/resources/aws.lr

@@ -1836,6 +1836,46 @@ private aws.dynamodb.table @defaults("name region") {
   status string
 }
 
+// Amazon Simple Queue Service (SQS)
+aws.sqs {
+  // List of Amazon SQS queues
+  queues() []aws.sqs.queue
+}
+
+// Amazon Simple Queue Service (SQS) Queue
+private aws.sqs.queue {
+  // ARN for the queue
+  arn() string
+  // Time when the queue was created
+  createdAt() time
+  // Dead letter SQS queue, if any
+  deadLetterQueue() aws.sqs.queue
+  // Delay seconds set on the queue
+  deliveryDelaySeconds() int
+  // KMS Key for SSE, if any
+  kmsKey() aws.kms.key
+  // Time when the queue was last modified
+  lastModified() time
+  // Maximum amount of messages that can be received by the queue
+  maxReceiveCount() int
+  // Maximum message size for the queue
+  maximumMessageSize() int
+  // Time in seconds the queue retains messages
+  messageRetentionPeriodSeconds() int
+  // Time in seconds the queue waits for messages
+  receiveMessageWaitTimeSeconds() int
+  // Region for the queue
+  region string
+  // Whether SSE is enabled for the queue
+  sqsManagedSseEnabled() bool
+  // The type of queue: Fifo or Standard
+  queueType() string 
+  // URL for the queue
+  url string
+  // Visibility timeout for the queue
+  visibilityTimeoutSeconds() int
+}
+
 // Amazon Relational Database Service (RDS)
 aws.rds {
   // List of database instances