aws

package

v0.0.2 Latest Latest Go to latest Published: Nov 8, 2021 License: Apache-2.0 Imports: 47 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kaarla/terratest

Documentation ¶

Overview ¶

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

Index ¶

Constants
func AddTagsToResource(t testing.TestingT, region string, resource string, tags map[string]string)
func AddTagsToResourceE(t testing.TestingT, region string, resource string, tags map[string]string) error
func AssertS3BucketExists(t testing.TestingT, region string, name string)
func AssertS3BucketExistsE(t testing.TestingT, region string, name string) error
func AssertS3BucketPolicyExists(t testing.TestingT, region string, bucketName string)
func AssertS3BucketPolicyExistsE(t testing.TestingT, region string, bucketName string) error
func AssertS3BucketVersioningExists(t testing.TestingT, region string, bucketName string)
func AssertS3BucketVersioningExistsE(t testing.TestingT, region string, bucketName string) error
func AssumeRole(sess *session.Session, roleARN string) *session.Session
func CreateAwsCredentials(accessKeyID string, secretAccessKey string) *credentials.Credentials
func CreateAwsCredentialsWithSessionToken(accessKeyID, secretAccessKey, sessionToken string) *credentials.Credentials
func CreateAwsSessionFromRole(region string, roleARN string) (*session.Session, error)
func CreateAwsSessionWithCreds(region string, accessKeyID string, secretAccessKey string) (*session.Session, error)
func CreateAwsSessionWithMfa(region string, stsClient *sts.STS, mfaDevice *iam.VirtualMFADevice) (*session.Session, error)
func CreateECRRepo(t testing.TestingT, region string, name string) *ecr.Repository
func CreateECRRepoE(t testing.TestingT, region string, name string) (*ecr.Repository, error)
func CreateEcsCluster(t testing.TestingT, region string, name string) *ecs.Cluster
func CreateEcsClusterE(t testing.TestingT, region string, name string) (*ecs.Cluster, error)
func CreateMfaDevice(t testing.TestingT, iamClient *iam.IAM, deviceName string) *iam.VirtualMFADevice
func CreateMfaDeviceE(t testing.TestingT, iamClient *iam.IAM, deviceName string) (*iam.VirtualMFADevice, error)
func CreateRandomFifoQueue(t testing.TestingT, awsRegion string, prefix string) string
func CreateRandomFifoQueueE(t testing.TestingT, awsRegion string, prefix string) (string, error)
func CreateRandomQueue(t testing.TestingT, awsRegion string, prefix string) string
func CreateRandomQueueE(t testing.TestingT, awsRegion string, prefix string) (string, error)
func CreateS3Bucket(t testing.TestingT, region string, name string)
func CreateS3BucketE(t testing.TestingT, region string, name string) error
func CreateSecretStringWithDefaultKey(t testing.TestingT, awsRegion, description, name, secretString string) string
func CreateSecretStringWithDefaultKeyE(t testing.TestingT, awsRegion, description, name, secretString string) (string, error)
func CreateSnsTopic(t testing.TestingT, region string, snsTopicName string) string
func CreateSnsTopicE(t testing.TestingT, region string, snsTopicName string) (string, error)
func DeleteAmi(t testing.TestingT, region string, imageID string)
func DeleteAmiAndAllSnapshots(t testing.TestingT, region string, ami string)
func DeleteAmiAndAllSnapshotsE(t testing.TestingT, region string, ami string) error
func DeleteAmiE(t testing.TestingT, region string, imageID string) error
func DeleteEC2KeyPair(t testing.TestingT, keyPair *Ec2Keypair)
func DeleteEC2KeyPairE(t testing.TestingT, keyPair *Ec2Keypair) error
func DeleteECRRepo(t testing.TestingT, region string, repo *ecr.Repository)
func DeleteECRRepoE(t testing.TestingT, region string, repo *ecr.Repository) error
func DeleteEbsSnapshot(t testing.TestingT, region string, snapshot string)
func DeleteEbsSnapshotE(t testing.TestingT, region string, snapshot string) error
func DeleteEcsCluster(t testing.TestingT, region string, cluster *ecs.Cluster)
func DeleteEcsClusterE(t testing.TestingT, region string, cluster *ecs.Cluster) error
func DeleteMessageFromQueue(t testing.TestingT, awsRegion string, queueURL string, receipt string)
func DeleteMessageFromQueueE(t testing.TestingT, awsRegion string, queueURL string, receipt string) error
func DeleteParameter(t testing.TestingT, awsRegion string, keyName string)
func DeleteParameterE(t testing.TestingT, awsRegion string, keyName string) error
func DeleteParameterWithClientE(t testing.TestingT, client *ssm.SSM, keyName string) error
func DeleteQueue(t testing.TestingT, awsRegion string, queueURL string)
func DeleteQueueE(t testing.TestingT, awsRegion string, queueURL string) error
func DeleteS3Bucket(t testing.TestingT, region string, name string)
func DeleteS3BucketE(t testing.TestingT, region string, name string) error
func DeleteSNSTopic(t testing.TestingT, region string, snsTopicArn string)
func DeleteSNSTopicE(t testing.TestingT, region string, snsTopicArn string) error
func DeleteSecret(t testing.TestingT, awsRegion, id string, forceDelete bool)
func DeleteSecretE(t testing.TestingT, awsRegion, id string, forceDelete bool) error
func EmptyS3Bucket(t testing.TestingT, region string, name string)
func EmptyS3BucketE(t testing.TestingT, region string, name string) error
func EnableMfaDevice(t testing.TestingT, iamClient *iam.IAM, mfaDevice *iam.VirtualMFADevice)
func EnableMfaDeviceE(t testing.TestingT, iamClient *iam.IAM, mfaDevice *iam.VirtualMFADevice) error
func FetchContentsOfFileFromAsg(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, ...) map[string]string
func FetchContentsOfFileFromAsgE(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, ...) (map[string]string, error)
func FetchContentsOfFileFromInstance(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, ...) string
func FetchContentsOfFileFromInstanceE(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, ...) (string, error)
func FetchContentsOfFilesFromAsg(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, ...) map[string]map[string]string
func FetchContentsOfFilesFromAsgE(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, ...) (map[string]map[string]string, error)
func FetchContentsOfFilesFromInstance(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, ...) map[string]string
func FetchContentsOfFilesFromInstanceE(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, ...) (map[string]string, error)
func FetchFilesFromAsgs(t testing.TestingT, awsRegion string, spec RemoteFileSpecification)
func FetchFilesFromAsgsE(t testing.TestingT, awsRegion string, spec RemoteFileSpecification) error
func FetchFilesFromInstance(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, ...)
func FetchFilesFromInstanceE(t testing.TestingT, awsRegion string, sshUserName string, keyPair *Ec2Keypair, ...) error
func FindS3BucketWithTag(t testing.TestingT, awsRegion string, key string, value string) string
func FindS3BucketWithTagE(t testing.TestingT, awsRegion string, key string, value string) (string, error)
func FindVpcName(vpc *ec2.Vpc) string
func GetAccountId(t testing.TestingT) string
func GetAccountIdE(t testing.TestingT) (string, error)
func GetAccountsWithLaunchPermissionsForAmi(t testing.TestingT, awsRegion string, amiID string) []string
func GetAccountsWithLaunchPermissionsForAmiE(t testing.TestingT, awsRegion string, amiID string) ([]string, error)
func GetAcmCertificateArn(t testing.TestingT, awsRegion string, certDomainName string) string
func GetAcmCertificateArnE(t testing.TestingT, awsRegion string, certDomainName string) (string, error)
func GetAddressOfRdsInstance(t testing.TestingT, dbInstanceID string, awsRegion string) string
func GetAddressOfRdsInstanceE(t testing.TestingT, dbInstanceID string, awsRegion string) (string, error)
func GetAllAwsRegions(t testing.TestingT) []string
func GetAllAwsRegionsE(t testing.TestingT) ([]string, error)
func GetAllParametersOfRdsInstance(t testing.TestingT, dbInstanceID string, awsRegion string) []*rds.Parameter
func GetAllParametersOfRdsInstanceE(t testing.TestingT, dbInstanceID string, awsRegion string) ([]*rds.Parameter, error)
func GetAmazonLinuxAmi(t testing.TestingT, region string) string
func GetAmazonLinuxAmiE(t testing.TestingT, region string) (string, error)
func GetAmiPubliclyAccessible(t testing.TestingT, awsRegion string, amiID string) bool
func GetAmiPubliclyAccessibleE(t testing.TestingT, awsRegion string, amiID string) (bool, error)
func GetAvailabilityZones(t testing.TestingT, region string) []string
func GetAvailabilityZonesE(t testing.TestingT, region string) ([]string, error)
func GetCentos7Ami(t testing.TestingT, region string) string
func GetCentos7AmiE(t testing.TestingT, region string) (string, error)
func GetCloudWatchLogEntries(t testing.TestingT, awsRegion string, logStreamName string, ...) []string
func GetCloudWatchLogEntriesE(t testing.TestingT, awsRegion string, logStreamName string, ...) ([]string, error)
func GetCmkArn(t testing.TestingT, region string, cmkID string) string
func GetCmkArnE(t testing.TestingT, region string, cmkID string) (string, error)
func GetDefaultEcsCluster(t testing.TestingT, region string) *ecs.Cluster
func GetDefaultEcsClusterE(t testing.TestingT, region string) (*ecs.Cluster, error)
func GetDynamoDBTable(t testing.TestingT, region string, tableName string) *dynamodb.TableDescription
func GetDynamoDBTableE(t testing.TestingT, region string, tableName string) (*dynamodb.TableDescription, error)
func GetDynamoDBTableTimeToLive(t testing.TestingT, region string, tableName string) *dynamodb.TimeToLiveDescription
func GetDynamoDBTableTimeToLiveE(t testing.TestingT, region string, tableName string) (*dynamodb.TimeToLiveDescription, error)
func GetDynamoDbTableTags(t testing.TestingT, region string, tableName string) []*dynamodb.Tag
func GetDynamoDbTableTagsE(t testing.TestingT, region string, tableName string) ([]*dynamodb.Tag, error)
func GetECRRepo(t testing.TestingT, region string, name string) *ecr.Repository
func GetECRRepoE(t testing.TestingT, region string, name string) (*ecr.Repository, error)
func GetEbsSnapshotsForAmi(t testing.TestingT, region string, ami string) []string
func GetEbsSnapshotsForAmiE(t testing.TestingT, region string, ami string) ([]string, error)
func GetEc2InstanceIdsByFilters(t testing.TestingT, region string, ec2Filters map[string][]string) []string
func GetEc2InstanceIdsByFiltersE(t testing.TestingT, region string, ec2Filters map[string][]string) ([]string, error)
func GetEc2InstanceIdsByTag(t testing.TestingT, region string, tagName string, tagValue string) []string
func GetEc2InstanceIdsByTagE(t testing.TestingT, region string, tagName string, tagValue string) ([]string, error)
func GetEcsCluster(t testing.TestingT, region string, name string) *ecs.Cluster
func GetEcsClusterE(t testing.TestingT, region string, name string) (*ecs.Cluster, error)
func GetEcsClusterWithInclude(t testing.TestingT, region string, name string, include []string) *ecs.Cluster
func GetEcsClusterWithIncludeE(t testing.TestingT, region string, name string, include []string) (*ecs.Cluster, error)
func GetEcsOptimizedAmazonLinuxAmi(t testing.TestingT, region string) string
func GetEcsOptimizedAmazonLinuxAmiE(t testing.TestingT, region string) (string, error)
func GetEcsService(t testing.TestingT, region string, clusterName string, serviceName string) *ecs.Service
func GetEcsServiceE(t testing.TestingT, region string, clusterName string, serviceName string) (*ecs.Service, error)
func GetEcsTaskDefinition(t testing.TestingT, region string, taskDefinition string) *ecs.TaskDefinition
func GetEcsTaskDefinitionE(t testing.TestingT, region string, taskDefinition string) (*ecs.TaskDefinition, error)
func GetFirstTwoOctets(cidrBlock string) string
func GetIamCurrentUserArn(t testing.TestingT) string
func GetIamCurrentUserArnE(t testing.TestingT) (string, error)
func GetIamCurrentUserName(t testing.TestingT) string
func GetIamCurrentUserNameE(t testing.TestingT) (string, error)
func GetInstanceIdsForAsg(t testing.TestingT, asgName string, awsRegion string) []string
func GetInstanceIdsForAsgE(t testing.TestingT, asgName string, awsRegion string) ([]string, error)
func GetLaunchPermissionsForAmiE(t testing.TestingT, awsRegion string, amiID string) ([]*ec2.LaunchPermission, error)
func GetMostRecentAmiId(t testing.TestingT, region string, ownerId string, filters map[string][]string) string
func GetMostRecentAmiIdE(t testing.TestingT, region string, ownerId string, filters map[string][]string) (string, error)
func GetOptionGroupNameOfRdsInstance(t testing.TestingT, dbInstanceID string, awsRegion string) string
func GetOptionGroupNameOfRdsInstanceE(t testing.TestingT, dbInstanceID string, awsRegion string) (string, error)
func GetOptionSettingForOfRdsInstance(t testing.TestingT, optionName string, optionSettingName string, ...) string
func GetOptionSettingForOfRdsInstanceE(t testing.TestingT, optionName string, optionSettingName string, ...) (string, error)
func GetOptionsOfOptionGroup(t testing.TestingT, optionGroupName string, awsRegion string) []*rds.Option
func GetOptionsOfOptionGroupE(t testing.TestingT, optionGroupName string, awsRegion string) ([]*rds.Option, error)
func GetParameter(t testing.TestingT, awsRegion string, keyName string) string
func GetParameterE(t testing.TestingT, awsRegion string, keyName string) (string, error)
func GetParameterValueForParameterOfRdsInstance(t testing.TestingT, parameterName string, dbInstanceID string, ...) string
func GetParameterValueForParameterOfRdsInstanceE(t testing.TestingT, parameterName string, dbInstanceID string, ...) (string, error)
func GetParameterWithClientE(t testing.TestingT, client *ssm.SSM, keyName string) (string, error)
func GetPortOfRdsInstance(t testing.TestingT, dbInstanceID string, awsRegion string) int64
func GetPortOfRdsInstanceE(t testing.TestingT, dbInstanceID string, awsRegion string) (int64, error)
func GetPrivateHostnameOfEc2Instance(t testing.TestingT, instanceID string, awsRegion string) string
func GetPrivateHostnameOfEc2InstanceE(t testing.TestingT, instanceID string, awsRegion string) (string, error)
func GetPrivateHostnamesOfEc2Instances(t testing.TestingT, instanceIDs []string, awsRegion string) map[string]string
func GetPrivateHostnamesOfEc2InstancesE(t testing.TestingT, instanceIDs []string, awsRegion string) (map[string]string, error)
func GetPrivateIpOfEc2Instance(t testing.TestingT, instanceID string, awsRegion string) string
func GetPrivateIpOfEc2InstanceE(t testing.TestingT, instanceID string, awsRegion string) (string, error)
func GetPrivateIpsOfEc2Instances(t testing.TestingT, instanceIDs []string, awsRegion string) map[string]string
func GetPrivateIpsOfEc2InstancesE(t testing.TestingT, instanceIDs []string, awsRegion string) (map[string]string, error)
func GetPublicIpOfEc2Instance(t testing.TestingT, instanceID string, awsRegion string) string
func GetPublicIpOfEc2InstanceE(t testing.TestingT, instanceID string, awsRegion string) (string, error)
func GetPublicIpsOfEc2Instances(t testing.TestingT, instanceIDs []string, awsRegion string) map[string]string
func GetPublicIpsOfEc2InstancesE(t testing.TestingT, instanceIDs []string, awsRegion string) (map[string]string, error)
func GetRandomPrivateCidrBlock(routingPrefix int) string
func GetRandomRegion(t testing.TestingT, approvedRegions []string, forbiddenRegions []string) string
func GetRandomRegionE(t testing.TestingT, approvedRegions []string, forbiddenRegions []string) (string, error)
func GetRandomStableRegion(t testing.TestingT, approvedRegions []string, forbiddenRegions []string) string
func GetRdsInstanceDetailsE(t testing.TestingT, dbInstanceID string, awsRegion string) (*rds.DBInstance, error)
func GetRecommendedInstanceType(t testing.TestingT, region string, instanceTypeOptions []string) string
func GetRecommendedInstanceTypeE(t testing.TestingT, region string, instanceTypeOptions []string) (string, error)
func GetRecommendedInstanceTypeWithClientE(t testing.TestingT, ec2Client *ec2.EC2, instanceTypeOptions []string) (string, error)
func GetRecommendedRdsInstanceType(t testing.TestingT, region string, engine string, engineVersion string, ...) string
func GetRecommendedRdsInstanceTypeE(t testing.TestingT, region string, engine string, engineVersion string, ...) (string, error)
func GetRecommendedRdsInstanceTypeWithClientE(t testing.TestingT, rdsClient *rds.RDS, engine string, engineVersion string, ...) (string, error)
func GetS3BucketLoggingTarget(t testing.TestingT, awsRegion string, bucket string) string
func GetS3BucketLoggingTargetE(t testing.TestingT, awsRegion string, bucket string) (string, error)
func GetS3BucketLoggingTargetPrefix(t testing.TestingT, awsRegion string, bucket string) string
func GetS3BucketLoggingTargetPrefixE(t testing.TestingT, awsRegion string, bucket string) (string, error)
func GetS3BucketPolicy(t testing.TestingT, awsRegion string, bucket string) string
func GetS3BucketPolicyE(t testing.TestingT, awsRegion string, bucket string) (string, error)
func GetS3BucketTags(t testing.TestingT, awsRegion string, bucket string) map[string]string
func GetS3BucketTagsE(t testing.TestingT, awsRegion string, bucket string) (map[string]string, error)
func GetS3BucketVersioning(t testing.TestingT, awsRegion string, bucket string) string
func GetS3BucketVersioningE(t testing.TestingT, awsRegion string, bucket string) (string, error)
func GetS3ObjectContents(t testing.TestingT, awsRegion string, bucket string, key string) string
func GetS3ObjectContentsE(t testing.TestingT, awsRegion string, bucket string, key string) (string, error)
func GetSecretValue(t testing.TestingT, awsRegion, id string) string
func GetSecretValueE(t testing.TestingT, awsRegion, id string) (string, error)
func GetSyslogForInstance(t testing.TestingT, instanceID string, awsRegion string) string
func GetSyslogForInstanceE(t testing.TestingT, instanceID string, region string) (string, error)
func GetSyslogForInstancesInAsg(t testing.TestingT, asgName string, awsRegion string) map[string]string
func GetSyslogForInstancesInAsgE(t testing.TestingT, asgName string, awsRegion string) (map[string]string, error)
func GetTagsForEc2Instance(t testing.TestingT, region string, instanceID string) map[string]string
func GetTagsForEc2InstanceE(t testing.TestingT, region string, instanceID string) (map[string]string, error)
func GetTagsForSubnet(t testing.TestingT, subnetId string, region string) map[string]string
func GetTagsForSubnetE(t testing.TestingT, subnetId string, region string) (map[string]string, error)
func GetTagsForVpc(t testing.TestingT, vpcID string, region string) map[string]string
func GetTagsForVpcE(t testing.TestingT, vpcID string, region string) (map[string]string, error)
func GetTimeBasedOneTimePassword(mfaDevice *iam.VirtualMFADevice) (string, error)
func GetUbuntu1404Ami(t testing.TestingT, region string) string
func GetUbuntu1404AmiE(t testing.TestingT, region string) (string, error)
func GetUbuntu1604Ami(t testing.TestingT, region string) string
func GetUbuntu1604AmiE(t testing.TestingT, region string) (string, error)
func GetWhetherSchemaExistsInRdsMySqlInstance(t testing.TestingT, dbUrl string, dbPort int64, dbUsername string, ...) bool
func GetWhetherSchemaExistsInRdsMySqlInstanceE(t testing.TestingT, dbUrl string, dbPort int64, dbUsername string, ...) (bool, error)
func InvokeFunction(t testing.TestingT, region, functionName string, payload interface{}) []byte
func InvokeFunctionE(t testing.TestingT, region, functionName string, payload interface{}) ([]byte, error)
func IsPublicSubnet(t testing.TestingT, subnetId string, region string) bool
func IsPublicSubnetE(t testing.TestingT, subnetId string, region string) (bool, error)
func NewAcmClient(t testing.TestingT, region string) *acm.ACM
func NewAcmClientE(t testing.TestingT, awsRegion string) (*acm.ACM, error)
func NewAsgClient(t testing.TestingT, region string) *autoscaling.AutoScaling
func NewAsgClientE(t testing.TestingT, region string) (*autoscaling.AutoScaling, error)
func NewAuthenticatedSession(region string) (*session.Session, error)
func NewAuthenticatedSessionFromDefaultCredentials(region string) (*session.Session, error)
func NewAuthenticatedSessionFromRole(region string, roleARN string) (*session.Session, error)
func NewCloudWatchLogsClient(t testing.TestingT, region string) *cloudwatchlogs.CloudWatchLogs
func NewCloudWatchLogsClientE(t testing.TestingT, region string) (*cloudwatchlogs.CloudWatchLogs, error)
func NewDynamoDBClient(t testing.TestingT, region string) *dynamodb.DynamoDB
func NewDynamoDBClientE(t testing.TestingT, region string) (*dynamodb.DynamoDB, error)
func NewECRClient(t testing.TestingT, region string) *ecr.ECR
func NewECRClientE(t testing.TestingT, region string) (*ecr.ECR, error)
func NewEc2Client(t testing.TestingT, region string) *ec2.EC2
func NewEc2ClientE(t testing.TestingT, region string) (*ec2.EC2, error)
func NewEcsClient(t testing.TestingT, region string) *ecs.ECS
func NewEcsClientE(t testing.TestingT, region string) (*ecs.ECS, error)
func NewIamClient(t testing.TestingT, region string) *iam.IAM
func NewIamClientE(t testing.TestingT, region string) (*iam.IAM, error)
func NewKmsClient(t testing.TestingT, region string) *kms.KMS
func NewKmsClientE(t testing.TestingT, region string) (*kms.KMS, error)
func NewLambdaClient(t testing.TestingT, region string) *lambda.Lambda
func NewLambdaClientE(t testing.TestingT, region string) (*lambda.Lambda, error)
func NewRdsClient(t testing.TestingT, region string) *rds.RDS
func NewRdsClientE(t testing.TestingT, region string) (*rds.RDS, error)
func NewS3Client(t testing.TestingT, region string) *s3.S3
func NewS3ClientE(t testing.TestingT, region string) (*s3.S3, error)
func NewS3Uploader(t testing.TestingT, region string) *s3manager.Uploader
func NewS3UploaderE(t testing.TestingT, region string) (*s3manager.Uploader, error)
func NewSecretsManagerClient(t testing.TestingT, region string) *secretsmanager.SecretsManager
func NewSecretsManagerClientE(t testing.TestingT, region string) (*secretsmanager.SecretsManager, error)
func NewSnsClient(t testing.TestingT, region string) *sns.SNS
func NewSnsClientE(t testing.TestingT, region string) (*sns.SNS, error)
func NewSqsClient(t testing.TestingT, region string) *sqs.SQS
func NewSqsClientE(t testing.TestingT, region string) (*sqs.SQS, error)
func NewSsmClient(t testing.TestingT, region string) *ssm.SSM
func NewSsmClientE(t testing.TestingT, region string) (*ssm.SSM, error)
func NewStsClientE(t testing.TestingT, region string) (*sts.STS, error)
func PutParameter(t testing.TestingT, awsRegion string, keyName string, keyDescription string, ...) int64
func PutParameterE(t testing.TestingT, awsRegion string, keyName string, keyDescription string, ...) (int64, error)
func PutParameterWithClientE(t testing.TestingT, client *ssm.SSM, keyName string, keyDescription string, ...) (int64, error)
func PutS3BucketPolicy(t testing.TestingT, region string, bucketName string, policyJSONString string)
func PutS3BucketPolicyE(t testing.TestingT, region string, bucketName string, policyJSONString string) error
func PutS3BucketVersioning(t testing.TestingT, region string, bucketName string)
func PutS3BucketVersioningE(t testing.TestingT, region string, bucketName string) error
func ReadPasswordPolicyMinPasswordLength(iamClient *iam.IAM) (int, error)
func SendMessageFifoToQueue(t testing.TestingT, awsRegion string, queueURL string, message string, ...)
func SendMessageToFifoQueueE(t testing.TestingT, awsRegion string, queueURL string, message string, ...) error
func SendMessageToQueue(t testing.TestingT, awsRegion string, queueURL string, message string)
func SendMessageToQueueE(t testing.TestingT, awsRegion string, queueURL string, message string) error
func TerminateInstance(t testing.TestingT, region string, instanceID string)
func TerminateInstanceE(t testing.TestingT, region string, instanceID string) error
func WaitForCapacity(t testing.TestingT, asgName string, region string, maxRetries int, ...)
func WaitForCapacityE(t testing.TestingT, asgName string, region string, maxRetries int, ...) error
func WaitForSsmInstance(t testing.TestingT, awsRegion, instanceID string, timeout time.Duration)
func WaitForSsmInstanceE(t testing.TestingT, awsRegion, instanceID string, timeout time.Duration) error
func WaitForSsmInstanceWithClientE(t testing.TestingT, client *ssm.SSM, instanceID string, timeout time.Duration) error
type AsgCapacityInfo
- func GetCapacityInfoForAsg(t testing.TestingT, asgName string, awsRegion string) AsgCapacityInfo
- func GetCapacityInfoForAsgE(t testing.TestingT, asgName string, awsRegion string) (AsgCapacityInfo, error)
type AsgCapacityNotMetError
- func NewAsgCapacityNotMetError(asgName string, desiredCapacity int64, currentCapacity int64) AsgCapacityNotMetError
- func (err AsgCapacityNotMetError) Error() string
type BucketVersioningNotEnabledError
- func NewBucketVersioningNotEnabledError(s3BucketName string, awsRegion string, versioningStatus string) BucketVersioningNotEnabledError
- func (err BucketVersioningNotEnabledError) Error() string
type CommandOutput
- func CheckSSMCommandWithClientE(t testing.TestingT, client *ssm.SSM, instanceID, command string, ...) (*CommandOutput, error)
- func CheckSSMCommandWithClientWithDocumentE(t testing.TestingT, client *ssm.SSM, instanceID, command string, ...) (*CommandOutput, error)
- func CheckSsmCommand(t testing.TestingT, awsRegion, instanceID, command string, ...) *CommandOutput
- func CheckSsmCommandE(t testing.TestingT, awsRegion, instanceID, command string, ...) (*CommandOutput, error)
- func CheckSsmCommandWithDocument(t testing.TestingT, awsRegion, instanceID, command string, ...) *CommandOutput
- func CheckSsmCommandWithDocumentE(t testing.TestingT, awsRegion, instanceID, command string, ...) (*CommandOutput, error)
type CredentialsError
- func (err CredentialsError) Error() string
type Ec2Keypair
- func CreateAndImportEC2KeyPair(t testing.TestingT, region string, name string) *Ec2Keypair
- func CreateAndImportEC2KeyPairE(t testing.TestingT, region string, name string) (*Ec2Keypair, error)
- func ImportEC2KeyPair(t testing.TestingT, region string, name string, keyPair *ssh.KeyPair) *Ec2Keypair
- func ImportEC2KeyPairE(t testing.TestingT, region string, name string, keyPair *ssh.KeyPair) (*Ec2Keypair, error)
type FunctionError
- func (err *FunctionError) Error() string
type HostnameForEc2InstanceNotFound
- func (err HostnameForEc2InstanceNotFound) Error() string
type InvocationTypeOption
- func (itype *InvocationTypeOption) Value() (string, error)
type IpForEc2InstanceNotFound
- func (err IpForEc2InstanceNotFound) Error() string
type LambdaOptions
type LambdaOutput
- func InvokeFunctionWithParams(t testing.TestingT, region, functionName string, input *LambdaOptions) *LambdaOutput
- func InvokeFunctionWithParamsE(t testing.TestingT, region, functionName string, input *LambdaOptions) (*LambdaOutput, error)
type NoBucketPolicyError
- func NewNoBucketPolicyError(s3BucketName string, awsRegion string, bucketPolicy string) NoBucketPolicyError
- func (err NoBucketPolicyError) Error() string
type NoImagesFound
- func (err NoImagesFound) Error() string
type NoInstanceTypeError
- func (err NoInstanceTypeError) Error() string
type NoRdsInstanceTypeError
- func (err NoRdsInstanceTypeError) Error() string
type NotFoundError
- func NewNotFoundError(objectType string, objectID string, region string) NotFoundError
- func (err NotFoundError) Error() string
type OptionGroupOptionSettingForDbInstanceNotFound
- func (err OptionGroupOptionSettingForDbInstanceNotFound) Error() string
type ParameterForDbInstanceNotFound
- func (err ParameterForDbInstanceNotFound) Error() string
type QueueMessageResponse
- func WaitForQueueMessage(t testing.TestingT, awsRegion string, queueURL string, timeout int) QueueMessageResponse
type ReceiveMessageTimeout
- func (err ReceiveMessageTimeout) Error() string
type RemoteFileSpecification
type S3AccessLoggingNotEnabledErr
- func (err S3AccessLoggingNotEnabledErr) Error() string
type Subnet
- func GetSubnetsForVpc(t testing.TestingT, vpcID string, region string) []Subnet
- func GetSubnetsForVpcE(t testing.TestingT, vpcID string, region string) ([]Subnet, error)
type Vpc
- func GetDefaultVpc(t testing.TestingT, region string) *Vpc
- func GetDefaultVpcE(t testing.TestingT, region string) (*Vpc, error)
- func GetVpcById(t testing.TestingT, vpcId string, region string) *Vpc
- func GetVpcByIdE(t testing.TestingT, vpcId string, region string) (*Vpc, error)
- func GetVpcsE(t testing.TestingT, filters []*ec2.Filter, region string) ([]*Vpc, error)

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 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 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 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 ¶

func (err BucketVersioningNotEnabledError) Error() string

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 ¶

func (err HostnameForEc2InstanceNotFound) Error() string

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 ¶

func (err OptionGroupOptionSettingForDbInstanceNotFound) Error() string

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 ¶

func (err ParameterForDbInstanceNotFound) Error() string

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 ¶

func (err S3AccessLoggingNotEnabledErr) Error() string

type Subnet ¶

type Subnet struct {
	Id               string            // The ID of the Subnet
	AvailabilityZone string            // The Availability Zone the subnet is in
	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

Source Files ¶

View all Source files

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