CCM-7939: enable high throughput fifo queues

Author: harrim91

infrastructure/modules/sqs/README.md

@@ -16,10 +16,12 @@
 | <a name="input_component"></a> [component](#input\_component) | The name of the tfscaffold component | `string` | n/a | yes |
 | <a name="input_content_based_deduplication"></a> [content\_based\_deduplication](#input\_content\_based\_deduplication) | Enables content-based deduplication for FIFO queues | `bool` | `false` | no |
 | <a name="input_create_dlq"></a> [create\_dlq](#input\_create\_dlq) | Create a DLQ | `bool` | `false` | no |
+| <a name="input_deduplication_scope"></a> [deduplication\_scope](#input\_deduplication\_scope) | For FIFO queues, specifies whether message deduplication occurs at the message group or queue level. Valid values are messageGroup and queue (default). | `string` | `"queue"` | no |
 | <a name="input_default_tags"></a> [default\_tags](#input\_default\_tags) | A map of default tags to apply to all taggable resources within the component | `map(string)` | `{}` | no |
 | <a name="input_delay_seconds"></a> [delay\_seconds](#input\_delay\_seconds) | Time in seconds that the delivery of all messages in the queue will be delayed. An integer from 0 to 900 (15 minutes). | `number` | `0` | no |
 | <a name="input_environment"></a> [environment](#input\_environment) | The name of the tfscaffold environment | `string` | n/a | yes |
 | <a name="input_fifo_queue"></a> [fifo\_queue](#input\_fifo\_queue) | Boolean designating a FIFO queue | `bool` | `false` | no |
+| <a name="input_fifo_throughput_limit"></a> [fifo\_throughput\_limit](#input\_fifo\_throughput\_limit) | For FIFO queues, specifies whether the FIFO queue throughput quota applies to the entire queue or per message group. Valid values are perQueue (default) and perMessageGroupId. | `string` | `"perQueue"` | no |
 | <a name="input_kms_data_key_reuse_period_seconds"></a> [kms\_data\_key\_reuse\_period\_seconds](#input\_kms\_data\_key\_reuse\_period\_seconds) | The length of time, in seconds, for which Amazon SQS can reuse a data key to encrypt or decrypt messages before calling AWS KMS again. An integer representing seconds, between 60 seconds (1 minute) and 86,400 seconds (24 hours) | `number` | `300` | no |
 | <a name="input_max_message_size"></a> [max\_message\_size](#input\_max\_message\_size) | The limit of how many bytes a message can contain before Amazon SQS rejects it. An integer from 1024 bytes (1 KiB) up to 262144 bytes (256 KiB) | `number` | `262144` | no |
 | <a name="input_message_retention_seconds"></a> [message\_retention\_seconds](#input\_message\_retention\_seconds) | The number of seconds Amazon SQS retains a message. Integer representing seconds, from 60 (1 minute) to 1209600 (14 days) | `number` | `null` | no |

infrastructure/modules/sqs/sqs_queue.tf

@@ -7,6 +7,8 @@ resource "aws_sqs_queue" "sqs_queue" {
   fifo_queue                  = var.fifo_queue
   content_based_deduplication = var.content_based_deduplication
   max_message_size            = var.max_message_size
+  deduplication_scope         = var.fifo_queue ? var.deduplication_scope : null
+  fifo_throughput_limit       = var.fifo_queue ? var.fifo_throughput_limit : null
 
   kms_master_key_id                 = var.sqs_kms_key_arn
   kms_data_key_reuse_period_seconds = var.kms_data_key_reuse_period_seconds

infrastructure/modules/sqs/variables.tf

@@ -110,3 +110,24 @@ variable "create_dlq" {
   type        = bool
   default     = false
 }
+
+variable "deduplication_scope" {
+  description = "For FIFO queues, specifies whether message deduplication occurs at the message group or queue level. Valid values are messageGroup and queue (default)."
+  type        = string
+  default     = "queue"
+
+  validation {
+    condition     = contains([], var.deduplication_scope)
+    error_message = "deduplication_scope must be either \"queue\" or \"messageGroup\""
+  }
+}
+variable "fifo_throughput_limit" {
+  description = "For FIFO queues, specifies whether the FIFO queue throughput quota applies to the entire queue or per message group. Valid values are perQueue (default) and perMessageGroupId."
+  type        = string
+  default     = "perQueue"
+
+  validation {
+    condition     = contains([], var.fifo_throughput_limit)
+    error_message = "fifo_throughput_limit must be either \"perQueue\" or \"perMessageGroup\""
+  }
+}