Function getQueueURL

pkg/operator/resources/asyncapi/queue.go:75–85

(apiName string, initialDeploymentTime int64)

}

func getQueueURL(apiName string, initialDeploymentTime int64) (string, error) {
	operatorAccountID, _, err := config.AWS.GetCachedAccountID()
	if err != nil {
		return "", errors.Wrap(err, "failed to construct queue url", "unable to get account id")
	}

	return fmt.Sprintf(
		"https://sqs.%s.amazonaws.com/%s/%s",
		config.AWS.Region, operatorAccountID, apiQueueName(apiName, initialDeploymentTime),
	), nil
}