aws

func AssertPotgresqlDatabaseExists ¶ added in v0.17.0

func AssertPotgresqlDatabaseExists(t *testing.T, dbUrl string, dbPort int32, dbUsername string, dbPassword string, databaseName string) bool

func AssertPotgresqlDatabaseExistsE ¶ added in v0.17.0

func AssertPotgresqlDatabaseExistsE(t *testing.T, dbUrl string, dbPort int32, dbUsername string, dbPassword string, databaseName string) (bool, error)

func AssertPotgresqlGrantsExists ¶ added in v0.17.0

func AssertPotgresqlGrantsExists(t *testing.T, dbUrl string, dbPort int32, dbUsername string, dbPassword string, databaseName string, expectedSchemaName string) bool

func AssertPotgresqlGrantsExistsE ¶ added in v0.17.0

func AssertPotgresqlGrantsExistsE(t *testing.T, dbUrl string, dbPort int32, dbUsername string, dbPassword string, databaseName string, expectedSchemaName string) (bool, error)

func AssertPotgresqlSchemaExists ¶ added in v0.17.0

func AssertPotgresqlSchemaExists(t *testing.T, dbUrl string, dbPort int32, dbUsername string, dbPassword string, databaseName string, expectedSchemaName string) bool

func AssertPotgresqlSchemaExistsE ¶ added in v0.17.0

func AssertPotgresqlSchemaExistsE(t *testing.T, dbUrl string, dbPort int32, dbUsername string, dbPassword string, databaseName string, expectedSchemaName string) (bool, error)

func CleanDNSZoneID ¶ added in v0.23.0

func CleanDNSZoneID(t *testing.T, ctx context.Context, zoneID string, awsRegion string) error

func CreateEksCluster ¶ added in v0.22.0

func CreateEksCluster(t testing.TestingT, ctx context.Context, region string, name string, roleArn string, enablePrivateAccess bool, enablePublicAccess bool, subnets []string, publicAccessCidrs []string, securityGroupIds []string) *types.Cluster

CreateEksCluster creates EKS cluster in the given region under the given name.

func CreateEksClusterE ¶ added in v0.22.0

func CreateEksClusterE(t testing.TestingT, ctx context.Context, region string, name string, roleArn string, enablePrivateAccess bool, enablePublicAccess bool, subnets []string, publicAccessCidrs []string, securityGroupIds []string) (*types.Cluster, error)

CreateEksClusterE creates EKS cluster in the given region under the given name.

func DeleteEksCluster ¶ added in v0.22.0

func DeleteEksCluster(t testing.TestingT, ctx context.Context, region string, cluster *types.Cluster)

DeleteEksCluster deletes existing EKS cluster in the given region.

func DeleteEksClusterE ¶ added in v0.22.0

func DeleteEksClusterE(t testing.TestingT, ctx context.Context, region string, cluster *types.Cluster) error

DeleteEksClusterE deletes existing EKS cluster in the given region.

func GetDNSZoneByNameE ¶ added in v0.17.0

func GetDNSZoneByNameE(t *testing.T, ctx context.Context, hostName string, awsRegion string) (*types.HostedZone, error)

func GetEc2Instances ¶ added in v0.17.0

func GetEc2Instances(t *testing.T, ctx context.Context, instanceID string, awsRegion string) types.Instance

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 GetEksCluster ¶ added in v0.22.0

func GetEksCluster(t testing.TestingT, ctx context.Context, region string, name string) *types.Cluster

GetEksCluster fetches information about an EKS cluster.

func GetEksClusterE ¶ added in v0.22.0

func GetEksClusterE(t testing.TestingT, ctx context.Context, region string, name string) (*types.Cluster, error)

GetEksClusterE fetches information about an EKS cluster.

func GetNatGatewaysByVpcIdE ¶

func GetNatGatewaysByVpcIdE(t *testing.T, ctx context.Context, vpcId string, awsRegion string) ([]types.NatGateway, error)

func NewAmplifyClient ¶

func NewAmplifyClient(t *testing.T, region string) *amplify.Client

func NewAmplifyClientE ¶

func NewAmplifyClientE(t *testing.T, region string) (*amplify.Client, error)

func NewBackupClient ¶ added in v0.17.0

func NewBackupClient(t *testing.T, region string) *backup.Client

func NewBackupClientE ¶ added in v0.17.0

func NewBackupClientE(t *testing.T, region string) (*backup.Client, error)

func NewCloudTrailClient ¶ added in v0.17.0

func NewCloudTrailClient(t *testing.T, region string) *cloudtrail.Client

func NewCloudTrailClientE ¶ added in v0.17.0

func NewCloudTrailClientE(t *testing.T, region string) (*cloudtrail.Client, error)

func NewDocDBClient ¶ added in v0.17.0

func NewDocDBClient(t *testing.T, region string) *docdb.Client

func NewDocDBClientE ¶ added in v0.17.0

func NewDocDBClientE(t *testing.T, region string) (*docdb.Client, error)

func NewEFSClient ¶ added in v0.17.0

func NewEFSClient(t *testing.T, region string) *efs.Client

func NewEFSClientE ¶ added in v0.17.0

func NewEFSClientE(t *testing.T, region string) (*efs.Client, error)

func NewEksClient ¶ added in v0.22.0

func NewEksClient(t testing.TestingT, region string) *eks.Client

NewEksClient creates an EKS client.

func NewEksClientE ¶ added in v0.22.0

func NewEksClientE(t testing.TestingT, region string) (*eks.Client, error)

NewEksClientE creates an EKS client.

func NewElbV2Client ¶

func NewElbV2Client(t *testing.T, region string) *elasticloadbalancingv2.Client

func NewElbV2ClientE ¶

func NewElbV2ClientE(t *testing.T, region string) (*elasticloadbalancingv2.Client, error)

NewElbV2ClientE creates an ELB client.

func NewK8SClientConfig ¶ added in v0.23.0

func NewK8SClientConfig(cluster *types.Cluster) (*rest.Config, error)

func NewK8SClientset ¶ added in v0.22.0

func NewK8SClientset(cluster *types.Cluster) (*kubernetes.Clientset, error)

func NewMSKClient ¶ added in v0.17.0

func NewMSKClient(t *testing.T, region string) *kafka.Client

func NewMSKClientE ¶ added in v0.17.0

func NewMSKClientE(t *testing.T, region string) (*kafka.Client, error)

func NewSESV2Client ¶ added in v0.17.0

func NewSESV2Client(t *testing.T, region string) *sesv2.Client

NewElbV2Client creates en ELB client.

func NewSESV2ClientE ¶ added in v0.17.0

func NewSESV2ClientE(t *testing.T, region string) (*sesv2.Client, error)

NewSESV2ClientE creates an SES v2 client.

func NewWAFClient ¶ added in v0.20.0

func NewWAFClient(t *testing.T, region string) *wafv2.Client

func NewWAFClientE ¶ added in v0.20.0

func NewWAFClientE(t *testing.T, region string) (*wafv2.Client, error)

func StartDeploymentJob ¶

func StartDeploymentJob(t *testing.T, ctx context.Context, client *amplify.Client, id *string, branchName *string) *string

func WafCreateRegexPatternSet ¶ added in v0.20.0

func WafCreateRegexPatternSet(client *wafv2.Client, name string, description string, patterns []string) (*types.RegexPatternSetSummary, error)

func WafGetIPSetByARN ¶ added in v0.20.0

func WafGetIPSetByARN(t *testing.T, client *wafv2.Client, arn string) *wafv2.GetIPSetOutput