(apiName string, initialDeploymentTime int64)
| 54 | } |
| 55 | |
| 56 | func apiQueueName(apiName string, initialDeploymentTime int64) string { |
| 57 | // initialDeploymentTime is incorporated so that the queue name changes when doing a deploy after a delete |
| 58 | // (if the queue name doesn't change, the user would have to wait 60 seconds before recreating the queue) |
| 59 | initialDeploymentTimeStr := s.Int64(initialDeploymentTime) |
| 60 | initialDeploymentTimeID := initialDeploymentTimeStr[len(initialDeploymentTimeStr)-10:] |
| 61 | return config.ClusterConfig.SQSNamePrefix() + apiName + clusterconfig.SQSQueueDelimiter + initialDeploymentTimeID + ".fifo" |
| 62 | } |
| 63 | |
| 64 | func deleteQueueByURL(queueURL string) error { |
| 65 | _, err := config.AWS.SQS().DeleteQueue(&sqs.DeleteQueueInput{ |
no test coverage detected