Function CachedCodeDeployListDeployments

aws/sdk/codedeploy.go:128–174

(client AWSCodeDeployClientInterface, accountID string, region string)

}

func CachedCodeDeployListDeployments(client AWSCodeDeployClientInterface, accountID string, region string) ([]string, error) {
	var PaginationControl *string
	var deployments []string
	cacheKey := fmt.Sprintf("%s-codedeploy-ListDeployments-%s", accountID, region)
	cached, found := internal.Cache.Get(cacheKey)
	if found {
		sharedLogger.WithFields(logrus.Fields{
			"api":     "codedeploy:ListDeployments",
			"account": accountID,
			"region":  region,
			"cache":   "hit",
		}).Info("AWS API call")
		return cached.([]string), nil
	}
	sharedLogger.WithFields(logrus.Fields{
		"api":     "codedeploy:ListDeployments",
		"account": accountID,
		"region":  region,
		"cache":   "miss",
	}).Info("AWS API call")
	for {
		ListDeployments, err := client.ListDeployments(
			context.TODO(),
			&codedeploy.ListDeploymentsInput{
				NextToken: PaginationControl,
			},
			func(o *codedeploy.Options) {
				o.Region = region
			},
		)

		if err != nil {
			return deployments, err
		}

		deployments = append(deployments, ListDeployments.Deployments...)

		//pagination
		if ListDeployments.NextToken == nil {
			break
		}
		PaginationControl = ListDeployments.NextToken
	}

	internal.Cache.Set(cacheKey, deployments, cache.DefaultExpiration)
	return deployments, nil
}

func CachedCodeDeployGetApplication(client AWSCodeDeployClientInterface, accountID string, region string, applicationName string) (codeDeployTypes.ApplicationInfo, error) {
	cacheKey := fmt.Sprintf("%s-codedeploy-GetApplication-%s-%s", accountID, region, applicationName)