aws

package
v0.0.0-...-7ec6de2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 14, 2023 License: Apache-2.0 Imports: 47 Imported by: 0

Documentation

Overview

Package aws allows to interact with resources on Amazon Web Services.

Index

Constants

View Source
const (
	CanonicalAccountId = "099720109477"
	CentOsAccountId    = "679593333241"
	AmazonAccountId    = "amazon"
)

These are commonly used AMI account IDs.

View Source
const (
	AuthAssumeRoleEnvVar = "TERRATEST_IAM_ROLE" // OS environment variable name through which Assume Role ARN may be passed for authentication
)

Variables

This section is empty.

Functions

func AddTagsToResource

func AddTagsToResource(t testing.TestingT, region string, resource string, tags map[string]string)

AddTagsToResource adds the tags to the given taggable AWS resource such as EC2, AMI or VPC.

func AddTagsToResourceE

func AddTagsToResourceE(t testing.TestingT, region string, resource string, tags map[string]string) error

AddTagsToResourceE adds the tags to the given taggable AWS resource such as EC2, AMI or VPC.

func AssertS3BucketExists

func AssertS3BucketExists(t testing.TestingT, region string, name string)

AssertS3BucketExists checks if the given S3 bucket exists in the given region and fail the test if it does not.

func AssertS3BucketExistsE

func AssertS3BucketExistsE(t testing.TestingT, region string, name string) error

AssertS3BucketExistsE checks if the given S3 bucket exists in the given region and return an error if it does not.

func AssertS3BucketPolicyExists

func AssertS3BucketPolicyExists(t testing.TestingT, region string, bucketName string)

AssertS3BucketPolicyExists checks if the given S3 bucket has a resource policy attached and returns an error if it does not

func AssertS3BucketPolicyExistsE

func AssertS3BucketPolicyExistsE(t testing.TestingT, region string, bucketName string) error

AssertS3BucketPolicyExistsE checks if the given S3 bucket has a resource policy attached and returns an error if it does not

func AssertS3BucketVersioningExists

func AssertS3BucketVersioningExists(t testing.TestingT, region string, bucketName string)

AssertS3BucketVersioningExists checks if the given S3 bucket has a versioning configuration enabled and returns an error if it does not.

func AssertS3BucketVersioningExistsE

func AssertS3BucketVersioningExistsE(t testing.TestingT, region string, bucketName string) error

AssertS3BucketVersioningExistsE checks if the given S3 bucket has a versioning configuration enabled and returns an error if it does not.

func AssumeRole

func AssumeRole(sess *session.Session, roleARN string) *session.Session

AssumeRole mutates the provided session by obtaining new credentials by assuming the role provided in roleARN.

func CreateAwsCredentials

func CreateAwsCredentials(accessKeyID string, secretAccessKey string) *credentials.Credentials

CreateAwsCredentials creates an AWS Credentials configuration with specific AWS credentials.

func CreateAwsCredentialsWithSessionToken

func CreateAwsCredentialsWithSessionToken(accessKeyID, secretAccessKey, sessionToken string) *credentials.Credentials

CreateAwsCredentialsWithSessionToken creates an AWS Credentials configuration with temporary AWS credentials by including a session token (used for authenticating with MFA).

func CreateAwsSessionFromRole

func CreateAwsSessionFromRole(region string, roleARN string) (*session.Session, error)

CreateAwsSessionFromRole returns a new AWS session after assuming the role whose ARN is provided in roleARN.

func CreateAwsSessionWithCreds

func CreateAwsSessionWithCreds(region string, accessKeyID string, secretAccessKey string) (*session.Session, error)

CreateAwsSessionWithCreds creates a new AWS session using explicit credentials. This is useful if you want to create an IAM User dynamically and create an AWS session authenticated as the new IAM User.

func CreateAwsSessionWithMfa

func CreateAwsSessionWithMfa(region string, stsClient *sts.STS, mfaDevice *iam.VirtualMFADevice) (*session.Session, error)

CreateAwsSessionWithMfa creates a new AWS session authenticated using an MFA token retrieved using the given STS client and MFA Device.

func CreateECRRepo

func CreateECRRepo(t testing.TestingT, region string, name string) *ecr.Repository

CreateECRRepo creates a new ECR Repository. This will fail the test and stop execution if there is an error.

func CreateECRRepoE

func CreateECRRepoE(t testing.TestingT, region string, name string) (*ecr.Repository, error)

CreateECRRepoE creates a new ECR Repository.

func CreateEcsCluster

func CreateEcsCluster(t testing.TestingT, region string, name string) *ecs.Cluster

CreateEcsCluster creates ECS cluster in the given region under the given name.

func CreateEcsClusterE

func CreateEcsClusterE(t testing.TestingT, region string, name string) (*ecs.Cluster, error)

CreateEcsClusterE creates ECS cluster in the given region under the given name.

func CreateMfaDevice

func CreateMfaDevice(t testing.TestingT, iamClient *iam.IAM, deviceName string) *iam.VirtualMFADevice

CreateMfaDevice creates an MFA device using the given IAM client.

func CreateMfaDeviceE

func CreateMfaDeviceE(t testing.TestingT, iamClient *iam.IAM, deviceName string) (*iam.VirtualMFADevice, error)

CreateMfaDeviceE creates an MFA device using the given IAM client.

func CreateRandomFifoQueue

func CreateRandomFifoQueue(t testing.TestingT, awsRegion string, prefix string) string

CreateRandomFifoQueue creates a new FIFO SQS queue with a random name that starts with the given prefix and return the queue URL.

func CreateRandomFifoQueueE

func CreateRandomFifoQueueE(t testing.TestingT, awsRegion string, prefix string) (string, error)

CreateRandomFifoQueueE creates a new FIFO SQS queue with a random name that starts with the given prefix and return the queue URL.

func CreateRandomQueue

func CreateRandomQueue(t testing.TestingT, awsRegion string, prefix string) string

CreateRandomQueue creates a new SQS queue with a random name that starts with the given prefix and return the queue URL.

func CreateRandomQueueE

func CreateRandomQueueE(t testing.TestingT, awsRegion string, prefix string) (string, error)

CreateRandomQueueE creates a new SQS queue with a random name that starts with the given prefix and return the queue URL.

func CreateS3Bucket

func CreateS3Bucket(t testing.TestingT, region string, name string)

CreateS3Bucket creates an S3 bucket in the given region with the given name. Note that S3 bucket names must be globally unique.

func CreateS3BucketE

func CreateS3BucketE(t testing.TestingT, region string, name string) error

CreateS3BucketE creates an S3 bucket in the given region with the given name. Note that S3 bucket names must be globally unique.

func CreateSecretStringWithDefaultKey

func CreateSecretStringWithDefaultKey(t testing.TestingT, awsRegion, description, name, secretString string) string

CreateSecretStringWithDefaultKey creates a new secret in Secrets Manager using the default "aws/secretsmanager" KMS key and returns the secret ARN

func CreateSecretStringWithDefaultKeyE

func CreateSecretStringWithDefaultKeyE(t testing.TestingT, awsRegion, description, name, secretString string) (string, error)

CreateSecretStringWithDefaultKeyE creates a new secret in Secrets Manager using the default "aws/secretsmanager" KMS key and returns the secret ARN

func CreateSnsTopic

func CreateSnsTopic(t testing.TestingT, region string, snsTopicName string) string

CreateSnsTopic creates an SNS Topic and return the ARN.

func CreateSnsTopicE

func CreateSnsTopicE(t testing.TestingT, region string, snsTopicName string) (string, error)

CreateSnsTopicE creates an SNS Topic and return the ARN.

func DeleteAmi

func DeleteAmi(t testing.TestingT, region string, imageID string)

DeleteAmi deletes the given AMI in the given region.

func DeleteAmiAndAllSnapshots

func DeleteAmiAndAllSnapshots(t testing.TestingT, region string, ami string)

DeleteAmiAndAllSnapshots will delete the given AMI along with all EBS snapshots that backed that AMI

func DeleteAmiAndAllSnapshotsE

func DeleteAmiAndAllSnapshotsE(t testing.TestingT, region string, ami string) error

DeleteAmiAndAllSnapshotsE will delete the given AMI along with all EBS snapshots that backed that AMI

func DeleteAmiE

func DeleteAmiE(t testing.TestingT, region string, imageID string) error

DeleteAmiE deletes the given AMI in the given region.

func DeleteEC2KeyPair

func DeleteEC2KeyPair(t testing.TestingT, keyPair *Ec2Keypair)

DeleteEC2KeyPair deletes an EC2 key pair.

func DeleteEC2KeyPairE

func DeleteEC2KeyPairE(t testing.TestingT, keyPair *Ec2Keypair) error

DeleteEC2KeyPairE deletes an EC2 key pair.

func DeleteECRRepo

func DeleteECRRepo(t testing.TestingT, region string, repo *ecr.Repository)

DeleteECRRepo will force delete the ECR repo by deleting all images prior to deleting the ECR repository. This will fail the test and stop execution if there is an error.

func DeleteECRRepoE

func DeleteECRRepoE(t testing.TestingT, region string, repo *ecr.Repository) error

DeleteECRRepoE will force delete the ECR repo by deleting all images prior to deleting the ECR repository.

func DeleteEbsSnapshot

func DeleteEbsSnapshot(t testing.TestingT, region string, snapshot string)

DeleteEbsSnapshot deletes the given EBS snapshot

func DeleteEbsSnapshotE

func DeleteEbsSnapshotE(t testing.TestingT, region string, snapshot string) error

DeleteEbsSnapshot deletes the given EBS snapshot

func DeleteEcsCluster

func DeleteEcsCluster(t testing.TestingT, region string, cluster *ecs.Cluster)

func DeleteEcsClusterE

func DeleteEcsClusterE(t testing.TestingT, region string, cluster *ecs.Cluster) error

DeleteEcsClusterE deletes existing ECS cluster in the given region.

func DeleteMessageFromQueue

func DeleteMessageFromQueue(t testing.TestingT, awsRegion string, queueURL string, receipt string)

DeleteMessageFromQueue deletes the message with the given receipt from the SQS queue with the given URL.

func DeleteMessageFromQueueE

func DeleteMessageFromQueueE(t testing.TestingT, awsRegion string, queueURL string, receipt string) error

DeleteMessageFromQueueE deletes the message with the given receipt from the SQS queue with the given URL.

func DeleteParameter

func DeleteParameter(t testing.TestingT, awsRegion string, keyName string)

DeleteParameter deletes all versions of SSM Parameter at keyName.

func DeleteParameterE

func DeleteParameterE(t testing.TestingT, awsRegion string, keyName string) error

DeleteParameterE deletes all versions of SSM Parameter at keyName.

func DeleteParameterWithClientE

func DeleteParameterWithClientE(t testing.TestingT, client *ssm.SSM, keyName string) error

DeleteParameterE deletes all versions of SSM Parameter at keyName with the ability to provide the SSM client.

func DeleteQueue

func DeleteQueue(t testing.TestingT, awsRegion string, queueURL string)

DeleteQueue deletes the SQS queue with the given URL.

func DeleteQueueE

func DeleteQueueE(t testing.TestingT, awsRegion string, queueURL string) error

DeleteQueueE deletes the SQS queue with the given URL.

func DeleteS3Bucket

func DeleteS3Bucket(t testing.TestingT, region string, name string)

DeleteS3Bucket destroys the S3 bucket in the given region with the given name.

func DeleteS3BucketE

func DeleteS3BucketE(t testing.TestingT, region string, name string) error

DeleteS3BucketE destroys the S3 bucket in the given region with the given name.

func DeleteSNSTopic

func DeleteSNSTopic(t testing.TestingT, region string, snsTopicArn string)

DeleteSNSTopic deletes an SNS Topic.

func DeleteSNSTopicE

func DeleteSNSTopicE(t testing.TestingT, region string, snsTopicArn string) error

DeleteSNSTopicE deletes an SNS Topic.

func DeleteSecret

func DeleteSecret(t testing.TestingT, awsRegion, id string, forceDelete bool)

DeleteSecret deletes a secret. If forceDelete is true, the secret will be deleted after a short delay. If forceDelete is false, the secret will be deleted after a 30 day recovery window.

func DeleteSecretE

func DeleteSecretE(t testing.TestingT, awsRegion, id string, forceDelete bool) error

DeleteSecretE deletes a secret. If forceDelete is true, the secret will be deleted after a short delay. If forceDelete is false, the secret will be deleted after a 30 day recovery window.

func EmptyS3Bucket

func EmptyS3Bucket(t testing.TestingT, region string, name string)

EmptyS3Bucket removes the contents of an S3 bucket in the given region with the given name.

func EmptyS3BucketE

func EmptyS3BucketE(t testing.TestingT, region string, name string) error

EmptyS3BucketE removes the contents of an S3 bucket in the given region with the given name.

func EnableMfaDevice

func EnableMfaDevice(t testing.TestingT, iamClient *iam.IAM, mfaDevice *iam.VirtualMFADevice)

EnableMfaDevice enables a newly created MFA Device by supplying the first two one-time passwords, so that it can be used for future logins by the given IAM User.

func EnableMfaDeviceE

func EnableMfaDeviceE(t testing.TestingT, iamClient *iam.IAM, mfaDevice *iam.VirtualMFADevice) error

EnableMfaDeviceE enables a newly created MFA Device by supplying the first two one-time passwords, so that it can be used for future logins by the given IAM User.

func FetchContentsOfFileFromAsg

func FetchContentsOfFileFromAsg(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, asgName string, useSudo bool, filePath string) map[string]string

FetchContentsOfFileFromAsg looks up the EC2 Instances in the given ASG, looks up the public IPs of those EC2 Instances, connects to each Instance via SSH using the given username and Key Pair, fetches the contents of the file at the given path (using sudo if useSudo is true), and returns a map from Instance ID to the contents of that file as a string.

func FetchContentsOfFileFromAsgE

func FetchContentsOfFileFromAsgE(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, asgName string, useSudo bool, filePath string) (map[string]string, error)

FetchContentsOfFileFromAsgE looks up the EC2 Instances in the given ASG, looks up the public IPs of those EC2 Instances, connects to each Instance via SSH using the given username and Key Pair, fetches the contents of the file at the given path (using sudo if useSudo is true), and returns a map from Instance ID to the contents of that file as a string.

func FetchContentsOfFileFromInstance

func FetchContentsOfFileFromInstance(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, instanceID string, useSudo bool, filePath string) string

FetchContentsOfFileFromInstance looks up the public IP address of the EC2 Instance with the given ID, connects to the Instance via SSH using the given username and Key Pair, fetches the contents of the file at the given path (using sudo if useSudo is true), and returns the contents of that file as a string.

func FetchContentsOfFileFromInstanceE

func FetchContentsOfFileFromInstanceE(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, instanceID string, useSudo bool, filePath string) (string, error)

FetchContentsOfFileFromInstanceE looks up the public IP address of the EC2 Instance with the given ID, connects to the Instance via SSH using the given username and Key Pair, fetches the contents of the file at the given path (using sudo if useSudo is true), and returns the contents of that file as a string.

func FetchContentsOfFilesFromAsg

func FetchContentsOfFilesFromAsg(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, asgName string, useSudo bool, filePaths ...string) map[string]map[string]string

FetchContentsOfFilesFromAsg looks up the EC2 Instances in the given ASG, looks up the public IPs of those EC2 Instances, connects to each Instance via SSH using the given username and Key Pair, fetches the contents of the files at the given paths (using sudo if useSudo is true), and returns a map from Instance ID to a map of file path to the contents of that file as a string.

func FetchContentsOfFilesFromAsgE

func FetchContentsOfFilesFromAsgE(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, asgName string, useSudo bool, filePaths ...string) (map[string]map[string]string, error)

FetchContentsOfFilesFromAsgE looks up the EC2 Instances in the given ASG, looks up the public IPs of those EC2 Instances, connects to each Instance via SSH using the given username and Key Pair, fetches the contents of the files at the given paths (using sudo if useSudo is true), and returns a map from Instance ID to a map of file path to the contents of that file as a string.

func FetchContentsOfFilesFromInstance

func FetchContentsOfFilesFromInstance(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, instanceID string, useSudo bool, filePaths ...string) map[string]string

FetchContentsOfFilesFromInstance looks up the public IP address of the EC2 Instance with the given ID, connects to the Instance via SSH using the given username and Key Pair, fetches the contents of the files at the given paths (using sudo if useSudo is true), and returns a map from file path to the contents of that file as a string.

func FetchContentsOfFilesFromInstanceE

func FetchContentsOfFilesFromInstanceE(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, instanceID string, useSudo bool, filePaths ...string) (map[string]string, error)

FetchContentsOfFilesFromInstanceE looks up the public IP address of the EC2 Instance with the given ID, connects to the Instance via SSH using the given username and Key Pair, fetches the contents of the files at the given paths (using sudo if useSudo is true), and returns a map from file path to the contents of that file as a string.

func FetchFilesFromAsgs

func FetchFilesFromAsgs(t testing.TestingT, awsRegion string, spec RemoteFileSpecification)

FetchFilesFromAsgs looks up the EC2 Instances in all the ASGs given in the RemoteFileSpecification, looks up the public IPs of those EC2 Instances, connects to each Instance via SSH using the given username and Key Pair, downloads the files matching filenameFilters at the given remoteDirectory (using sudo if useSudo is true), and stores the files locally at localDirectory/<publicip>/<remoteFolderName>

func FetchFilesFromAsgsE

func FetchFilesFromAsgsE(t testing.TestingT, awsRegion string, spec RemoteFileSpecification) error

FetchFilesFromAsgsE looks up the EC2 Instances in all the ASGs given in the RemoteFileSpecification, looks up the public IPs of those EC2 Instances, connects to each Instance via SSH using the given username and Key Pair, downloads the files matching filenameFilters at the given remoteDirectory (using sudo if useSudo is true), and stores the files locally at localDirectory/<publicip>/<remoteFolderName>

func FetchFilesFromInstance

func FetchFilesFromInstance(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, instanceID string, useSudo bool, remoteDirectory string, localDirectory string, filenameFilters []string)

FetchFilesFromInstance looks up the EC2 Instances in the given ASG, looks up the public IPs of those EC2 Instances, connects to each Instance via SSH using the given username and Key Pair, downloads the files matching filenameFilters at the given remoteDirectory (using sudo if useSudo is true), and stores the files locally at localDirectory/<publicip>/<remoteFolderName>

func FetchFilesFromInstanceE

func FetchFilesFromInstanceE(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, instanceID string, useSudo bool, remoteDirectory string, localDirectory string, filenameFilters []string) error

FetchFilesFromInstanceE looks up the EC2 Instances in the given ASG, looks up the public IPs of those EC2 Instances, connects to each Instance via SSH using the given username and Key Pair, downloads the files matching filenameFilters at the given remoteDirectory (using sudo if useSudo is true), and stores the files locally at localDirectory/<publicip>/<remoteFolderName>

func FindS3BucketWithTag

func FindS3BucketWithTag(t testing.TestingT, awsRegion string, key string, value string) string

FindS3BucketWithTag finds the name of the S3 bucket in the given region with the given tag key=value.

func FindS3BucketWithTagE

func FindS3BucketWithTagE(t testing.TestingT, awsRegion string, key string, value string) (string, error)

FindS3BucketWithTagE finds the name of the S3 bucket in the given region with the given tag key=value.

func FindVpcName

func FindVpcName(vpc *ec2.Vpc) string

FindVpcName extracts the VPC name from its tags (if any). Fall back to "Default" if it's the default VPC or empty string otherwise.

func GetAccountId

func GetAccountId(t testing.TestingT) string

GetAccountId gets the Account ID for the currently logged in IAM User.

func GetAccountIdE

func GetAccountIdE(t testing.TestingT) (string, error)

GetAccountIdE gets the Account ID for the currently logged in IAM User.

func GetAccountsWithLaunchPermissionsForAmi

func GetAccountsWithLaunchPermissionsForAmi(t testing.TestingT, awsRegion string, amiID string) []string

GetAccountsWithLaunchPermissionsForAmi returns list of accounts that the AMI is shared with

func GetAccountsWithLaunchPermissionsForAmiE

func GetAccountsWithLaunchPermissionsForAmiE(t testing.TestingT, awsRegion string, amiID string) ([]string, error)

GetAccountsWithLaunchPermissionsForAmiE returns list of accounts that the AMI is shared with

func GetAcmCertificateArn

func GetAcmCertificateArn(t testing.TestingT, awsRegion string, certDomainName string) string

GetAcmCertificateArn gets the ACM certificate for the given domain name in the given region.

func GetAcmCertificateArnE

func GetAcmCertificateArnE(t testing.TestingT, awsRegion string, certDomainName string) (string, error)

GetAcmCertificateArnE gets the ACM certificate for the given domain name in the given region.

func GetAddressOfRdsInstance

func GetAddressOfRdsInstance(t testing.TestingT, dbInstanceID string, awsRegion string) string

GetAddressOfRdsInstance gets the address of the given RDS Instance in the given region.

func GetAddressOfRdsInstanceE

func GetAddressOfRdsInstanceE(t testing.TestingT, dbInstanceID string, awsRegion string) (string, error)

GetAddressOfRdsInstanceE gets the address of the given RDS Instance in the given region.

func GetAllAwsRegions

func GetAllAwsRegions(t testing.TestingT) []string

GetAllAwsRegions gets the list of AWS regions available in this account.

func GetAllAwsRegionsE

func GetAllAwsRegionsE(t testing.TestingT) ([]string, error)

GetAllAwsRegionsE gets the list of AWS regions available in this account.

func GetAllParametersOfRdsInstance

func GetAllParametersOfRdsInstance(t testing.TestingT, dbInstanceID string, awsRegion string) []*rds.Parameter

GetAllParametersOfRdsInstance gets all the parameters defined in the parameter group for the RDS instance in the given region.

func GetAllParametersOfRdsInstanceE

func GetAllParametersOfRdsInstanceE(t testing.TestingT, dbInstanceID string, awsRegion string) ([]*rds.Parameter, error)

GetAllParametersOfRdsInstanceE gets all the parameters defined in the parameter group for the RDS instance in the given region.

func GetAmazonLinuxAmi

func GetAmazonLinuxAmi(t testing.TestingT, region string) string

GetAmazonLinuxAmi returns an Amazon Linux AMI HVM, SSD Volume Type public AMI for the given region.

func GetAmazonLinuxAmiE

func GetAmazonLinuxAmiE(t testing.TestingT, region string) (string, error)

GetAmazonLinuxAmiE returns an Amazon Linux AMI HVM, SSD Volume Type public AMI for the given region.

func GetAmiPubliclyAccessible

func GetAmiPubliclyAccessible(t testing.TestingT, awsRegion string, amiID string) bool

GetAmiPubliclyAccessible returns whether the AMI is publicly accessible or not

func GetAmiPubliclyAccessibleE

func GetAmiPubliclyAccessibleE(t testing.TestingT, awsRegion string, amiID string) (bool, error)

GetAmiPubliclyAccessibleE returns whether the AMI is publicly accessible or not

func GetAvailabilityZones

func GetAvailabilityZones(t testing.TestingT, region string) []string

GetAvailabilityZones gets the Availability Zones for a given AWS region. Note that for certain regions (e.g. us-east-1), different AWS accounts have access to different availability zones.

func GetAvailabilityZonesE

func GetAvailabilityZonesE(t testing.TestingT, region string) ([]string, error)

GetAvailabilityZonesE gets the Availability Zones for a given AWS region. Note that for certain regions (e.g. us-east-1), different AWS accounts have access to different availability zones.

func GetCentos7Ami

func GetCentos7Ami(t testing.TestingT, region string) string

GetCentos7Ami returns a CentOS 7 public AMI from the given region. WARNING: you may have to accept the terms & conditions of this AMI in AWS MarketPlace for your AWS Account before you can successfully launch the AMI.

func GetCentos7AmiE

func GetCentos7AmiE(t testing.TestingT, region string) (string, error)

GetCentos7AmiE returns a CentOS 7 public AMI from the given region. WARNING: you may have to accept the terms & conditions of this AMI in AWS MarketPlace for your AWS Account before you can successfully launch the AMI.

func GetCloudWatchLogEntries

func GetCloudWatchLogEntries(t testing.TestingT, awsRegion string, logStreamName string, logGroupName string) []string

GetCloudWatchLogEntries returns the CloudWatch log messages in the given region for the given log stream and log group.

func GetCloudWatchLogEntriesE

func GetCloudWatchLogEntriesE(t testing.TestingT, awsRegion string, logStreamName string, logGroupName string) ([]string, error)

GetCloudWatchLogEntriesE returns the CloudWatch log messages in the given region for the given log stream and log group.

func GetCmkArn

func GetCmkArn(t testing.TestingT, region string, cmkID string) string

GetCmkArn gets the ARN of a KMS Customer Master Key (CMK) in the given region with the given ID. The ID can be an alias, such as "alias/my-cmk".

func GetCmkArnE

func GetCmkArnE(t testing.TestingT, region string, cmkID string) (string, error)

GetCmkArnE gets the ARN of a KMS Customer Master Key (CMK) in the given region with the given ID. The ID can be an alias, such as "alias/my-cmk".

func GetDefaultEcsCluster

func GetDefaultEcsCluster(t testing.TestingT, region string) *ecs.Cluster

GetDefaultEcsCluster fetches information about default ECS cluster.

func GetDefaultEcsClusterE

func GetDefaultEcsClusterE(t testing.TestingT, region string) (*ecs.Cluster, error)

GetDefaultEcsClusterE fetches information about default ECS cluster.

func GetDefaultSubnetIDsForVpc

func GetDefaultSubnetIDsForVpc(t testing.TestingT, vpc Vpc) []string

GetDefaultSubnetIDsForVpc gets the ids of the subnets that are the default subnet for the AvailabilityZone

func GetDefaultSubnetIDsForVpcE

func GetDefaultSubnetIDsForVpcE(t testing.TestingT, vpc Vpc) ([]string, error)

GetDefaultSubnetIDsForVpcE gets the ids of the subnets that are the default subnet for the AvailabilityZone

func GetDynamoDBTable

func GetDynamoDBTable(t testing.TestingT, region string, tableName string) *dynamodb.TableDescription

GetDynamoDBTable fetches information about the specified dynamoDB table. This will fail the test if there are any errors.

func GetDynamoDBTableE

func GetDynamoDBTableE(t testing.TestingT, region string, tableName string) (*dynamodb.TableDescription, error)

GetDynamoDBTableE fetches information about the specified dynamoDB table.

func GetDynamoDBTableTimeToLive

func GetDynamoDBTableTimeToLive(t testing.TestingT, region string, tableName string) *dynamodb.TimeToLiveDescription

GetDynamoDBTableTimeToLive fetches information about the TTL configuration of a specified dynamoDB table. This will fail the test if there are any errors.

func GetDynamoDBTableTimeToLiveE

func GetDynamoDBTableTimeToLiveE(t testing.TestingT, region string, tableName string) (*dynamodb.TimeToLiveDescription, error)

GetDynamoDBTableTimeToLiveE fetches information about the TTL configuration of a specified dynamoDB table.

func GetDynamoDbTableTags

func GetDynamoDbTableTags(t testing.TestingT, region string, tableName string) []*dynamodb.Tag

GetDynamoDbTableTags fetches resource tags of a specified dynamoDB table. This will fail the test if there are any errors

func GetDynamoDbTableTagsE

func GetDynamoDbTableTagsE(t testing.TestingT, region string, tableName string) ([]*dynamodb.Tag, error)

GetDynamoDbTableTagsE fetches resource tags of a specified dynamoDB table.

func GetECRRepo

func GetECRRepo(t testing.TestingT, region string, name string) *ecr.Repository

GetECRRepo gets an ECR repository by name. This will fail the test and stop execution if there is an error. An error occurs if a repository with the given name does not exist in the given region.

func GetECRRepoE

func GetECRRepoE(t testing.TestingT, region string, name string) (*ecr.Repository, error)

GetECRRepoE gets an ECR Repository by name. An error occurs if a repository with the given name does not exist in the given region.

func GetECRRepoLifecyclePolicy

func GetECRRepoLifecyclePolicy(t testing.TestingT, region string, repo *ecr.Repository) string

GetECRRepoLifecyclePolicy gets the policies for the given ECR repository. This will fail the test and stop execution if there is an error.

func GetECRRepoLifecyclePolicyE

func GetECRRepoLifecyclePolicyE(t testing.TestingT, region string, repo *ecr.Repository) (string, error)

GetECRRepoLifecyclePolicyE gets the policies for the given ECR repository.

func GetEbsSnapshotsForAmi

func GetEbsSnapshotsForAmi(t testing.TestingT, region string, ami string) []string

GetEbsSnapshotsForAmi retrieves the EBS snapshots which back the given AMI

func GetEbsSnapshotsForAmiE

func GetEbsSnapshotsForAmiE(t testing.TestingT, region string, ami string) ([]string, error)

GetEbsSnapshotsForAmi retrieves the EBS snapshots which back the given AMI

func GetEc2InstanceIdsByFilters

func GetEc2InstanceIdsByFilters(t testing.TestingT, region string, ec2Filters map[string][]string) []string

GetEc2InstanceIdsByFilters returns all the IDs of EC2 instances in the given region which match to EC2 filter list as per https://docs.aws.amazon.com/sdk-for-go/api/service/ec2/#DescribeInstancesInput.

func GetEc2InstanceIdsByFiltersE

func GetEc2InstanceIdsByFiltersE(t testing.TestingT, region string, ec2Filters map[string][]string) ([]string, error)

GetEc2InstanceIdsByFilters returns all the IDs of EC2 instances in the given region which match to EC2 filter list as per https://docs.aws.amazon.com/sdk-for-go/api/service/ec2/#DescribeInstancesInput.

func GetEc2InstanceIdsByTag

func GetEc2InstanceIdsByTag(t testing.TestingT, region string, tagName string, tagValue string) []string

GetEc2InstanceIdsByTag returns all the IDs of EC2 instances in the given region with the given tag.

func GetEc2InstanceIdsByTagE

func GetEc2InstanceIdsByTagE(t testing.TestingT, region string, tagName string, tagValue string) ([]string, error)

GetEc2InstanceIdsByTagE returns all the IDs of EC2 instances in the given region with the given tag.

func GetEcsCluster

func GetEcsCluster(t testing.TestingT, region string, name string) *ecs.Cluster

GetEcsCluster fetches information about specified ECS cluster.

func GetEcsClusterE

func GetEcsClusterE(t testing.TestingT, region string, name string) (*ecs.Cluster, error)

GetEcsClusterE fetches information about specified ECS cluster.

func GetEcsClusterWithInclude

func GetEcsClusterWithInclude(t testing.TestingT, region string, name string, include []string) *ecs.Cluster

GetEcsClusterWithInclude fetches extended information about specified ECS cluster. The `include` parameter specifies a list of `ecs.ClusterField*` constants, such as `ecs.ClusterFieldTags`.

func GetEcsClusterWithIncludeE

func GetEcsClusterWithIncludeE(t testing.TestingT, region string, name string, include []string) (*ecs.Cluster, error)

GetEcsClusterWithIncludeE fetches extended information about specified ECS cluster. The `include` parameter specifies a list of `ecs.ClusterField*` constants, such as `ecs.ClusterFieldTags`.

func GetEcsOptimizedAmazonLinuxAmi

func GetEcsOptimizedAmazonLinuxAmi(t testing.TestingT, region string) string

GetEcsOptimizedAmazonLinuxAmi returns an Amazon ECS-Optimized Amazon Linux AMI for the given region. This AMI is useful for running an ECS cluster.

func GetEcsOptimizedAmazonLinuxAmiE

func GetEcsOptimizedAmazonLinuxAmiE(t testing.TestingT, region string) (string, error)

GetEcsOptimizedAmazonLinuxAmiE returns an Amazon ECS-Optimized Amazon Linux AMI for the given region. This AMI is useful for running an ECS cluster.

func GetEcsService

func GetEcsService(t testing.TestingT, region string, clusterName string, serviceName string) *ecs.Service

GetEcsService fetches information about specified ECS service.

func GetEcsServiceE

func GetEcsServiceE(t testing.TestingT, region string, clusterName string, serviceName string) (*ecs.Service, error)

GetEcsServiceE fetches information about specified ECS service.

func GetEcsTaskDefinition

func GetEcsTaskDefinition(t testing.TestingT, region string, taskDefinition string) *ecs.TaskDefinition

GetEcsTaskDefinition fetches information about specified ECS task definition.

func GetEcsTaskDefinitionE

func GetEcsTaskDefinitionE(t testing.TestingT, region string, taskDefinition string) (*ecs.TaskDefinition, error)

GetEcsTaskDefinitionE fetches information about specified ECS task definition.

func GetFirstTwoOctets

func GetFirstTwoOctets(cidrBlock string) string

GetFirstTwoOctets gets the first two octets from a CIDR block.

func GetIamCurrentUserArn

func GetIamCurrentUserArn(t testing.TestingT) string

GetIamCurrentUserArn gets the ARN for the current IAM user.

func GetIamCurrentUserArnE

func GetIamCurrentUserArnE(t testing.TestingT) (string, error)

GetIamCurrentUserArnE gets the ARN for the current IAM user.

func GetIamCurrentUserName

func GetIamCurrentUserName(t testing.TestingT) string

GetIamCurrentUserName gets the username for the current IAM user.

func GetIamCurrentUserNameE

func GetIamCurrentUserNameE(t testing.TestingT) (string, error)

GetIamCurrentUserNameE gets the username for the current IAM user.

func GetInstanceIdsForAsg

func GetInstanceIdsForAsg(t testing.TestingT, asgName string, awsRegion string) []string

GetInstanceIdsForAsg gets the IDs of EC2 Instances in the given ASG.

func GetInstanceIdsForAsgE

func GetInstanceIdsForAsgE(t testing.TestingT, asgName string, awsRegion string) ([]string, error)

GetInstanceIdsForAsgE gets the IDs of EC2 Instances in the given ASG.

func GetLaunchPermissionsForAmiE

func GetLaunchPermissionsForAmiE(t testing.TestingT, awsRegion string, amiID string) ([]*ec2.LaunchPermission, error)

GetLaunchPermissionsForAmiE returns launchPermissions as configured in AWS

func GetMostRecentAmiId

func GetMostRecentAmiId(t testing.TestingT, region string, ownerId string, filters map[string][]string) string

GetMostRecentAmiId gets the ID of the most recent AMI in the given region that has the given owner and matches the given filters. Each filter should correspond to the name and values of a filter supported by DescribeImagesInput: https://docs.aws.amazon.com/sdk-for-go/api/service/ec2/#DescribeImagesInput

func GetMostRecentAmiIdE

func GetMostRecentAmiIdE(t testing.TestingT, region string, ownerId string, filters map[string][]string) (string, error)

GetMostRecentAmiIdE gets the ID of the most recent AMI in the given region that has the given owner and matches the given filters. Each filter should correspond to the name and values of a filter supported by DescribeImagesInput: https://docs.aws.amazon.com/sdk-for-go/api/service/ec2/#DescribeImagesInput

func GetOptionGroupNameOfRdsInstance

func GetOptionGroupNameOfRdsInstance(t testing.TestingT, dbInstanceID string, awsRegion string) string

GetOptionGroupNameOfRdsInstance gets the name of the option group associated with the RDS instance

func GetOptionGroupNameOfRdsInstanceE

func GetOptionGroupNameOfRdsInstanceE(t testing.TestingT, dbInstanceID string, awsRegion string) (string, error)

GetOptionGroupNameOfRdsInstanceE gets the name of the option group associated with the RDS instance

func GetOptionSettingForOfRdsInstance

func GetOptionSettingForOfRdsInstance(t testing.TestingT, optionName string, optionSettingName string, dbInstanceID, awsRegion string) string

GetOptionSettingForOfRdsInstance gets the value of the option name in the option group specified for the RDS instance in the given region.

func GetOptionSettingForOfRdsInstanceE

func GetOptionSettingForOfRdsInstanceE(t testing.TestingT, optionName string, optionSettingName string, dbInstanceID, awsRegion string) (string, error)

GetOptionSettingForOfRdsInstanceE gets the value of the option name in the option group specified for the RDS instance in the given region.

func GetOptionsOfOptionGroup

func GetOptionsOfOptionGroup(t testing.TestingT, optionGroupName string, awsRegion string) []*rds.Option

GetOptionsOfOptionGroup gets the options of the option group specified

func GetOptionsOfOptionGroupE

func GetOptionsOfOptionGroupE(t testing.TestingT, optionGroupName string, awsRegion string) ([]*rds.Option, error)

GetOptionsOfOptionGroupE gets the options of the option group specified

func GetParameter

func GetParameter(t testing.TestingT, awsRegion string, keyName string) string

GetParameter retrieves the latest version of SSM Parameter at keyName with decryption.

func GetParameterE

func GetParameterE(t testing.TestingT, awsRegion string, keyName string) (string, error)

GetParameterE retrieves the latest version of SSM Parameter at keyName with decryption.

func GetParameterValueForParameterOfRdsInstance

func GetParameterValueForParameterOfRdsInstance(t testing.TestingT, parameterName string, dbInstanceID string, awsRegion string) string

GetParameterValueForParameterOfRdsInstance gets the value of the parameter name specified for the RDS instance in the given region.

func GetParameterValueForParameterOfRdsInstanceE

func GetParameterValueForParameterOfRdsInstanceE(t testing.TestingT, parameterName string, dbInstanceID string, awsRegion string) (string, error)

GetParameterValueForParameterOfRdsInstanceE gets the value of the parameter name specified for the RDS instance in the given region.

func GetParameterWithClientE

func GetParameterWithClientE(t testing.TestingT, client *ssm.SSM, keyName string) (string, error)

GetParameterE retrieves the latest version of SSM Parameter at keyName with decryption with the ability to provide the SSM client.

func GetPortOfRdsInstance

func GetPortOfRdsInstance(t testing.TestingT, dbInstanceID string, awsRegion string) int64

GetPortOfRdsInstance gets the address of the given RDS Instance in the given region.

func GetPortOfRdsInstanceE

func GetPortOfRdsInstanceE(t testing.TestingT, dbInstanceID string, awsRegion string) (int64, error)

GetPortOfRdsInstanceE gets the address of the given RDS Instance in the given region.

func GetPrivateHostnameOfEc2Instance

func GetPrivateHostnameOfEc2Instance(t testing.TestingT, instanceID string, awsRegion string) string

GetPrivateHostnameOfEc2Instance gets the private IP address of the given EC2 Instance in the given region.

func GetPrivateHostnameOfEc2InstanceE

func GetPrivateHostnameOfEc2InstanceE(t testing.TestingT, instanceID string, awsRegion string) (string, error)

GetPrivateHostnameOfEc2InstanceE gets the private IP address of the given EC2 Instance in the given region.

func GetPrivateHostnamesOfEc2Instances

func GetPrivateHostnamesOfEc2Instances(t testing.TestingT, instanceIDs []string, awsRegion string) map[string]string

GetPrivateHostnamesOfEc2Instances gets the private IP address of the given EC2 Instance in the given region. Returns a map of instance ID to IP address.

func GetPrivateHostnamesOfEc2InstancesE

func GetPrivateHostnamesOfEc2InstancesE(t testing.TestingT, instanceIDs []string, awsRegion string) (map[string]string, error)

GetPrivateHostnamesOfEc2InstancesE gets the private IP address of the given EC2 Instance in the given region. Returns a map of instance ID to IP address.

func GetPrivateIpOfEc2Instance

func GetPrivateIpOfEc2Instance(t testing.TestingT, instanceID string, awsRegion string) string

GetPrivateIpOfEc2Instance gets the private IP address of the given EC2 Instance in the given region.

func GetPrivateIpOfEc2InstanceE

func GetPrivateIpOfEc2InstanceE(t testing.TestingT, instanceID string, awsRegion string) (string, error)

GetPrivateIpOfEc2InstanceE gets the private IP address of the given EC2 Instance in the given region.

func GetPrivateIpsOfEc2Instances

func GetPrivateIpsOfEc2Instances(t testing.TestingT, instanceIDs []string, awsRegion string) map[string]string

GetPrivateIpsOfEc2Instances gets the private IP address of the given EC2 Instance in the given region. Returns a map of instance ID to IP address.

func GetPrivateIpsOfEc2InstancesE

func GetPrivateIpsOfEc2InstancesE(t testing.TestingT, instanceIDs []string, awsRegion string) (map[string]string, error)

GetPrivateIpsOfEc2InstancesE gets the private IP address of the given EC2 Instance in the given region. Returns a map of instance ID to IP address.

func GetPublicIpOfEc2Instance

func GetPublicIpOfEc2Instance(t testing.TestingT, instanceID string, awsRegion string) string

GetPublicIpOfEc2Instance gets the public IP address of the given EC2 Instance in the given region.

func GetPublicIpOfEc2InstanceE

func GetPublicIpOfEc2InstanceE(t testing.TestingT, instanceID string, awsRegion string) (string, error)

GetPublicIpOfEc2InstanceE gets the public IP address of the given EC2 Instance in the given region.

func GetPublicIpsOfEc2Instances

func GetPublicIpsOfEc2Instances(t testing.TestingT, instanceIDs []string, awsRegion string) map[string]string

GetPublicIpsOfEc2Instances gets the public IP address of the given EC2 Instance in the given region. Returns a map of instance ID to IP address.

func GetPublicIpsOfEc2InstancesE

func GetPublicIpsOfEc2InstancesE(t testing.TestingT, instanceIDs []string, awsRegion string) (map[string]string, error)

GetPublicIpsOfEc2InstancesE gets the public IP address of the given EC2 Instance in the given region. Returns a map of instance ID to IP address.

func GetRandomPrivateCidrBlock

func GetRandomPrivateCidrBlock(routingPrefix int) string

GetRandomPrivateCidrBlock gets a random CIDR block from the range of acceptable private IP addresses per RFC 1918 (https://tools.ietf.org/html/rfc1918#section-3) The routingPrefix refers to the "/28" in 1.2.3.4/28. Note that, as written, this function will return a subset of all valid ranges. Since we will probably use this function mostly for generating random CIDR ranges for VPCs and Subnets, having comprehensive set coverage is not essential.

func GetRandomRegion

func GetRandomRegion(t testing.TestingT, approvedRegions []string, forbiddenRegions []string) string

GetRandomRegion gets a randomly chosen AWS region. If approvedRegions is not empty, this will be a region from the approvedRegions list; otherwise, this method will fetch the latest list of regions from the AWS APIs and pick one of those. If forbiddenRegions is not empty, this method will make sure the returned region is not in the forbiddenRegions list.

func GetRandomRegionE

func GetRandomRegionE(t testing.TestingT, approvedRegions []string, forbiddenRegions []string) (string, error)

GetRandomRegionE gets a randomly chosen AWS region. If approvedRegions is not empty, this will be a region from the approvedRegions list; otherwise, this method will fetch the latest list of regions from the AWS APIs and pick one of those. If forbiddenRegions is not empty, this method will make sure the returned region is not in the forbiddenRegions list.

func GetRandomStableRegion

func GetRandomStableRegion(t testing.TestingT, approvedRegions []string, forbiddenRegions []string) string

GetRandomStableRegion gets a randomly chosen AWS region that is considered stable. Like GetRandomRegion, you can further restrict the stable region list using approvedRegions and forbiddenRegions. We consider stable regions to be those that have been around for at least 1 year. Note that regions in the approvedRegions list that are not considered stable are ignored.

func GetRdsInstanceDetailsE

func GetRdsInstanceDetailsE(t testing.TestingT, dbInstanceID string, awsRegion string) (*rds.DBInstance, error)

GetRdsInstanceDetailsE gets the details of a single DB instance whose identifier is passed.

func GetRecommendedInstanceType

func GetRecommendedInstanceType(t testing.TestingT, region string, instanceTypeOptions []string) string

GetRecommendedInstanceType takes in a list of EC2 instance types (e.g., "t2.micro", "t3.micro") and returns the first instance type in the list that is available in all Availability Zones (AZs) in the given region. If there's no instance available in all AZs, this function exits with an error. This is useful because certain instance types, such as t2.micro, are not available in some of the newer AZs, while t3.micro is not available in some of the older AZs, and if you have code that needs to run on a "small" instance across all AZs in many different regions, you can use this function to automatically figure out which instance type you should use. This function will fail the test if there is an error.

func GetRecommendedInstanceTypeE

func GetRecommendedInstanceTypeE(t testing.TestingT, region string, instanceTypeOptions []string) (string, error)

GetRecommendedInstanceTypeE takes in a list of EC2 instance types (e.g., "t2.micro", "t3.micro") and returns the first instance type in the list that is available in all Availability Zones (AZs) in the given region. If there's no instance available in all AZs, this function exits with an error. This is useful because certain instance types, such as t2.micro, are not available in some of the newer AZs, while t3.micro is not available in some of the older AZs. If you have code that needs to run on a "small" instance across all AZs in many different regions, you can use this function to automatically figure out which instance type you should use.

func GetRecommendedInstanceTypeWithClientE

func GetRecommendedInstanceTypeWithClientE(t testing.TestingT, ec2Client *ec2.EC2, instanceTypeOptions []string) (string, error)

GetRecommendedInstanceTypeWithClientE takes in a list of EC2 instance types (e.g., "t2.micro", "t3.micro") and returns the first instance type in the list that is available in all Availability Zones (AZs) in the given region. If there's no instance available in all AZs, this function exits with an error. This is useful because certain instance types, such as t2.micro, are not available in some of the newer AZs, while t3.micro is not available in some of the older AZs. If you have code that needs to run on a "small" instance across all AZs in many different regions, you can use this function to automatically figure out which instance type you should use. This function expects an authenticated EC2 client from the AWS SDK Go library.

func GetRecommendedRdsInstanceType

func GetRecommendedRdsInstanceType(t testing.TestingT, region string, engine string, engineVersion string, instanceTypeOptions []string) string

GetRecommendedRdsInstanceType takes in a list of RDS instance types (e.g., "db.t2.micro", "db.t3.micro") and returns the first instance type in the list that is available in the given region and for the given database engine type. If none of the instances provided are avaiable for your combination of region and database engine, this function will exit with an error.

func GetRecommendedRdsInstanceTypeE

func GetRecommendedRdsInstanceTypeE(t testing.TestingT, region string, engine string, engineVersion string, instanceTypeOptions []string) (string, error)

GetRecommendedRdsInstanceTypeE takes in a list of RDS instance types (e.g., "db.t2.micro", "db.t3.micro") and returns the first instance type in the list that is available in the given region and for the given database engine type. If none of the instances provided are avaiable for your combination of region and database engine, this function will return an error.

func GetRecommendedRdsInstanceTypeWithClientE

func GetRecommendedRdsInstanceTypeWithClientE(t testing.TestingT, rdsClient *rds.RDS, engine string, engineVersion string, instanceTypeOptions []string) (string, error)

GetRecommendedRdsInstanceTypeWithClientE takes in a list of RDS instance types (e.g., "db.t2.micro", "db.t3.micro") and returns the first instance type in the list that is available in the given region and for the given database engine type. If none of the instances provided are avaiable for your combination of region and database engine, this function will return an error. This function expects an authenticated RDS client from the AWS SDK Go library.

func GetS3BucketLoggingTarget

func GetS3BucketLoggingTarget(t testing.TestingT, awsRegion string, bucket string) string

GetS3BucketLoggingTarget fetches the given bucket's logging target bucket and returns it as a string

func GetS3BucketLoggingTargetE

func GetS3BucketLoggingTargetE(t testing.TestingT, awsRegion string, bucket string) (string, error)

GetS3BucketLoggingTargetE fetches the given bucket's logging target bucket and returns it as the following string: `TargetBucket` of the `LoggingEnabled` property for an S3 bucket

func GetS3BucketLoggingTargetPrefix

func GetS3BucketLoggingTargetPrefix(t testing.TestingT, awsRegion string, bucket string) string

GetS3BucketLoggingTargetPrefix fetches the given bucket's logging object prefix and returns it as a string

func GetS3BucketLoggingTargetPrefixE

func GetS3BucketLoggingTargetPrefixE(t testing.TestingT, awsRegion string, bucket string) (string, error)

GetS3BucketLoggingTargetPrefixE fetches the given bucket's logging object prefix and returns it as the following string: `TargetPrefix` of the `LoggingEnabled` property for an S3 bucket

func GetS3BucketPolicy

func GetS3BucketPolicy(t testing.TestingT, awsRegion string, bucket string) string

GetS3BucketPolicy fetches the given bucket's resource policy and returns it as a string

func GetS3BucketPolicyE

func GetS3BucketPolicyE(t testing.TestingT, awsRegion string, bucket string) (string, error)

GetS3BucketPolicyE fetches the given bucket's resource policy and returns it as a string

func GetS3BucketTags

func GetS3BucketTags(t testing.TestingT, awsRegion string, bucket string) map[string]string

GetS3BucketTags fetches the given bucket's tags and returns them as a string map of strings.

func GetS3BucketTagsE

func GetS3BucketTagsE(t testing.TestingT, awsRegion string, bucket string) (map[string]string, error)

GetS3BucketTagsE fetches the given bucket's tags and returns them as a string map of strings.

func GetS3BucketVersioning

func GetS3BucketVersioning(t testing.TestingT, awsRegion string, bucket string) string

GetS3BucketVersioning fetches the given bucket's versioning configuration status and returns it as a string

func GetS3BucketVersioningE

func GetS3BucketVersioningE(t testing.TestingT, awsRegion string, bucket string) (string, error)

GetS3BucketVersioningE fetches the given bucket's versioning configuration status and returns it as a string

func GetS3ObjectContents

func GetS3ObjectContents(t testing.TestingT, awsRegion string, bucket string, key string) string

GetS3ObjectContents fetches the contents of the object in the given bucket with the given key and return it as a string.

func GetS3ObjectContentsE

func GetS3ObjectContentsE(t testing.TestingT, awsRegion string, bucket string, key string) (string, error)

GetS3ObjectContentsE fetches the contents of the object in the given bucket with the given key and return it as a string.

func GetSecretValue

func GetSecretValue(t testing.TestingT, awsRegion, id string) string

GetSecretValue takes the friendly name or ARN of a secret and returns the plaintext value

func GetSecretValueE

func GetSecretValueE(t testing.TestingT, awsRegion, id string) (string, error)

GetSecretValueE takes the friendly name or ARN of a secret and returns the plaintext value

func GetSyslogForInstance

func GetSyslogForInstance(t testing.TestingT, instanceID string, awsRegion string) string

(Deprecated) See the FetchContentsOfFileFromInstance method for a more powerful solution.

GetSyslogForInstance gets the syslog for the Instance with the given ID in the given region. This should be available ~1 minute after an Instance boots and is very useful for debugging boot-time issues, such as an error in User Data.

func GetSyslogForInstanceE

func GetSyslogForInstanceE(t testing.TestingT, instanceID string, region string) (string, error)

(Deprecated) See the FetchContentsOfFileFromInstanceE method for a more powerful solution.

GetSyslogForInstanceE gets the syslog for the Instance with the given ID in the given region. This should be available ~1 minute after an Instance boots and is very useful for debugging boot-time issues, such as an error in User Data.

func GetSyslogForInstancesInAsg

func GetSyslogForInstancesInAsg(t testing.TestingT, asgName string, awsRegion string) map[string]string

(Deprecated) See the FetchContentsOfFilesFromAsg method for a more powerful solution.

GetSyslogForInstancesInAsg gets the syslog for each of the Instances in the given ASG in the given region. These logs should be available ~1 minute after the Instance boots and are very useful for debugging boot-time issues, such as an error in User Data. Returns a map of Instance Id -> Syslog for that Instance.

func GetSyslogForInstancesInAsgE

func GetSyslogForInstancesInAsgE(t testing.TestingT, asgName string, awsRegion string) (map[string]string, error)

(Deprecated) See the FetchContentsOfFilesFromAsgE method for a more powerful solution.

GetSyslogForInstancesInAsgE gets the syslog for each of the Instances in the given ASG in the given region. These logs should be available ~1 minute after the Instance boots and are very useful for debugging boot-time issues, such as an error in User Data. Returns a map of Instance Id -> Syslog for that Instance.

func GetTagsForEc2Instance

func GetTagsForEc2Instance(t testing.TestingT, region string, instanceID string) map[string]string

GetTagsForEc2Instance returns all the tags for the given EC2 Instance.

func GetTagsForEc2InstanceE

func GetTagsForEc2InstanceE(t testing.TestingT, region string, instanceID string) (map[string]string, error)

GetTagsForEc2InstanceE returns all the tags for the given EC2 Instance.

func GetTagsForSubnet

func GetTagsForSubnet(t testing.TestingT, subnetId string, region string) map[string]string

GetTagsForSubnet gets the tags for the specified subnet.

func GetTagsForSubnetE

func GetTagsForSubnetE(t testing.TestingT, subnetId string, region string) (map[string]string, error)

GetTagsForSubnetE gets the tags for the specified subnet.

func GetTagsForVpc

func GetTagsForVpc(t testing.TestingT, vpcID string, region string) map[string]string

GetTagsForVpc gets the tags for the specified VPC.

func GetTagsForVpcE

func GetTagsForVpcE(t testing.TestingT, vpcID string, region string) (map[string]string, error)

GetTagsForVpcE gets the tags for the specified VPC.

func GetTimeBasedOneTimePassword

func GetTimeBasedOneTimePassword(mfaDevice *iam.VirtualMFADevice) (string, error)

GetTimeBasedOneTimePassword gets a One-Time Password from the given mfaDevice. Per the RFC 6238 standard, this value will be different every 30 seconds.

func GetUbuntu1404Ami

func GetUbuntu1404Ami(t testing.TestingT, region string) string

GetUbuntu1404Ami gets the ID of the most recent Ubuntu 14.04 HVM x86_64 EBS GP2 AMI in the given region.

func GetUbuntu1404AmiE

func GetUbuntu1404AmiE(t testing.TestingT, region string) (string, error)

GetUbuntu1404AmiE gets the ID of the most recent Ubuntu 14.04 HVM x86_64 EBS GP2 AMI in the given region.

func GetUbuntu1604Ami

func GetUbuntu1604Ami(t testing.TestingT, region string) string

GetUbuntu1604Ami gets the ID of the most recent Ubuntu 16.04 HVM x86_64 EBS GP2 AMI in the given region.

func GetUbuntu1604AmiE

func GetUbuntu1604AmiE(t testing.TestingT, region string) (string, error)

GetUbuntu1604AmiE gets the ID of the most recent Ubuntu 16.04 HVM x86_64 EBS GP2 AMI in the given region.

func GetWhetherSchemaExistsInRdsMySqlInstance

func GetWhetherSchemaExistsInRdsMySqlInstance(t testing.TestingT, dbUrl string, dbPort int64, dbUsername string, dbPassword string, expectedSchemaName string) bool

GetWhetherSchemaExistsInRdsMySqlInstance checks whether the specified schema/table name exists in the RDS instance

func GetWhetherSchemaExistsInRdsMySqlInstanceE

func GetWhetherSchemaExistsInRdsMySqlInstanceE(t testing.TestingT, dbUrl string, dbPort int64, dbUsername string, dbPassword string, expectedSchemaName string) (bool, error)

GetWhetherSchemaExistsInRdsMySqlInstanceE checks whether the specified schema/table name exists in the RDS instance

func InvokeFunction

func InvokeFunction(t testing.TestingT, region, functionName string, payload interface{}) []byte

InvokeFunction invokes a lambda function.

func InvokeFunctionE

func InvokeFunctionE(t testing.TestingT, region, functionName string, payload interface{}) ([]byte, error)

InvokeFunctionE invokes a lambda function.

func IsPublicSubnet

func IsPublicSubnet(t testing.TestingT, subnetId string, region string) bool

IsPublicSubnet returns True if the subnet identified by the given id in the provided region is public.

func IsPublicSubnetE

func IsPublicSubnetE(t testing.TestingT, subnetId string, region string) (bool, error)

IsPublicSubnetE returns True if the subnet identified by the given id in the provided region is public.

func NewAcmClient

func NewAcmClient(t testing.TestingT, region string) *acm.ACM

NewAcmClient create a new ACM client.

func NewAcmClientE

func NewAcmClientE(t testing.TestingT, awsRegion string) (*acm.ACM, error)

NewAcmClientE creates a new ACM client.

func NewAsgClient

func NewAsgClient(t testing.TestingT, region string) *autoscaling.AutoScaling

NewAsgClient creates an Auto Scaling Group client.

func NewAsgClientE

func NewAsgClientE(t testing.TestingT, region string) (*autoscaling.AutoScaling, error)

NewAsgClientE creates an Auto Scaling Group client.

func NewAuthenticatedSession

func NewAuthenticatedSession(region string) (*session.Session, error)

NewAuthenticatedSession creates an AWS session following to standard AWS authentication workflow. If AuthAssumeIamRoleEnvVar environment variable is set, assumes IAM role specified in it.

func NewAuthenticatedSessionFromDefaultCredentials

func NewAuthenticatedSessionFromDefaultCredentials(region string) (*session.Session, error)

NewAuthenticatedSessionFromDefaultCredentials gets an AWS Session, checking that the user has credentials properly configured in their environment.

func NewAuthenticatedSessionFromRole

func NewAuthenticatedSessionFromRole(region string, roleARN string) (*session.Session, error)

NewAuthenticatedSessionFromRole returns a new AWS Session after assuming the role whose ARN is provided in roleARN. If the credentials are not properly configured in the underlying environment, an error is returned.

func NewCloudWatchLogsClient

func NewCloudWatchLogsClient(t testing.TestingT, region string) *cloudwatchlogs.CloudWatchLogs

NewCloudWatchLogsClient creates a new CloudWatch Logs client.

func NewCloudWatchLogsClientE

func NewCloudWatchLogsClientE(t testing.TestingT, region string) (*cloudwatchlogs.CloudWatchLogs, error)

NewCloudWatchLogsClientE creates a new CloudWatch Logs client.

func NewDynamoDBClient

func NewDynamoDBClient(t testing.TestingT, region string) *dynamodb.DynamoDB

NewDynamoDBClient creates a DynamoDB client.

func NewDynamoDBClientE

func NewDynamoDBClientE(t testing.TestingT, region string) (*dynamodb.DynamoDB, error)

NewDynamoDBClientE creates a DynamoDB client.

func NewECRClient

func NewECRClient(t testing.TestingT, region string) *ecr.ECR

NewECRClient returns a client for the Elastic Container Registry. This will fail the test and stop execution if there is an error.

func NewECRClientE

func NewECRClientE(t testing.TestingT, region string) (*ecr.ECR, error)

NewECRClient returns a client for the Elastic Container Registry.

func NewEc2Client

func NewEc2Client(t testing.TestingT, region string) *ec2.EC2

NewEc2Client creates an EC2 client.

func NewEc2ClientE

func NewEc2ClientE(t testing.TestingT, region string) (*ec2.EC2, error)

NewEc2ClientE creates an EC2 client.

func NewEcsClient

func NewEcsClient(t testing.TestingT, region string) *ecs.ECS

NewEcsClient creates en ECS client.

func NewEcsClientE

func NewEcsClientE(t testing.TestingT, region string) (*ecs.ECS, error)

NewEcsClientE creates an ECS client.

func NewIamClient

func NewIamClient(t testing.TestingT, region string) *iam.IAM

NewIamClient creates a new IAM client.

func NewIamClientE

func NewIamClientE(t testing.TestingT, region string) (*iam.IAM, error)

NewIamClientE creates a new IAM client.

func NewKmsClient

func NewKmsClient(t testing.TestingT, region string) *kms.KMS

NewKmsClient creates a KMS client.

func NewKmsClientE

func NewKmsClientE(t testing.TestingT, region string) (*kms.KMS, error)

NewKmsClientE creates a KMS client.

func NewLambdaClient

func NewLambdaClient(t testing.TestingT, region string) *lambda.Lambda

NewLambdaClient creates a new Lambda client.

func NewLambdaClientE

func NewLambdaClientE(t testing.TestingT, region string) (*lambda.Lambda, error)

NewLambdaClientE creates a new Lambda client.

func NewRdsClient

func NewRdsClient(t testing.TestingT, region string) *rds.RDS

NewRdsClient creates an RDS client.

func NewRdsClientE

func NewRdsClientE(t testing.TestingT, region string) (*rds.RDS, error)

NewRdsClientE creates an RDS client.

func NewS3Client

func NewS3Client(t testing.TestingT, region string) *s3.S3

NewS3Client creates an S3 client.

func NewS3ClientE

func NewS3ClientE(t testing.TestingT, region string) (*s3.S3, error)

NewS3ClientE creates an S3 client.

func NewS3Uploader

func NewS3Uploader(t testing.TestingT, region string) *s3manager.Uploader

NewS3Uploader creates an S3 Uploader.

func NewS3UploaderE

func NewS3UploaderE(t testing.TestingT, region string) (*s3manager.Uploader, error)

NewS3UploaderE creates an S3 Uploader.

func NewSecretsManagerClient

func NewSecretsManagerClient(t testing.TestingT, region string) *secretsmanager.SecretsManager

NewSecretsManagerClient creates a new SecretsManager client.

func NewSecretsManagerClientE

func NewSecretsManagerClientE(t testing.TestingT, region string) (*secretsmanager.SecretsManager, error)

NewSecretsManagerClientE creates a new SecretsManager client.

func NewSnsClient

func NewSnsClient(t testing.TestingT, region string) *sns.SNS

NewSnsClient creates a new SNS client.

func NewSnsClientE

func NewSnsClientE(t testing.TestingT, region string) (*sns.SNS, error)

NewSnsClientE creates a new SNS client.

func NewSqsClient

func NewSqsClient(t testing.TestingT, region string) *sqs.SQS

NewSqsClient creates a new SQS client.

func NewSqsClientE

func NewSqsClientE(t testing.TestingT, region string) (*sqs.SQS, error)

NewSqsClientE creates a new SQS client.

func NewSsmClient

func NewSsmClient(t testing.TestingT, region string) *ssm.SSM

NewSsmClient creates a SSM client.

func NewSsmClientE

func NewSsmClientE(t testing.TestingT, region string) (*ssm.SSM, error)

NewSsmClientE creates an SSM client.

func NewStsClientE

func NewStsClientE(t testing.TestingT, region string) (*sts.STS, error)

NewStsClientE creates a new STS client.

func PutECRRepoLifecyclePolicy

func PutECRRepoLifecyclePolicy(t testing.TestingT, region string, repo *ecr.Repository, policy string)

PutECRRepoLifecyclePolicy puts the given policy for the given ECR repository. This will fail the test and stop execution if there is an error.

func PutECRRepoLifecyclePolicyE

func PutECRRepoLifecyclePolicyE(t testing.TestingT, region string, repo *ecr.Repository, policy string) error

PutEcrRepoLifecyclePolicy puts the given policy for the given ECR repository.

func PutParameter

func PutParameter(t testing.TestingT, awsRegion string, keyName string, keyDescription string, keyValue string) int64

PutParameter creates new version of SSM Parameter at keyName with keyValue as SecureString.

func PutParameterE

func PutParameterE(t testing.TestingT, awsRegion string, keyName string, keyDescription string, keyValue string) (int64, error)

PutParameterE creates new version of SSM Parameter at keyName with keyValue as SecureString.

func PutParameterWithClientE

func PutParameterWithClientE(t testing.TestingT, client *ssm.SSM, keyName string, keyDescription string, keyValue string) (int64, error)

PutParameterE creates new version of SSM Parameter at keyName with keyValue as SecureString with the ability to provide the SSM client.

func PutS3BucketPolicy

func PutS3BucketPolicy(t testing.TestingT, region string, bucketName string, policyJSONString string)

PutS3BucketPolicy applies an IAM resource policy to a given S3 bucket to create it's bucket policy

func PutS3BucketPolicyE

func PutS3BucketPolicyE(t testing.TestingT, region string, bucketName string, policyJSONString string) error

PutS3BucketPolicyE applies an IAM resource policy to a given S3 bucket to create it's bucket policy

func PutS3BucketVersioning

func PutS3BucketVersioning(t testing.TestingT, region string, bucketName string)

PutS3BucketVersioning creates an S3 bucket versioning configuration in the given region against the given bucket name, WITHOUT requiring MFA to remove versioning.

func PutS3BucketVersioningE

func PutS3BucketVersioningE(t testing.TestingT, region string, bucketName string) error

PutS3BucketVersioningE creates an S3 bucket versioning configuration in the given region against the given bucket name, WITHOUT requiring MFA to remove versioning.

func ReadPasswordPolicyMinPasswordLength

func ReadPasswordPolicyMinPasswordLength(iamClient *iam.IAM) (int, error)

ReadPasswordPolicyMinPasswordLength returns the minimal password length.

func SendMessageFifoToQueue

func SendMessageFifoToQueue(t testing.TestingT, awsRegion string, queueURL string, message string, messageGroupID string)

SendMessageToFifoQueue sends the given message to the FIFO SQS queue with the given URL.

func SendMessageToFifoQueueE

func SendMessageToFifoQueueE(t testing.TestingT, awsRegion string, queueURL string, message string, messageGroupID string) error

SendMessageToFifoQueueE sends the given message to the FIFO SQS queue with the given URL.

func SendMessageToQueue

func SendMessageToQueue(t testing.TestingT, awsRegion string, queueURL string, message string)

SendMessageToQueue sends the given message to the SQS queue with the given URL.

func SendMessageToQueueE

func SendMessageToQueueE(t testing.TestingT, awsRegion string, queueURL string, message string) error

SendMessageToQueueE sends the given message to the SQS queue with the given URL.

func TerminateInstance

func TerminateInstance(t testing.TestingT, region string, instanceID string)

TerminateInstance terminates the EC2 instance with the given ID in the given region.

func TerminateInstanceE

func TerminateInstanceE(t testing.TestingT, region string, instanceID string) error

TerminateInstanceE terminates the EC2 instance with the given ID in the given region.

func WaitForCapacity

func WaitForCapacity(
	t testing.TestingT,
	asgName string,
	region string,
	maxRetries int,
	sleepBetweenRetries time.Duration,
)

WaitForCapacity waits for the currently set desired capacity to be reached on the ASG

func WaitForCapacityE

func WaitForCapacityE(
	t testing.TestingT,
	asgName string,
	region string,
	maxRetries int,
	sleepBetweenRetries time.Duration,
) error

WaitForCapacityE waits for the currently set desired capacity to be reached on the ASG

func WaitForSsmInstance

func WaitForSsmInstance(t testing.TestingT, awsRegion, instanceID string, timeout time.Duration)

WaitForSsmInstance waits until the instance get registered to the SSM inventory.

func WaitForSsmInstanceE

func WaitForSsmInstanceE(t testing.TestingT, awsRegion, instanceID string, timeout time.Duration) error

WaitForSsmInstanceE waits until the instance get registered to the SSM inventory.

func WaitForSsmInstanceWithClientE

func WaitForSsmInstanceWithClientE(t testing.TestingT, client *ssm.SSM, instanceID string, timeout time.Duration) error

WaitForSsmInstanceE waits until the instance get registered to the SSM inventory with the ability to provide the SSM client.

Types

type AsgCapacityInfo

type AsgCapacityInfo struct {
	MinCapacity     int64
	MaxCapacity     int64
	CurrentCapacity int64
	DesiredCapacity int64
}

func GetCapacityInfoForAsg

func GetCapacityInfoForAsg(t testing.TestingT, asgName string, awsRegion string) AsgCapacityInfo

GetCapacityInfoForAsg returns the capacity info for the queried asg as a struct, AsgCapacityInfo.

func GetCapacityInfoForAsgE

func GetCapacityInfoForAsgE(t testing.TestingT, asgName string, awsRegion string) (AsgCapacityInfo, error)

GetCapacityInfoForAsgE returns the capacity info for the queried asg as a struct, AsgCapacityInfo.

type AsgCapacityNotMetError

type AsgCapacityNotMetError struct {
	// contains filtered or unexported fields
}

AsgCapacityNotMetError is returned when the ASG capacity is not yet at the desired capacity.

func NewAsgCapacityNotMetError

func NewAsgCapacityNotMetError(asgName string, desiredCapacity int64, currentCapacity int64) AsgCapacityNotMetError

func (AsgCapacityNotMetError) Error

func (err AsgCapacityNotMetError) Error() string

type BucketVersioningNotEnabledError

type BucketVersioningNotEnabledError struct {
	// contains filtered or unexported fields
}

BucketVersioningNotEnabledError is returned when an S3 bucket that should have versioning does not have it applied

func NewBucketVersioningNotEnabledError

func NewBucketVersioningNotEnabledError(s3BucketName string, awsRegion string, versioningStatus string) BucketVersioningNotEnabledError

func (BucketVersioningNotEnabledError) Error

type CommandOutput

type CommandOutput struct {
	Stdout   string
	Stderr   string
	ExitCode int64
}

CommandOutput contains the result of the SSM command.

func CheckSSMCommandWithClientE

func CheckSSMCommandWithClientE(t testing.TestingT, client *ssm.SSM, instanceID, command string, timeout time.Duration) (*CommandOutput, error)

CheckSSMCommandWithClientE checks that you can run the given command on the given instance through AWS SSM with the ability to provide the SSM client. Returns the result and an error if one occurs.

func CheckSSMCommandWithClientWithDocumentE

func CheckSSMCommandWithClientWithDocumentE(t testing.TestingT, client *ssm.SSM, instanceID, command string, commandDocName string, timeout time.Duration) (*CommandOutput, error)

CheckSSMCommandWithClientWithDocumentE checks that you can run the given command on the given instance through AWS SSM with the ability to provide the SSM client with specified Command Doc type. Returns the result and an error if one occurs.

func CheckSsmCommand

func CheckSsmCommand(t testing.TestingT, awsRegion, instanceID, command string, timeout time.Duration) *CommandOutput

CheckSsmCommand checks that you can run the given command on the given instance through AWS SSM.

func CheckSsmCommandE

func CheckSsmCommandE(t testing.TestingT, awsRegion, instanceID, command string, timeout time.Duration) (*CommandOutput, error)

CheckSsmCommandE checks that you can run the given command on the given instance through AWS SSM. Returns the result and an error if one occurs.

func CheckSsmCommandWithDocument

func CheckSsmCommandWithDocument(t testing.TestingT, awsRegion, instanceID, command string, commandDocName string, timeout time.Duration) *CommandOutput

CheckSsmCommandWithDocument checks that you can run the given command on the given instance through AWS SSM with specified Command Doc type.

func CheckSsmCommandWithDocumentE

func CheckSsmCommandWithDocumentE(t testing.TestingT, awsRegion, instanceID, command string, commandDocName string, timeout time.Duration) (*CommandOutput, error)

CheckSsmCommandWithDocumentE checks that you can run the given command on the given instance through AWS SSM with specified Command Doc type. Returns the result and an error if one occurs.

type CredentialsError

type CredentialsError struct {
	UnderlyingErr error
}

CredentialsError is an error that occurs because AWS credentials can't be found.

func (CredentialsError) Error

func (err CredentialsError) Error() string

type Ec2Keypair

type Ec2Keypair struct {
	*ssh.KeyPair
	Name   string // The name assigned in AWS to the EC2 Key Pair
	Region string // The AWS region where the EC2 Key Pair lives
}

Ec2Keypair is an EC2 key pair.

func CreateAndImportEC2KeyPair

func CreateAndImportEC2KeyPair(t testing.TestingT, region string, name string) *Ec2Keypair

CreateAndImportEC2KeyPair generates a public/private KeyPair and import it into EC2 in the given region under the given name.

func CreateAndImportEC2KeyPairE

func CreateAndImportEC2KeyPairE(t testing.TestingT, region string, name string) (*Ec2Keypair, error)

CreateAndImportEC2KeyPairE generates a public/private KeyPair and import it into EC2 in the given region under the given name.

func ImportEC2KeyPair

func ImportEC2KeyPair(t testing.TestingT, region string, name string, keyPair *ssh.KeyPair) *Ec2Keypair

ImportEC2KeyPair creates a Key Pair in EC2 by importing an existing public key.

func ImportEC2KeyPairE

func ImportEC2KeyPairE(t testing.TestingT, region string, name string, keyPair *ssh.KeyPair) (*Ec2Keypair, error)

ImportEC2KeyPairE creates a Key Pair in EC2 by importing an existing public key.

type FunctionError

type FunctionError struct {
	Message    string
	StatusCode int64
	Payload    []byte
}

func (*FunctionError) Error

func (err *FunctionError) Error() string

type HostnameForEc2InstanceNotFound

type HostnameForEc2InstanceNotFound struct {
	InstanceId string
	AwsRegion  string
	Type       string
}

HostnameForEc2InstanceNotFound is an error that occurs when the IP for an EC2 instance is not found.

func (HostnameForEc2InstanceNotFound) Error

type InvocationTypeOption

type InvocationTypeOption string
const (
	InvocationTypeRequestResponse InvocationTypeOption = "RequestResponse"
	InvocationTypeDryRun                               = "DryRun"
)

func (*InvocationTypeOption) Value

func (itype *InvocationTypeOption) Value() (string, error)

type IpForEc2InstanceNotFound

type IpForEc2InstanceNotFound struct {
	InstanceId string
	AwsRegion  string
	Type       string
}

IpForEc2InstanceNotFound is an error that occurs when the IP for an EC2 instance is not found.

func (IpForEc2InstanceNotFound) Error

func (err IpForEc2InstanceNotFound) Error() string

type LambdaOptions

type LambdaOptions struct {
	// InvocationType can be one of InvocationTypeOption values:
	//    * InvocationTypeRequestResponse (default) - Invoke the function
	//      synchronously.  Keep the connection open until the function
	//      returns a response or times out.
	//    * InvocationTypeDryRun - Validate parameter values and verify
	//      that the user or role has permission to invoke the function.
	InvocationType *InvocationTypeOption

	// Lambda function input; will be converted to JSON.
	Payload interface{}
}

LambdaOptions contains additional parameters for InvokeFunctionWithParams(). It contains a subset of the fields found in the lambda.InvokeInput struct.

type LambdaOutput

type LambdaOutput struct {
	// The response from the function, or an error object.
	Payload []byte

	// The HTTP status code for a successful request is in the 200 range.
	// For RequestResponse invocation type, the status code is 200.
	// For the DryRun invocation type, the status code is 204.
	StatusCode *int64
}

LambdaOutput contains the output from InvokeFunctionWithParams(). The fields may or may not have a value depending on the invocation type and whether an error occurred or not.

func InvokeFunctionWithParams

func InvokeFunctionWithParams(t testing.TestingT, region, functionName string, input *LambdaOptions) *LambdaOutput

InvokeFunctionWithParams invokes a lambda function using parameters supplied in the LambdaOptions struct and returns values in a LambdaOutput struct. Checks for failure using "require".

func InvokeFunctionWithParamsE

func InvokeFunctionWithParamsE(t testing.TestingT, region, functionName string, input *LambdaOptions) (*LambdaOutput, error)

InvokeFunctionWithParamsE invokes a lambda function using parameters supplied in the LambdaOptions struct. Returns the status code and payload in a LambdaOutput struct and the error. A non-nil error will either reflect a problem with the parameters supplied to this function or an error returned by the Lambda.

type NoBucketPolicyError

type NoBucketPolicyError struct {
	// contains filtered or unexported fields
}

NoBucketPolicyError is returned when an S3 bucket that should have a policy applied does not

func NewNoBucketPolicyError

func NewNoBucketPolicyError(s3BucketName string, awsRegion string, bucketPolicy string) NoBucketPolicyError

func (NoBucketPolicyError) Error

func (err NoBucketPolicyError) Error() string

type NoImagesFound

type NoImagesFound struct {
	Region  string
	OwnerId string
	Filters map[string][]string
}

NoImagesFound is an error that occurs if no images were found.

func (NoImagesFound) Error

func (err NoImagesFound) Error() string

type NoInstanceTypeError

type NoInstanceTypeError struct {
	InstanceTypeOptions []string
	Azs                 []string
}

NoInstanceTypeError is returned when none of the given instance type options are available in all AZs in a region

func (NoInstanceTypeError) Error

func (err NoInstanceTypeError) Error() string

type NoRdsInstanceTypeError

type NoRdsInstanceTypeError struct {
	InstanceTypeOptions   []string
	DatabaseEngine        string
	DatabaseEngineVersion string
}

NoRdsInstanceTypeError is returned when none of the given instance types are avaiable for the region, database engine, and database engine combination given

func (NoRdsInstanceTypeError) Error

func (err NoRdsInstanceTypeError) Error() string

type NotFoundError

type NotFoundError struct {
	// contains filtered or unexported fields
}

NotFoundError is returned when an expected object is not found

func NewNotFoundError

func NewNotFoundError(objectType string, objectID string, region string) NotFoundError

func (NotFoundError) Error

func (err NotFoundError) Error() string

type OptionGroupOptionSettingForDbInstanceNotFound

type OptionGroupOptionSettingForDbInstanceNotFound struct {
	OptionName        string
	OptionSettingName string
	DbInstanceID      string
	AwsRegion         string
}

OptionGroupOptionSettingForDbInstanceNotFound is an error that occurs when the option setting specified is not found in the option group of the DB instance

func (OptionGroupOptionSettingForDbInstanceNotFound) Error

type ParameterForDbInstanceNotFound

type ParameterForDbInstanceNotFound struct {
	ParameterName string
	DbInstanceID  string
	AwsRegion     string
}

ParameterForDbInstanceNotFound is an error that occurs when the parameter group specified is not found for the DB instance

func (ParameterForDbInstanceNotFound) Error

type QueueMessageResponse

type QueueMessageResponse struct {
	ReceiptHandle string
	MessageBody   string
	Error         error
}

QueueMessageResponse contains a queue message.

func WaitForQueueMessage

func WaitForQueueMessage(t testing.TestingT, awsRegion string, queueURL string, timeout int) QueueMessageResponse

WaitForQueueMessage waits to receive a message from on the queueURL. Since the API only allows us to wait a max 20 seconds for a new message to arrive, we must loop TIMEOUT/20 number of times to be able to wait for a total of TIMEOUT seconds

type ReceiveMessageTimeout

type ReceiveMessageTimeout struct {
	QueueUrl   string
	TimeoutSec int
}

ReceiveMessageTimeout is an error that occurs if receiving a message times out.

func (ReceiveMessageTimeout) Error

func (err ReceiveMessageTimeout) Error() string

type RemoteFileSpecification

type RemoteFileSpecification struct {
	AsgNames               []string            //ASGs where our instances will be
	RemotePathToFileFilter map[string][]string //A map of the files to fetch, where the keys are directories on the remote host and the values are filters for what files to fetch from the directory. The filters support bash-style wildcards.
	UseSudo                bool
	SshUser                string
	KeyPair                *Ec2Keypair
	LocalDestinationDir    string //base path where to store downloaded artifacts locally. The final path of each resource will include the ip of the host and the name of the immediate parent folder.
}

RemoteFileSpecification describes which files you want to copy from your instances

type S3AccessLoggingNotEnabledErr

type S3AccessLoggingNotEnabledErr struct {
	OriginBucket string
	Region       string
}

S3AccessLoggingNotEnabledErr is a custom error that occurs when acess logging hasn't been enabled on the S3 Bucket

func (S3AccessLoggingNotEnabledErr) Error

type Subnet

type Subnet struct {
	Id               string            // The ID of the Subnet
	AvailabilityZone string            // The Availability Zone the subnet is in
	DefaultForAz     bool              // If the subnet is default for the Availability Zone
	Tags             map[string]string // The tags associated with the subnet
}

Subnet is a subnet in an availability zone.

func GetSubnetsForVpc

func GetSubnetsForVpc(t testing.TestingT, vpcID string, region string) []Subnet

GetSubnetsForVpc gets the subnets in the specified VPC.

func GetSubnetsForVpcE

func GetSubnetsForVpcE(t testing.TestingT, vpcID string, region string) ([]Subnet, error)

GetSubnetsForVpcE gets the subnets in the specified VPC.

type Vpc

type Vpc struct {
	Id      string            // The ID of the VPC
	Name    string            // The name of the VPC
	Subnets []Subnet          // A list of subnets in the VPC
	Tags    map[string]string // The tags associated with the VPC
}

Vpc is an Amazon Virtual Private Cloud.

func GetDefaultVpc

func GetDefaultVpc(t testing.TestingT, region string) *Vpc

GetDefaultVpc fetches information about the default VPC in the given region.

func GetDefaultVpcE

func GetDefaultVpcE(t testing.TestingT, region string) (*Vpc, error)

GetDefaultVpcE fetches information about the default VPC in the given region.

func GetVpcById

func GetVpcById(t testing.TestingT, vpcId string, region string) *Vpc

GetVpcById fetches information about a VPC with given Id in the given region.

func GetVpcByIdE

func GetVpcByIdE(t testing.TestingT, vpcId string, region string) (*Vpc, error)

GetVpcByIdE fetches information about a VPC with given Id in the given region.

func GetVpcsE

func GetVpcsE(t testing.TestingT, filters []*ec2.Filter, region string) ([]*Vpc, error)

GetVpcsE fetches informations about VPCs from given regions limited by filters

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL