// Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package rds_test import ( "fmt" "strings" "time" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/awserr" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/rds" ) var _ time.Duration var _ strings.Reader var _ aws.Config func parseTime(layout, value string) *time.Time { t, err := time.Parse(layout, value) if err != nil { panic(err) } return &t } // To associate an AWS Identity and Access Management (IAM) role with a DB cluster // // The following example associates a role with a DB cluster. func ExampleRDS_AddRoleToDBCluster_shared00() { svc := rds.New(session.New()) input := &rds.AddRoleToDBClusterInput{ DBClusterIdentifier: aws.String("mydbcluster"), RoleArn: aws.String("arn:aws:iam::123456789012:role/RDSLoadFromS3"), } result, err := svc.AddRoleToDBCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterRoleAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterRoleAlreadyExistsFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeDBClusterRoleQuotaExceededFault: fmt.Println(rds.ErrCodeDBClusterRoleQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To associate an AWS Identity and Access Management (IAM) role with a DB instance // // The following example adds the role to a DB instance named test-instance. func ExampleRDS_AddRoleToDBInstance_shared00() { svc := rds.New(session.New()) input := &rds.AddRoleToDBInstanceInput{ DBInstanceIdentifier: aws.String("test-instance"), FeatureName: aws.String("S3_INTEGRATION"), RoleArn: aws.String("arn:aws:iam::111122223333:role/rds-s3-integration-role"), } result, err := svc.AddRoleToDBInstance(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBInstanceRoleAlreadyExistsFault: fmt.Println(rds.ErrCodeDBInstanceRoleAlreadyExistsFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeDBInstanceRoleQuotaExceededFault: fmt.Println(rds.ErrCodeDBInstanceRoleQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To add a source identifier to a subscription // // The following example adds another source identifier to an existing subscription. func ExampleRDS_AddSourceIdentifierToSubscription_shared00() { svc := rds.New(session.New()) input := &rds.AddSourceIdentifierToSubscriptionInput{ SourceIdentifier: aws.String("test-instance-repl"), SubscriptionName: aws.String("my-instance-events"), } result, err := svc.AddSourceIdentifierToSubscription(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeSubscriptionNotFoundFault: fmt.Println(rds.ErrCodeSubscriptionNotFoundFault, aerr.Error()) case rds.ErrCodeSourceNotFoundFault: fmt.Println(rds.ErrCodeSourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To add tags to a resource // // This example adds a tag to an option group. func ExampleRDS_AddTagsToResource_shared00() { svc := rds.New(session.New()) input := &rds.AddTagsToResourceInput{ ResourceName: aws.String("arn:aws:rds:us-east-1:992648334831:og:mymysqloptiongroup"), Tags: []*rds.Tag{ { Key: aws.String("Staging"), Value: aws.String("LocationDB"), }, }, } result, err := svc.AddTagsToResource(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeDBProxyNotFoundFault: fmt.Println(rds.ErrCodeDBProxyNotFoundFault, aerr.Error()) case rds.ErrCodeDBProxyTargetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBProxyTargetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeBlueGreenDeploymentNotFoundFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To apply pending maintenance actions // // The following example applies the pending maintenance actions for a DB cluster. func ExampleRDS_ApplyPendingMaintenanceAction_shared00() { svc := rds.New(session.New()) input := &rds.ApplyPendingMaintenanceActionInput{ ApplyAction: aws.String("system-update"), OptInType: aws.String("immediate"), ResourceIdentifier: aws.String("arn:aws:rds:us-east-1:123456789012:cluster:my-db-cluster"), } result, err := svc.ApplyPendingMaintenanceAction(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeResourceNotFoundFault: fmt.Println(rds.ErrCodeResourceNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To authorize DB security group integress // // This example authorizes access to the specified security group by the specified CIDR // block. func ExampleRDS_AuthorizeDBSecurityGroupIngress_shared00() { svc := rds.New(session.New()) input := &rds.AuthorizeDBSecurityGroupIngressInput{ CIDRIP: aws.String("203.0.113.5/32"), DBSecurityGroupName: aws.String("mydbsecuritygroup"), } result, err := svc.AuthorizeDBSecurityGroupIngress(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSecurityGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSecurityGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBSecurityGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBSecurityGroupStateFault, aerr.Error()) case rds.ErrCodeAuthorizationAlreadyExistsFault: fmt.Println(rds.ErrCodeAuthorizationAlreadyExistsFault, aerr.Error()) case rds.ErrCodeAuthorizationQuotaExceededFault: fmt.Println(rds.ErrCodeAuthorizationQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To cancel a snapshot export to Amazon S3 // // The following example cancels an export task in progress that is exporting a snapshot // to Amazon S3. func ExampleRDS_CancelExportTask_shared00() { svc := rds.New(session.New()) input := &rds.CancelExportTaskInput{ ExportTaskIdentifier: aws.String("my-s3-export-1"), } result, err := svc.CancelExportTask(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeExportTaskNotFoundFault: fmt.Println(rds.ErrCodeExportTaskNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidExportTaskStateFault: fmt.Println(rds.ErrCodeInvalidExportTaskStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To copy a DB cluster parameter group // // This example copies a DB cluster parameter group. func ExampleRDS_CopyDBClusterParameterGroup_shared00() { svc := rds.New(session.New()) input := &rds.CopyDBClusterParameterGroupInput{ SourceDBClusterParameterGroupIdentifier: aws.String("mydbclusterparametergroup"), TargetDBClusterParameterGroupDescription: aws.String("My DB cluster parameter group copy"), TargetDBClusterParameterGroupIdentifier: aws.String("mydbclusterparametergroup-copy"), } result, err := svc.CopyDBClusterParameterGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBParameterGroupQuotaExceededFault: fmt.Println(rds.ErrCodeDBParameterGroupQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBParameterGroupAlreadyExistsFault: fmt.Println(rds.ErrCodeDBParameterGroupAlreadyExistsFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To copy a DB cluster snapshot // // The following example creates a copy of a DB cluster snapshot, including its tags. func ExampleRDS_CopyDBClusterSnapshot_shared00() { svc := rds.New(session.New()) input := &rds.CopyDBClusterSnapshotInput{ CopyTags: aws.Bool(true), SourceDBClusterSnapshotIdentifier: aws.String("arn:aws:rds:us-east-1:123456789012:cluster-snapshot:rds:myaurora-2019-06-04-09-16"), TargetDBClusterSnapshotIdentifier: aws.String("myclustersnapshotcopy"), } result, err := svc.CopyDBClusterSnapshot(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterSnapshotAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterSnapshotAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBClusterSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBClusterSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterSnapshotStateFault, aerr.Error()) case rds.ErrCodeSnapshotQuotaExceededFault: fmt.Println(rds.ErrCodeSnapshotQuotaExceededFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To copy a DB parameter group // // The following example makes a copy of a DB parameter group. func ExampleRDS_CopyDBParameterGroup_shared00() { svc := rds.New(session.New()) input := &rds.CopyDBParameterGroupInput{ SourceDBParameterGroupIdentifier: aws.String("mydbpg"), TargetDBParameterGroupDescription: aws.String("Copy of mydbpg parameter group"), TargetDBParameterGroupIdentifier: aws.String("mydbpgcopy"), } result, err := svc.CopyDBParameterGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBParameterGroupAlreadyExistsFault: fmt.Println(rds.ErrCodeDBParameterGroupAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBParameterGroupQuotaExceededFault: fmt.Println(rds.ErrCodeDBParameterGroupQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To copy a DB snapshot // // The following example creates a copy of a DB snapshot. func ExampleRDS_CopyDBSnapshot_shared00() { svc := rds.New(session.New()) input := &rds.CopyDBSnapshotInput{ SourceDBSnapshotIdentifier: aws.String("rds:database-mysql-2019-06-06-08-38"), TargetDBSnapshotIdentifier: aws.String("mydbsnapshotcopy"), } result, err := svc.CopyDBSnapshot(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSnapshotAlreadyExistsFault: fmt.Println(rds.ErrCodeDBSnapshotAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBSnapshotStateFault, aerr.Error()) case rds.ErrCodeSnapshotQuotaExceededFault: fmt.Println(rds.ErrCodeSnapshotQuotaExceededFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeCustomAvailabilityZoneNotFoundFault: fmt.Println(rds.ErrCodeCustomAvailabilityZoneNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To copy an option group // // The following example makes a copy of an option group. func ExampleRDS_CopyOptionGroup_shared00() { svc := rds.New(session.New()) input := &rds.CopyOptionGroupInput{ SourceOptionGroupIdentifier: aws.String("myoptiongroup"), TargetOptionGroupDescription: aws.String("My option group copy"), TargetOptionGroupIdentifier: aws.String("new-option-group"), } result, err := svc.CopyOptionGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeOptionGroupAlreadyExistsFault: fmt.Println(rds.ErrCodeOptionGroupAlreadyExistsFault, aerr.Error()) case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) case rds.ErrCodeOptionGroupQuotaExceededFault: fmt.Println(rds.ErrCodeOptionGroupQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a blue/green deployment for an RDS for MySQL DB instance // // The following example creates a blue/green deployment for a MySQL DB instance. func ExampleRDS_CreateBlueGreenDeployment_shared00() { svc := rds.New(session.New()) input := &rds.CreateBlueGreenDeploymentInput{ BlueGreenDeploymentName: aws.String("bgd-test-instance"), Source: aws.String("arn:aws:rds:us-east-1:123456789012:db:my-db-instance"), TargetDBParameterGroupName: aws.String("mysql-80-group"), TargetEngineVersion: aws.String("8.0"), } result, err := svc.CreateBlueGreenDeployment(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeSourceDatabaseNotSupportedFault: fmt.Println(rds.ErrCodeSourceDatabaseNotSupportedFault, aerr.Error()) case rds.ErrCodeSourceClusterNotSupportedFault: fmt.Println(rds.ErrCodeSourceClusterNotSupportedFault, aerr.Error()) case rds.ErrCodeBlueGreenDeploymentAlreadyExistsFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBClusterParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInstanceQuotaExceededFault: fmt.Println(rds.ErrCodeInstanceQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBClusterQuotaExceededFault: fmt.Println(rds.ErrCodeDBClusterQuotaExceededFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a blue/green deployment for an Aurora MySQL DB cluster // // The following example creates a blue/green deployment for an Aurora MySQL DB cluster. func ExampleRDS_CreateBlueGreenDeployment_shared01() { svc := rds.New(session.New()) input := &rds.CreateBlueGreenDeploymentInput{ BlueGreenDeploymentName: aws.String("my-blue-green-deployment"), Source: aws.String("arn:aws:rds:us-east-1:123456789012:cluster:my-aurora-mysql-cluster"), TargetDBClusterParameterGroupName: aws.String("mysql-80-cluster-group"), TargetDBParameterGroupName: aws.String("ams-80-binlog-enabled"), TargetEngineVersion: aws.String("8.0"), } result, err := svc.CreateBlueGreenDeployment(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeSourceDatabaseNotSupportedFault: fmt.Println(rds.ErrCodeSourceDatabaseNotSupportedFault, aerr.Error()) case rds.ErrCodeSourceClusterNotSupportedFault: fmt.Println(rds.ErrCodeSourceClusterNotSupportedFault, aerr.Error()) case rds.ErrCodeBlueGreenDeploymentAlreadyExistsFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBClusterParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInstanceQuotaExceededFault: fmt.Println(rds.ErrCodeInstanceQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBClusterQuotaExceededFault: fmt.Println(rds.ErrCodeDBClusterQuotaExceededFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a MySQL 5.7-compatible DB cluster // // The following example creates a MySQL 5.7-compatible Aurora DB cluster. func ExampleRDS_CreateDBCluster_shared00() { svc := rds.New(session.New()) input := &rds.CreateDBClusterInput{ DBClusterIdentifier: aws.String("sample-cluster"), DBSubnetGroupName: aws.String("default"), Engine: aws.String("aurora-mysql"), EngineVersion: aws.String("5.7.12"), MasterUserPassword: aws.String("mypassword"), MasterUsername: aws.String("admin"), VpcSecurityGroupIds: []*string{ aws.String("sg-0b91305example"), }, } result, err := svc.CreateDBCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterAlreadyExistsFault, aerr.Error()) case rds.ErrCodeInsufficientStorageClusterCapacityFault: fmt.Println(rds.ErrCodeInsufficientStorageClusterCapacityFault, aerr.Error()) case rds.ErrCodeDBClusterQuotaExceededFault: fmt.Println(rds.ErrCodeDBClusterQuotaExceededFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBSubnetGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBSubnetGroupStateFault, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeDBClusterParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBClusterParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case rds.ErrCodeGlobalClusterNotFoundFault: fmt.Println(rds.ErrCodeGlobalClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidGlobalClusterStateFault: fmt.Println(rds.ErrCodeInvalidGlobalClusterStateFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a PostgreSQL-compatible DB cluster // // The following example creates a PostgreSQL-compatible Aurora DB cluster. func ExampleRDS_CreateDBCluster_shared01() { svc := rds.New(session.New()) input := &rds.CreateDBClusterInput{ DBClusterIdentifier: aws.String("sample-pg-cluster"), DBSubnetGroupName: aws.String("default"), Engine: aws.String("aurora-postgresql"), MasterUserPassword: aws.String("mypassword"), MasterUsername: aws.String("admin"), VpcSecurityGroupIds: []*string{ aws.String("sg-0b91305example"), }, } result, err := svc.CreateDBCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterAlreadyExistsFault, aerr.Error()) case rds.ErrCodeInsufficientStorageClusterCapacityFault: fmt.Println(rds.ErrCodeInsufficientStorageClusterCapacityFault, aerr.Error()) case rds.ErrCodeDBClusterQuotaExceededFault: fmt.Println(rds.ErrCodeDBClusterQuotaExceededFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBSubnetGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBSubnetGroupStateFault, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeDBClusterParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBClusterParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case rds.ErrCodeGlobalClusterNotFoundFault: fmt.Println(rds.ErrCodeGlobalClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidGlobalClusterStateFault: fmt.Println(rds.ErrCodeInvalidGlobalClusterStateFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a custom DB cluster endpoint // // The following example creates a custom DB cluster endpoint and associate it with // the specified Aurora DB cluster. func ExampleRDS_CreateDBClusterEndpoint_shared00() { svc := rds.New(session.New()) input := &rds.CreateDBClusterEndpointInput{ DBClusterEndpointIdentifier: aws.String("mycustomendpoint"), DBClusterIdentifier: aws.String("mydbcluster"), EndpointType: aws.String("reader"), StaticMembers: []*string{ aws.String("dbinstance1"), aws.String("dbinstance2"), }, } result, err := svc.CreateDBClusterEndpoint(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterEndpointQuotaExceededFault: fmt.Println(rds.ErrCodeDBClusterEndpointQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBClusterEndpointAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterEndpointAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a DB cluster parameter group // // The following example creates a DB cluster parameter group. func ExampleRDS_CreateDBClusterParameterGroup_shared00() { svc := rds.New(session.New()) input := &rds.CreateDBClusterParameterGroupInput{ DBClusterParameterGroupName: aws.String("mydbclusterparametergroup"), DBParameterGroupFamily: aws.String("aurora5.6"), Description: aws.String("My new cluster parameter group"), } result, err := svc.CreateDBClusterParameterGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBParameterGroupQuotaExceededFault: fmt.Println(rds.ErrCodeDBParameterGroupQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBParameterGroupAlreadyExistsFault: fmt.Println(rds.ErrCodeDBParameterGroupAlreadyExistsFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a DB cluster snapshot // // The following example creates a DB cluster snapshot. func ExampleRDS_CreateDBClusterSnapshot_shared00() { svc := rds.New(session.New()) input := &rds.CreateDBClusterSnapshotInput{ DBClusterIdentifier: aws.String("mydbclustersnapshot"), DBClusterSnapshotIdentifier: aws.String("mydbcluster"), } result, err := svc.CreateDBClusterSnapshot(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterSnapshotAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterSnapshotAlreadyExistsFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeSnapshotQuotaExceededFault: fmt.Println(rds.ErrCodeSnapshotQuotaExceededFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterSnapshotStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a DB instance // // The following example uses the required options to launch a new DB instance. func ExampleRDS_CreateDBInstance_shared00() { svc := rds.New(session.New()) input := &rds.CreateDBInstanceInput{ AllocatedStorage: aws.Int64(20), DBInstanceClass: aws.String("db.t3.micro"), DBInstanceIdentifier: aws.String("test-mysql-instance"), Engine: aws.String("mysql"), MasterUserPassword: aws.String("secret99"), MasterUsername: aws.String("admin"), } result, err := svc.CreateDBInstance(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceAlreadyExistsFault: fmt.Println(rds.ErrCodeDBInstanceAlreadyExistsFault, aerr.Error()) case rds.ErrCodeInsufficientDBInstanceCapacityFault: fmt.Println(rds.ErrCodeInsufficientDBInstanceCapacityFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBSecurityGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSecurityGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInstanceQuotaExceededFault: fmt.Println(rds.ErrCodeInstanceQuotaExceededFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeProvisionedIopsNotAvailableInAZFault: fmt.Println(rds.ErrCodeProvisionedIopsNotAvailableInAZFault, aerr.Error()) case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeStorageTypeNotSupportedFault: fmt.Println(rds.ErrCodeStorageTypeNotSupportedFault, aerr.Error()) case rds.ErrCodeAuthorizationNotFoundFault: fmt.Println(rds.ErrCodeAuthorizationNotFoundFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) case rds.ErrCodeBackupPolicyNotFoundFault: fmt.Println(rds.ErrCodeBackupPolicyNotFoundFault, aerr.Error()) case rds.ErrCodeNetworkTypeNotSupported: fmt.Println(rds.ErrCodeNetworkTypeNotSupported, aerr.Error()) case rds.ErrCodeCertificateNotFoundFault: fmt.Println(rds.ErrCodeCertificateNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a DB instance read replica // // This example creates a read replica of an existing DB instance named test-instance. // The read replica is named test-instance-repl. func ExampleRDS_CreateDBInstanceReadReplica_shared00() { svc := rds.New(session.New()) input := &rds.CreateDBInstanceReadReplicaInput{ DBInstanceIdentifier: aws.String("test-instance-repl"), SourceDBInstanceIdentifier: aws.String("test-instance"), } result, err := svc.CreateDBInstanceReadReplica(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceAlreadyExistsFault: fmt.Println(rds.ErrCodeDBInstanceAlreadyExistsFault, aerr.Error()) case rds.ErrCodeInsufficientDBInstanceCapacityFault: fmt.Println(rds.ErrCodeInsufficientDBInstanceCapacityFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBSecurityGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSecurityGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInstanceQuotaExceededFault: fmt.Println(rds.ErrCodeInstanceQuotaExceededFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeProvisionedIopsNotAvailableInAZFault: fmt.Println(rds.ErrCodeProvisionedIopsNotAvailableInAZFault, aerr.Error()) case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotAllowedFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotAllowedFault, aerr.Error()) case rds.ErrCodeInvalidDBSubnetGroupFault: fmt.Println(rds.ErrCodeInvalidDBSubnetGroupFault, aerr.Error()) case rds.ErrCodeStorageTypeNotSupportedFault: fmt.Println(rds.ErrCodeStorageTypeNotSupportedFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) case rds.ErrCodeNetworkTypeNotSupported: fmt.Println(rds.ErrCodeNetworkTypeNotSupported, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a DB parameter group // // The following example creates a DB parameter group. func ExampleRDS_CreateDBParameterGroup_shared00() { svc := rds.New(session.New()) input := &rds.CreateDBParameterGroupInput{ DBParameterGroupFamily: aws.String("MySQL8.0"), DBParameterGroupName: aws.String("mydbparametergroup"), Description: aws.String("My new parameter group"), } result, err := svc.CreateDBParameterGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBParameterGroupQuotaExceededFault: fmt.Println(rds.ErrCodeDBParameterGroupQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBParameterGroupAlreadyExistsFault: fmt.Println(rds.ErrCodeDBParameterGroupAlreadyExistsFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a DB security group. // // This example creates a DB security group. func ExampleRDS_CreateDBSecurityGroup_shared00() { svc := rds.New(session.New()) input := &rds.CreateDBSecurityGroupInput{ DBSecurityGroupDescription: aws.String("My DB security group"), DBSecurityGroupName: aws.String("mydbsecuritygroup"), } result, err := svc.CreateDBSecurityGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSecurityGroupAlreadyExistsFault: fmt.Println(rds.ErrCodeDBSecurityGroupAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBSecurityGroupQuotaExceededFault: fmt.Println(rds.ErrCodeDBSecurityGroupQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBSecurityGroupNotSupportedFault: fmt.Println(rds.ErrCodeDBSecurityGroupNotSupportedFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a DB snapshot // // The following example creates a DB snapshot. func ExampleRDS_CreateDBSnapshot_shared00() { svc := rds.New(session.New()) input := &rds.CreateDBSnapshotInput{ DBInstanceIdentifier: aws.String("mydbsnapshot"), DBSnapshotIdentifier: aws.String("database-mysql"), } result, err := svc.CreateDBSnapshot(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSnapshotAlreadyExistsFault: fmt.Println(rds.ErrCodeDBSnapshotAlreadyExistsFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeSnapshotQuotaExceededFault: fmt.Println(rds.ErrCodeSnapshotQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a DB subnet group // // The following example creates a DB subnet group called mysubnetgroup using existing // subnets. func ExampleRDS_CreateDBSubnetGroup_shared00() { svc := rds.New(session.New()) input := &rds.CreateDBSubnetGroupInput{ DBSubnetGroupDescription: aws.String("test DB subnet group"), DBSubnetGroupName: aws.String("mysubnetgroup"), SubnetIds: []*string{ aws.String("subnet-0a1dc4e1a6f123456"), aws.String("subnet-070dd7ecb3aaaaaaa"), aws.String("subnet-00f5b198bc0abcdef"), }, } result, err := svc.CreateDBSubnetGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSubnetGroupAlreadyExistsFault: fmt.Println(rds.ErrCodeDBSubnetGroupAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupQuotaExceededFault: fmt.Println(rds.ErrCodeDBSubnetGroupQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBSubnetQuotaExceededFault: fmt.Println(rds.ErrCodeDBSubnetQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create an event subscription // // The following example creates a subscription for backup and recovery events for DB // instances in the current AWS account. Notifications are sent to an Amazon Simple // Notification Service topic. func ExampleRDS_CreateEventSubscription_shared00() { svc := rds.New(session.New()) input := &rds.CreateEventSubscriptionInput{ EventCategories: []*string{ aws.String("backup"), aws.String("recovery"), }, SnsTopicArn: aws.String("arn:aws:sns:us-east-1:123456789012:interesting-events"), SourceType: aws.String("db-instance"), SubscriptionName: aws.String("my-instance-events"), } result, err := svc.CreateEventSubscription(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeEventSubscriptionQuotaExceededFault: fmt.Println(rds.ErrCodeEventSubscriptionQuotaExceededFault, aerr.Error()) case rds.ErrCodeSubscriptionAlreadyExistFault: fmt.Println(rds.ErrCodeSubscriptionAlreadyExistFault, aerr.Error()) case rds.ErrCodeSNSInvalidTopicFault: fmt.Println(rds.ErrCodeSNSInvalidTopicFault, aerr.Error()) case rds.ErrCodeSNSNoAuthorizationFault: fmt.Println(rds.ErrCodeSNSNoAuthorizationFault, aerr.Error()) case rds.ErrCodeSNSTopicArnNotFoundFault: fmt.Println(rds.ErrCodeSNSTopicArnNotFoundFault, aerr.Error()) case rds.ErrCodeSubscriptionCategoryNotFoundFault: fmt.Println(rds.ErrCodeSubscriptionCategoryNotFoundFault, aerr.Error()) case rds.ErrCodeSourceNotFoundFault: fmt.Println(rds.ErrCodeSourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To create a global DB cluster // // The following example creates a new Aurora MySQL-compatible global DB cluster. func ExampleRDS_CreateGlobalCluster_shared00() { svc := rds.New(session.New()) input := &rds.CreateGlobalClusterInput{ Engine: aws.String("aurora-mysql"), GlobalClusterIdentifier: aws.String("myglobalcluster"), } result, err := svc.CreateGlobalCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeGlobalClusterAlreadyExistsFault: fmt.Println(rds.ErrCodeGlobalClusterAlreadyExistsFault, aerr.Error()) case rds.ErrCodeGlobalClusterQuotaExceededFault: fmt.Println(rds.ErrCodeGlobalClusterQuotaExceededFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To Create an Amazon RDS option group // // The following example creates a new Amazon RDS option group for Oracle MySQL version // 8,0 named MyOptionGroup. func ExampleRDS_CreateOptionGroup_shared00() { svc := rds.New(session.New()) input := &rds.CreateOptionGroupInput{ EngineName: aws.String("mysql"), MajorEngineVersion: aws.String("8.0"), OptionGroupDescription: aws.String("MySQL 8.0 option group"), OptionGroupName: aws.String("MyOptionGroup"), } result, err := svc.CreateOptionGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeOptionGroupAlreadyExistsFault: fmt.Println(rds.ErrCodeOptionGroupAlreadyExistsFault, aerr.Error()) case rds.ErrCodeOptionGroupQuotaExceededFault: fmt.Println(rds.ErrCodeOptionGroupQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete resources in green environment for an RDS for MySQL DB instance // // The following example deletes the resources in a green environment for an RDS for // MySQL DB instance. func ExampleRDS_DeleteBlueGreenDeployment_shared00() { svc := rds.New(session.New()) input := &rds.DeleteBlueGreenDeploymentInput{ BlueGreenDeploymentIdentifier: aws.String("bgd-v53303651eexfake"), DeleteTarget: aws.Bool(true), } result, err := svc.DeleteBlueGreenDeployment(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeBlueGreenDeploymentNotFoundFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidBlueGreenDeploymentStateFault: fmt.Println(rds.ErrCodeInvalidBlueGreenDeploymentStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete resources in green environment for an Aurora MySQL DB cluster // // The following example deletes the resources in a green environment for an Aurora // MySQL DB cluster. func ExampleRDS_DeleteBlueGreenDeployment_shared01() { svc := rds.New(session.New()) input := &rds.DeleteBlueGreenDeploymentInput{ BlueGreenDeploymentIdentifier: aws.String("bgd-wi89nwzglccsfake"), DeleteTarget: aws.Bool(true), } result, err := svc.DeleteBlueGreenDeployment(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeBlueGreenDeploymentNotFoundFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidBlueGreenDeploymentStateFault: fmt.Println(rds.ErrCodeInvalidBlueGreenDeploymentStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a DB cluster // // The following example deletes the DB cluster named mycluster and takes a final snapshot // named mycluster-final-snapshot. The status of the DB cluster is available while the // snapshot is being taken. func ExampleRDS_DeleteDBCluster_shared00() { svc := rds.New(session.New()) input := &rds.DeleteDBClusterInput{ DBClusterIdentifier: aws.String("mycluster"), FinalDBSnapshotIdentifier: aws.String("mycluster-final-snapshot"), SkipFinalSnapshot: aws.Bool(false), } result, err := svc.DeleteDBCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeDBClusterSnapshotAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterSnapshotAlreadyExistsFault, aerr.Error()) case rds.ErrCodeSnapshotQuotaExceededFault: fmt.Println(rds.ErrCodeSnapshotQuotaExceededFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterSnapshotStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a custom DB cluster endpoint // // The following example deletes the specified custom DB cluster endpoint. func ExampleRDS_DeleteDBClusterEndpoint_shared00() { svc := rds.New(session.New()) input := &rds.DeleteDBClusterEndpointInput{ DBClusterEndpointIdentifier: aws.String("mycustomendpoint"), } result, err := svc.DeleteDBClusterEndpoint(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBClusterEndpointStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterEndpointStateFault, aerr.Error()) case rds.ErrCodeDBClusterEndpointNotFoundFault: fmt.Println(rds.ErrCodeDBClusterEndpointNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a DB cluster parameter group // // The following example deletes the specified DB cluster parameter group. func ExampleRDS_DeleteDBClusterParameterGroup_shared00() { svc := rds.New(session.New()) input := &rds.DeleteDBClusterParameterGroupInput{ DBClusterParameterGroupName: aws.String("mydbclusterparametergroup"), } result, err := svc.DeleteDBClusterParameterGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBParameterGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBParameterGroupStateFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a DB cluster snapshot // func ExampleRDS_DeleteDBClusterSnapshot_shared00() { svc := rds.New(session.New()) input := &rds.DeleteDBClusterSnapshotInput{ DBClusterSnapshotIdentifier: aws.String("mydbclustersnapshot"), } result, err := svc.DeleteDBClusterSnapshot(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBClusterSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterSnapshotStateFault, aerr.Error()) case rds.ErrCodeDBClusterSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBClusterSnapshotNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a DB instance // // The following example deletes the specified DB instance after creating a final DB // snapshot named test-instance-final-snap. func ExampleRDS_DeleteDBInstance_shared00() { svc := rds.New(session.New()) input := &rds.DeleteDBInstanceInput{ DBInstanceIdentifier: aws.String("test-instance"), FinalDBSnapshotIdentifier: aws.String("test-instance-final-snap"), SkipFinalSnapshot: aws.Bool(false), } result, err := svc.DeleteDBInstance(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeDBSnapshotAlreadyExistsFault: fmt.Println(rds.ErrCodeDBSnapshotAlreadyExistsFault, aerr.Error()) case rds.ErrCodeSnapshotQuotaExceededFault: fmt.Println(rds.ErrCodeSnapshotQuotaExceededFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeDBInstanceAutomatedBackupQuotaExceededFault: fmt.Println(rds.ErrCodeDBInstanceAutomatedBackupQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a replicated automated backup from a Region // // The following example deletes the automated backup with the specified Amazon Resource // Name (ARN). func ExampleRDS_DeleteDBInstanceAutomatedBackup_shared00() { svc := rds.New(session.New()) input := &rds.DeleteDBInstanceAutomatedBackupInput{ DBInstanceAutomatedBackupsArn: aws.String("arn:aws:rds:us-west-2:123456789012:auto-backup:ab-jkib2gfq5rv7replzadausbrktni2bn4example"), } result, err := svc.DeleteDBInstanceAutomatedBackup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBInstanceAutomatedBackupStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceAutomatedBackupStateFault, aerr.Error()) case rds.ErrCodeDBInstanceAutomatedBackupNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceAutomatedBackupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a DB parameter group // // The following example deletes a DB parameter group. func ExampleRDS_DeleteDBParameterGroup_shared00() { svc := rds.New(session.New()) input := &rds.DeleteDBParameterGroupInput{ DBParameterGroupName: aws.String("mydbparametergroup"), } result, err := svc.DeleteDBParameterGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBParameterGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBParameterGroupStateFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a DB security group // // The following example deletes a DB security group. func ExampleRDS_DeleteDBSecurityGroup_shared00() { svc := rds.New(session.New()) input := &rds.DeleteDBSecurityGroupInput{ DBSecurityGroupName: aws.String("mysecgroup"), } result, err := svc.DeleteDBSecurityGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBSecurityGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBSecurityGroupStateFault, aerr.Error()) case rds.ErrCodeDBSecurityGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSecurityGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a DB snapshot // // The following example deletes the specified DB snapshot. func ExampleRDS_DeleteDBSnapshot_shared00() { svc := rds.New(session.New()) input := &rds.DeleteDBSnapshotInput{ DBSnapshotIdentifier: aws.String("mydbsnapshot"), } result, err := svc.DeleteDBSnapshot(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBSnapshotStateFault, aerr.Error()) case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a DB subnet group // // The following example deletes the DB subnet group called mysubnetgroup. func ExampleRDS_DeleteDBSubnetGroup_shared00() { svc := rds.New(session.New()) input := &rds.DeleteDBSubnetGroupInput{ DBSubnetGroupName: aws.String("mysubnetgroup"), } result, err := svc.DeleteDBSubnetGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBSubnetGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBSubnetGroupStateFault, aerr.Error()) case rds.ErrCodeInvalidDBSubnetStateFault: fmt.Println(rds.ErrCodeInvalidDBSubnetStateFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete an event subscription // // The following example deletes the specified event subscription. func ExampleRDS_DeleteEventSubscription_shared00() { svc := rds.New(session.New()) input := &rds.DeleteEventSubscriptionInput{ SubscriptionName: aws.String("my-instance-events"), } result, err := svc.DeleteEventSubscription(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeSubscriptionNotFoundFault: fmt.Println(rds.ErrCodeSubscriptionNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidEventSubscriptionStateFault: fmt.Println(rds.ErrCodeInvalidEventSubscriptionStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete a global DB cluster // // The following example deletes an Aurora MySQL-compatible global DB cluster. func ExampleRDS_DeleteGlobalCluster_shared00() { svc := rds.New(session.New()) input := &rds.DeleteGlobalClusterInput{ GlobalClusterIdentifier: aws.String("myglobalcluster"), } result, err := svc.DeleteGlobalCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeGlobalClusterNotFoundFault: fmt.Println(rds.ErrCodeGlobalClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidGlobalClusterStateFault: fmt.Println(rds.ErrCodeInvalidGlobalClusterStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To delete an option group // // The following example deletes the specified option group. func ExampleRDS_DeleteOptionGroup_shared00() { svc := rds.New(session.New()) input := &rds.DeleteOptionGroupInput{ OptionGroupName: aws.String("myoptiongroup"), } result, err := svc.DeleteOptionGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidOptionGroupStateFault: fmt.Println(rds.ErrCodeInvalidOptionGroupStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe account attributes // // The following example retrieves the attributes for the current AWS account. func ExampleRDS_DescribeAccountAttributes_shared00() { svc := rds.New(session.New()) input := &rds.DescribeAccountAttributesInput{} result, err := svc.DescribeAccountAttributes(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe a blue/green deployment of an RDS DB instance after creation completes // // The following example retrieves the details of a blue/green deployment after creation // completes. func ExampleRDS_DescribeBlueGreenDeployments_shared00() { svc := rds.New(session.New()) input := &rds.DescribeBlueGreenDeploymentsInput{ BlueGreenDeploymentIdentifier: aws.String("bgd-v53303651eexfake"), } result, err := svc.DescribeBlueGreenDeployments(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeBlueGreenDeploymentNotFoundFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe a blue/green deployment for an Aurora MySQL DB cluster // // The following example retrieves the details of a blue/green deployment. func ExampleRDS_DescribeBlueGreenDeployments_shared01() { svc := rds.New(session.New()) input := &rds.DescribeBlueGreenDeploymentsInput{ BlueGreenDeploymentIdentifier: aws.String("bgd-wi89nwzglccsfake"), } result, err := svc.DescribeBlueGreenDeployments(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeBlueGreenDeploymentNotFoundFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe a blue/green deployment for an Aurora MySQL cluster after switchover // // The following example retrieves the details about a blue/green deployment after the // green environment is promoted to be the production environment. func ExampleRDS_DescribeBlueGreenDeployments_shared02() { svc := rds.New(session.New()) input := &rds.DescribeBlueGreenDeploymentsInput{ BlueGreenDeploymentIdentifier: aws.String("bgd-wi89nwzglccsfake"), } result, err := svc.DescribeBlueGreenDeployments(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeBlueGreenDeploymentNotFoundFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe certificates // // The following example retrieves the details of the certificate associated with the // user's default region. func ExampleRDS_DescribeCertificates_shared00() { svc := rds.New(session.New()) input := &rds.DescribeCertificatesInput{} result, err := svc.DescribeCertificates(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeCertificateNotFoundFault: fmt.Println(rds.ErrCodeCertificateNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe backtracks for a DB cluster // // The following example retrieves details about the specified DB cluster. func ExampleRDS_DescribeDBClusterBacktracks_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBClusterBacktracksInput{ DBClusterIdentifier: aws.String("mydbcluster"), } result, err := svc.DescribeDBClusterBacktracks(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterBacktrackNotFoundFault: fmt.Println(rds.ErrCodeDBClusterBacktrackNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe DB cluster endpoints // // The following example retrieves details for your DB cluster endpoints. The most common // kinds of Aurora clusters have two endpoints. One endpoint has type WRITER. You can // use this endpoint for all SQL statements. The other endpoint has type READER. You // can use this endpoint only for SELECT and other read-only SQL statements. func ExampleRDS_DescribeDBClusterEndpoints_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBClusterEndpointsInput{} result, err := svc.DescribeDBClusterEndpoints(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe DB cluster endpoints of a single DB cluster // // The following example retrieves details for the DB cluster endpoints of a single // specified DB cluster. Aurora Serverless clusters have only a single endpoint with // a type of WRITER. func ExampleRDS_DescribeDBClusterEndpoints_shared01() { svc := rds.New(session.New()) input := &rds.DescribeDBClusterEndpointsInput{ DBClusterIdentifier: aws.String("serverless-cluster"), } result, err := svc.DescribeDBClusterEndpoints(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe DB cluster parameter groups // // The following example retrieves details for your DB cluster parameter groups. func ExampleRDS_DescribeDBClusterParameterGroups_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBClusterParameterGroupsInput{} result, err := svc.DescribeDBClusterParameterGroups(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe the parameters in a DB cluster parameter group // // The following example retrieves details about the parameters in a DB cluster parameter // group. func ExampleRDS_DescribeDBClusterParameters_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBClusterParametersInput{ DBClusterParameterGroupName: aws.String("mydbclusterpg"), } result, err := svc.DescribeDBClusterParameters(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe the attribute names and values for a DB cluster snapshot // // The following example retrieves details of the attribute names and values for the // specified DB cluster snapshot. func ExampleRDS_DescribeDBClusterSnapshotAttributes_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBClusterSnapshotAttributesInput{ DBClusterSnapshotIdentifier: aws.String("myclustersnapshot"), } result, err := svc.DescribeDBClusterSnapshotAttributes(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBClusterSnapshotNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe a DB cluster snapshot for a DB cluster // // The following example retrieves the details for the DB cluster snapshots for the // specified DB cluster. func ExampleRDS_DescribeDBClusterSnapshots_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBClusterSnapshotsInput{ DBClusterIdentifier: aws.String("mydbcluster"), } result, err := svc.DescribeDBClusterSnapshots(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBClusterSnapshotNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe a DB cluster // // The following example retrieves the details of the specified DB cluster. func ExampleRDS_DescribeDBClusters_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBClustersInput{ DBClusterIdentifier: aws.String("mydbcluster"), } result, err := svc.DescribeDBClusters(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe the DB engine versions for the MySQL DB engine // // The following example displays details about each of the DB engine versions for the // specified DB engine. func ExampleRDS_DescribeDBEngineVersions_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBEngineVersionsInput{ Engine: aws.String("mysql"), } result, err := svc.DescribeDBEngineVersions(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe the automated backups for a DB instance // // The following example displays details about the automated backups for the specified // DB instance. The details include replicated automated backups in other AWS Regions. func ExampleRDS_DescribeDBInstanceAutomatedBackups_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBInstanceAutomatedBackupsInput{ DBInstanceIdentifier: aws.String("new-orcl-db"), } result, err := svc.DescribeDBInstanceAutomatedBackups(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceAutomatedBackupNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceAutomatedBackupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe a DB instance // // The following example retrieves details about the specified DB instance. func ExampleRDS_DescribeDBInstances_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBInstancesInput{ DBInstanceIdentifier: aws.String("mydbinstancecf"), } result, err := svc.DescribeDBInstances(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe the log files for a DB instance // // The following example retrieves details about the log files for the specified DB // instance. func ExampleRDS_DescribeDBLogFiles_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBLogFilesInput{ DBInstanceIdentifier: aws.String("test-instance"), } result, err := svc.DescribeDBLogFiles(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe your DB parameter groups // // The following example retrieves details about your DB parameter groups. func ExampleRDS_DescribeDBParameterGroups_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBParameterGroupsInput{} result, err := svc.DescribeDBParameterGroups(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe the parameters in a DB parameter group // // The following example retrieves the details of the specified DB parameter group. func ExampleRDS_DescribeDBParameters_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBParametersInput{ DBParameterGroupName: aws.String("mydbpg"), } result, err := svc.DescribeDBParameters(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To list DB security group settings // // This example lists settings for the specified security group. func ExampleRDS_DescribeDBSecurityGroups_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBSecurityGroupsInput{ DBSecurityGroupName: aws.String("mydbsecuritygroup"), } result, err := svc.DescribeDBSecurityGroups(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSecurityGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSecurityGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe the attribute names and values for a DB snapshot // // The following example describes the attribute names and values for a DB snapshot. func ExampleRDS_DescribeDBSnapshotAttributes_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBSnapshotAttributesInput{ DBSnapshotIdentifier: aws.String("mydbsnapshot"), } result, err := svc.DescribeDBSnapshotAttributes(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe a DB snapshot for a DB instance // // The following example retrieves the details of a DB snapshot for a DB instance. func ExampleRDS_DescribeDBSnapshots_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBSnapshotsInput{ DBSnapshotIdentifier: aws.String("mydbsnapshot"), } result, err := svc.DescribeDBSnapshots(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe a DB subnet group // // The following example retrieves the details of the specified DB subnet group. func ExampleRDS_DescribeDBSubnetGroups_shared00() { svc := rds.New(session.New()) input := &rds.DescribeDBSubnetGroupsInput{} result, err := svc.DescribeDBSubnetGroups(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe the default engine and system parameter information for the Aurora database // engine // // The following example retrieves the details of the default engine and system parameter // information for Aurora DB clusters with MySQL 5.7 compatibility. func ExampleRDS_DescribeEngineDefaultClusterParameters_shared00() { svc := rds.New(session.New()) input := &rds.DescribeEngineDefaultClusterParametersInput{ DBParameterGroupFamily: aws.String("aurora-mysql5.7"), } result, err := svc.DescribeEngineDefaultClusterParameters(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe the default engine and system parameter information for the database // engine // // The following example retrieves details for the default engine and system parameter // information for MySQL 5.7 DB instances. func ExampleRDS_DescribeEngineDefaultParameters_shared00() { svc := rds.New(session.New()) input := &rds.DescribeEngineDefaultParametersInput{ DBParameterGroupFamily: aws.String("mysql5.7"), } result, err := svc.DescribeEngineDefaultParameters(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe event categories // // The following example retrieves details about the event categories for all available // event sources. func ExampleRDS_DescribeEventCategories_shared00() { svc := rds.New(session.New()) input := &rds.DescribeEventCategoriesInput{ SourceType: aws.String(""), } result, err := svc.DescribeEventCategories(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe event subscriptions // // This example describes all of the Amazon RDS event subscriptions for the current // AWS account. func ExampleRDS_DescribeEventSubscriptions_shared00() { svc := rds.New(session.New()) input := &rds.DescribeEventSubscriptionsInput{} result, err := svc.DescribeEventSubscriptions(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeSubscriptionNotFoundFault: fmt.Println(rds.ErrCodeSubscriptionNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe events // // The following retrieves details for the events that have occurred for the specified // DB instance. func ExampleRDS_DescribeEvents_shared00() { svc := rds.New(session.New()) input := &rds.DescribeEventsInput{ SourceIdentifier: aws.String("test-instance"), SourceType: aws.String("db-instance"), } result, err := svc.DescribeEvents(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe snapshot export tasks // // The following example returns information about snapshot exports to Amazon S3. func ExampleRDS_DescribeExportTasks_shared00() { svc := rds.New(session.New()) input := &rds.DescribeExportTasksInput{} result, err := svc.DescribeExportTasks(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeExportTaskNotFoundFault: fmt.Println(rds.ErrCodeExportTaskNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe global DB clusters // // The following example lists Aurora global DB clusters in the current AWS Region. func ExampleRDS_DescribeGlobalClusters_shared00() { svc := rds.New(session.New()) input := &rds.DescribeGlobalClustersInput{} result, err := svc.DescribeGlobalClusters(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeGlobalClusterNotFoundFault: fmt.Println(rds.ErrCodeGlobalClusterNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe all available options // // The following example lists the options for an RDS for MySQL version 8.0 DB instance. func ExampleRDS_DescribeOptionGroupOptions_shared00() { svc := rds.New(session.New()) input := &rds.DescribeOptionGroupOptionsInput{ EngineName: aws.String("mysql"), MajorEngineVersion: aws.String("8.0"), } result, err := svc.DescribeOptionGroupOptions(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe the available option groups // // The following example lists the options groups for an Oracle Database 19c instance. func ExampleRDS_DescribeOptionGroups_shared00() { svc := rds.New(session.New()) input := &rds.DescribeOptionGroupsInput{ EngineName: aws.String("oracle-ee"), MajorEngineVersion: aws.String("19"), } result, err := svc.DescribeOptionGroups(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe orderable DB instance options // // The following example retrieves details about the orderable options for a DB instances // running the MySQL DB engine. func ExampleRDS_DescribeOrderableDBInstanceOptions_shared00() { svc := rds.New(session.New()) input := &rds.DescribeOrderableDBInstanceOptionsInput{ Engine: aws.String("mysql"), } result, err := svc.DescribeOrderableDBInstanceOptions(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To list resources with at least one pending maintenance action // // The following example lists the pending maintenace action for a DB instance. func ExampleRDS_DescribePendingMaintenanceActions_shared00() { svc := rds.New(session.New()) input := &rds.DescribePendingMaintenanceActionsInput{} result, err := svc.DescribePendingMaintenanceActions(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeResourceNotFoundFault: fmt.Println(rds.ErrCodeResourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe reserved DB instances // // The following example retrieves details about any reserved DB instances in the current // AWS account. func ExampleRDS_DescribeReservedDBInstances_shared00() { svc := rds.New(session.New()) input := &rds.DescribeReservedDBInstancesInput{} result, err := svc.DescribeReservedDBInstances(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeReservedDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeReservedDBInstanceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe reserved DB instance offerings // // The following example retrieves details about reserved DB instance options for RDS // for Oracle. func ExampleRDS_DescribeReservedDBInstancesOfferings_shared00() { svc := rds.New(session.New()) input := &rds.DescribeReservedDBInstancesOfferingsInput{ ProductDescription: aws.String("oracle"), } result, err := svc.DescribeReservedDBInstancesOfferings(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeReservedDBInstancesOfferingNotFoundFault: fmt.Println(rds.ErrCodeReservedDBInstancesOfferingNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe source Regions // // The following example retrieves details about all source AWS Regions where the current // AWS Region can create a read replica, copy a DB snapshot from, or replicate automated // backups from. It also shows that automated backups can be replicated only from US // West (Oregon) to the destination AWS Region, US East (N. Virginia). func ExampleRDS_DescribeSourceRegions_shared00() { svc := rds.New(session.New()) input := &rds.DescribeSourceRegionsInput{ RegionName: aws.String("us-east-1"), } result, err := svc.DescribeSourceRegions(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To describe valid modifications for a DB instance // // The following example retrieves details about the valid modifications for the specified // DB instance. func ExampleRDS_DescribeValidDBInstanceModifications_shared00() { svc := rds.New(session.New()) input := &rds.DescribeValidDBInstanceModificationsInput{ DBInstanceIdentifier: aws.String("database-test1"), } result, err := svc.DescribeValidDBInstanceModifications(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To download a DB log file // // The following example downloads only the latest part of your log file. func ExampleRDS_DownloadDBLogFilePortion_shared00() { svc := rds.New(session.New()) input := &rds.DownloadDBLogFilePortionInput{ DBInstanceIdentifier: aws.String("test-instance"), LogFileName: aws.String("log.txt"), } result, err := svc.DownloadDBLogFilePortion(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBLogFileNotFoundFault: fmt.Println(rds.ErrCodeDBLogFileNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To perform a failover for a DB cluster // // This example performs a failover for the specified DB cluster to the specified DB // instance. func ExampleRDS_FailoverDBCluster_shared00() { svc := rds.New(session.New()) input := &rds.FailoverDBClusterInput{ DBClusterIdentifier: aws.String("myaurorainstance-cluster"), TargetDBInstanceIdentifier: aws.String("myaurorareplica"), } result, err := svc.FailoverDBCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To list tags on an Amazon RDS resource // // The following example lists all tags on a DB instance. func ExampleRDS_ListTagsForResource_shared00() { svc := rds.New(session.New()) input := &rds.ListTagsForResourceInput{ ResourceName: aws.String("arn:aws:rds:us-east-1:123456789012:db:orcl1"), } result, err := svc.ListTagsForResource(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBProxyNotFoundFault: fmt.Println(rds.ErrCodeDBProxyNotFoundFault, aerr.Error()) case rds.ErrCodeDBProxyTargetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBProxyTargetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeBlueGreenDeploymentNotFoundFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To temporarily override the system-default SSL/TLS certificate for new DB instances // // The following example temporarily overrides the system-default SSL/TLS certificate // for new DB instances. func ExampleRDS_ModifyCertificates_shared00() { svc := rds.New(session.New()) input := &rds.ModifyCertificatesInput{ CertificateIdentifier: aws.String("rds-ca-2019"), } result, err := svc.ModifyCertificates(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeCertificateNotFoundFault: fmt.Println(rds.ErrCodeCertificateNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To scale the capacity of an Aurora Serverless DB cluster // // The following example scales the capacity of an Aurora Serverless DB cluster to 8. func ExampleRDS_ModifyCurrentDBClusterCapacity_shared00() { svc := rds.New(session.New()) input := &rds.ModifyCurrentDBClusterCapacityInput{ Capacity: aws.Int64(8), DBClusterIdentifier: aws.String("mydbcluster"), } result, err := svc.ModifyCurrentDBClusterCapacity(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterCapacityFault: fmt.Println(rds.ErrCodeInvalidDBClusterCapacityFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify a DB cluster // // The following example changes the master user password for the DB cluster named cluster-2 // and sets the backup retention period to 14 days. The ApplyImmediately parameter causes // the changes to be made immediately, instead of waiting until the next maintenance // window. func ExampleRDS_ModifyDBCluster_shared00() { svc := rds.New(session.New()) input := &rds.ModifyDBClusterInput{ ApplyImmediately: aws.Bool(true), BackupRetentionPeriod: aws.Int64(14), DBClusterIdentifier: aws.String("cluster-2"), MasterUserPassword: aws.String("newpassword99"), } result, err := svc.ModifyDBCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeInvalidDBSubnetGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBSubnetGroupStateFault, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeDBClusterParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBClusterParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBSecurityGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBSecurityGroupStateFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeDBClusterAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBInstanceAlreadyExistsFault: fmt.Println(rds.ErrCodeDBInstanceAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify a custom DB cluster endpoint // // The following example modifies the specified custom DB cluster endpoint. func ExampleRDS_ModifyDBClusterEndpoint_shared00() { svc := rds.New(session.New()) input := &rds.ModifyDBClusterEndpointInput{ DBClusterEndpointIdentifier: aws.String("mycustomendpoint"), StaticMembers: []*string{ aws.String("dbinstance1"), aws.String("dbinstance2"), aws.String("dbinstance3"), }, } result, err := svc.ModifyDBClusterEndpoint(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterEndpointStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterEndpointStateFault, aerr.Error()) case rds.ErrCodeDBClusterEndpointNotFoundFault: fmt.Println(rds.ErrCodeDBClusterEndpointNotFoundFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify parameters in a DB cluster parameter group // // The following example modifies the values of parameters in a DB cluster parameter // group. func ExampleRDS_ModifyDBClusterParameterGroup_shared00() { svc := rds.New(session.New()) input := &rds.ModifyDBClusterParameterGroupInput{ DBClusterParameterGroupName: aws.String("mydbclusterpg"), Parameters: []*rds.Parameter{ { ApplyMethod: aws.String("immediate"), ParameterName: aws.String("server_audit_logging"), ParameterValue: aws.String("1"), }, { ApplyMethod: aws.String("immediate"), ParameterName: aws.String("server_audit_logs_upload"), ParameterValue: aws.String("1"), }, }, } result, err := svc.ModifyDBClusterParameterGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBParameterGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBParameterGroupStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify a DB cluster snapshot attribute // // The following example makes changes to the specified DB cluster snapshot attribute. func ExampleRDS_ModifyDBClusterSnapshotAttribute_shared00() { svc := rds.New(session.New()) input := &rds.ModifyDBClusterSnapshotAttributeInput{ AttributeName: aws.String("restore"), DBClusterSnapshotIdentifier: aws.String("myclustersnapshot"), ValuesToAdd: []*string{ aws.String("123456789012"), }, } result, err := svc.ModifyDBClusterSnapshotAttribute(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBClusterSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterSnapshotStateFault, aerr.Error()) case rds.ErrCodeSharedSnapshotQuotaExceededFault: fmt.Println(rds.ErrCodeSharedSnapshotQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify a DB instance // // The following example associates an option group and a parameter group with a compatible // Microsoft SQL Server DB instance. The ApplyImmediately parameter causes the option // and parameter groups to be associated immediately, instead of waiting until the next // maintenance window. func ExampleRDS_ModifyDBInstance_shared00() { svc := rds.New(session.New()) input := &rds.ModifyDBInstanceInput{ ApplyImmediately: aws.Bool(true), DBInstanceIdentifier: aws.String("database-2"), DBParameterGroupName: aws.String("test-sqlserver-se-2017"), OptionGroupName: aws.String("test-se-2017"), } result, err := svc.ModifyDBInstance(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeInvalidDBSecurityGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBSecurityGroupStateFault, aerr.Error()) case rds.ErrCodeDBInstanceAlreadyExistsFault: fmt.Println(rds.ErrCodeDBInstanceAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBSecurityGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSecurityGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInsufficientDBInstanceCapacityFault: fmt.Println(rds.ErrCodeInsufficientDBInstanceCapacityFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeProvisionedIopsNotAvailableInAZFault: fmt.Println(rds.ErrCodeProvisionedIopsNotAvailableInAZFault, aerr.Error()) case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBUpgradeDependencyFailureFault: fmt.Println(rds.ErrCodeDBUpgradeDependencyFailureFault, aerr.Error()) case rds.ErrCodeStorageTypeNotSupportedFault: fmt.Println(rds.ErrCodeStorageTypeNotSupportedFault, aerr.Error()) case rds.ErrCodeAuthorizationNotFoundFault: fmt.Println(rds.ErrCodeAuthorizationNotFoundFault, aerr.Error()) case rds.ErrCodeCertificateNotFoundFault: fmt.Println(rds.ErrCodeCertificateNotFoundFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) case rds.ErrCodeBackupPolicyNotFoundFault: fmt.Println(rds.ErrCodeBackupPolicyNotFoundFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeNetworkTypeNotSupported: fmt.Println(rds.ErrCodeNetworkTypeNotSupported, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify a DB parameter group // // The following example changes the value of the clr enabled parameter in a DB parameter // group. The value of the ApplyMethod parameter causes the DB parameter group to be // modified immediately, instead of waiting until the next maintenance window. func ExampleRDS_ModifyDBParameterGroup_shared00() { svc := rds.New(session.New()) input := &rds.ModifyDBParameterGroupInput{ DBParameterGroupName: aws.String("test-sqlserver-se-2017"), Parameters: []*rds.Parameter{ { ApplyMethod: aws.String("immediate"), ParameterName: aws.String("clr enabled"), ParameterValue: aws.String("1"), }, }, } result, err := svc.ModifyDBParameterGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBParameterGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBParameterGroupStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify a DB snapshot // // The following example upgrades a PostgeSQL 10.6 snapshot named db5-snapshot-upg-test // to PostgreSQL 11.7. The new DB engine version is shown after the snapshot has finished // upgrading and its status is available. func ExampleRDS_ModifyDBSnapshot_shared00() { svc := rds.New(session.New()) input := &rds.ModifyDBSnapshotInput{ DBSnapshotIdentifier: aws.String("db5-snapshot-upg-test"), EngineVersion: aws.String("11.7"), } result, err := svc.ModifyDBSnapshot(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To allow two AWS accounts to restore a DB snapshot // // The following example grants permission to two AWS accounts, with the identifiers // 111122223333 and 444455556666, to restore the DB snapshot named mydbsnapshot. func ExampleRDS_ModifyDBSnapshotAttribute_shared00() { svc := rds.New(session.New()) input := &rds.ModifyDBSnapshotAttributeInput{ AttributeName: aws.String("restore"), DBSnapshotIdentifier: aws.String("mydbsnapshot"), ValuesToAdd: []*string{ aws.String("111122223333"), aws.String("444455556666"), }, } result, err := svc.ModifyDBSnapshotAttribute(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBSnapshotStateFault, aerr.Error()) case rds.ErrCodeSharedSnapshotQuotaExceededFault: fmt.Println(rds.ErrCodeSharedSnapshotQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To prevent an AWS account from restoring a DB snapshot // // The following example removes permission from the AWS account with the identifier // 444455556666 to restore the DB snapshot named mydbsnapshot. func ExampleRDS_ModifyDBSnapshotAttribute_shared01() { svc := rds.New(session.New()) input := &rds.ModifyDBSnapshotAttributeInput{ AttributeName: aws.String("restore"), DBSnapshotIdentifier: aws.String("mydbsnapshot"), ValuesToRemove: []*string{ aws.String("444455556666"), }, } result, err := svc.ModifyDBSnapshotAttribute(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBSnapshotStateFault, aerr.Error()) case rds.ErrCodeSharedSnapshotQuotaExceededFault: fmt.Println(rds.ErrCodeSharedSnapshotQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify a DB subnet group // // The following example adds a subnet with the ID subnet-08e41f9e230222222 to the DB // subnet group named mysubnetgroup. To keep the existing subnets in the subnet group, // include their IDs as values in the --subnet-ids option. Make sure to have subnets // with at least two different Availability Zones in the DB subnet group. func ExampleRDS_ModifyDBSubnetGroup_shared00() { svc := rds.New(session.New()) input := &rds.ModifyDBSubnetGroupInput{ DBSubnetGroupDescription: aws.String(""), DBSubnetGroupName: aws.String("mysubnetgroup"), SubnetIds: []*string{ aws.String("subnet-0a1dc4e1a6f123456"), aws.String("subnet-070dd7ecb3aaaaaaa"), aws.String("subnet-00f5b198bc0abcdef"), aws.String("subnet-08e41f9e230222222"), }, } result, err := svc.ModifyDBSubnetGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBSubnetQuotaExceededFault: fmt.Println(rds.ErrCodeDBSubnetQuotaExceededFault, aerr.Error()) case rds.ErrCodeSubnetAlreadyInUse: fmt.Println(rds.ErrCodeSubnetAlreadyInUse, aerr.Error()) case rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify an event subscription // // The following example turns off the specified event subscription, so that it no longer // publishes notifications to the specified Amazon Simple Notification Service topic. func ExampleRDS_ModifyEventSubscription_shared00() { svc := rds.New(session.New()) input := &rds.ModifyEventSubscriptionInput{ Enabled: aws.Bool(false), SubscriptionName: aws.String("my-instance-events"), } result, err := svc.ModifyEventSubscription(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeEventSubscriptionQuotaExceededFault: fmt.Println(rds.ErrCodeEventSubscriptionQuotaExceededFault, aerr.Error()) case rds.ErrCodeSubscriptionNotFoundFault: fmt.Println(rds.ErrCodeSubscriptionNotFoundFault, aerr.Error()) case rds.ErrCodeSNSInvalidTopicFault: fmt.Println(rds.ErrCodeSNSInvalidTopicFault, aerr.Error()) case rds.ErrCodeSNSNoAuthorizationFault: fmt.Println(rds.ErrCodeSNSNoAuthorizationFault, aerr.Error()) case rds.ErrCodeSNSTopicArnNotFoundFault: fmt.Println(rds.ErrCodeSNSTopicArnNotFoundFault, aerr.Error()) case rds.ErrCodeSubscriptionCategoryNotFoundFault: fmt.Println(rds.ErrCodeSubscriptionCategoryNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify a global database cluster // // The following example enables deletion protection for an Aurora MySQL-based global // database cluster. func ExampleRDS_ModifyGlobalCluster_shared00() { svc := rds.New(session.New()) input := &rds.ModifyGlobalClusterInput{ DeletionProtection: aws.Bool(true), GlobalClusterIdentifier: aws.String("myglobalcluster"), } result, err := svc.ModifyGlobalCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeGlobalClusterNotFoundFault: fmt.Println(rds.ErrCodeGlobalClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidGlobalClusterStateFault: fmt.Println(rds.ErrCodeInvalidGlobalClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To modify an option group // // The following example adds an option to an option group. func ExampleRDS_ModifyOptionGroup_shared00() { svc := rds.New(session.New()) input := &rds.ModifyOptionGroupInput{ ApplyImmediately: aws.Bool(true), OptionGroupName: aws.String("myawsuser-og02"), OptionsToInclude: []*rds.OptionConfiguration{ { DBSecurityGroupMemberships: []*string{ aws.String("default"), }, OptionName: aws.String("MEMCACHED"), }, }, } result, err := svc.ModifyOptionGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidOptionGroupStateFault: fmt.Println(rds.ErrCodeInvalidOptionGroupStateFault, aerr.Error()) case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To promote a read replica // // The following example promotes the specified read replica to become a standalone // DB instance. func ExampleRDS_PromoteReadReplica_shared00() { svc := rds.New(session.New()) input := &rds.PromoteReadReplicaInput{ DBInstanceIdentifier: aws.String("test-instance-repl"), } result, err := svc.PromoteReadReplica(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To purchase a reserved DB instance // // The following example shows how to buy the reserved DB instance offering from the // previous example. func ExampleRDS_PurchaseReservedDBInstancesOffering_shared00() { svc := rds.New(session.New()) input := &rds.PurchaseReservedDBInstancesOfferingInput{ ReservedDBInstanceId: aws.String("8ba30be1-b9ec-447f-8f23-6114e3f4c7b4"), ReservedDBInstancesOfferingId: aws.String(""), } result, err := svc.PurchaseReservedDBInstancesOffering(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeReservedDBInstancesOfferingNotFoundFault: fmt.Println(rds.ErrCodeReservedDBInstancesOfferingNotFoundFault, aerr.Error()) case rds.ErrCodeReservedDBInstanceAlreadyExistsFault: fmt.Println(rds.ErrCodeReservedDBInstanceAlreadyExistsFault, aerr.Error()) case rds.ErrCodeReservedDBInstanceQuotaExceededFault: fmt.Println(rds.ErrCodeReservedDBInstanceQuotaExceededFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To reboot a DB instance // // The following example starts a reboot of the specified DB instance. func ExampleRDS_RebootDBInstance_shared00() { svc := rds.New(session.New()) input := &rds.RebootDBInstanceInput{ DBInstanceIdentifier: aws.String("test-mysql-instance"), } result, err := svc.RebootDBInstance(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To detach an Aurora secondary cluster from an Aurora global database cluster // // The following example detaches an Aurora secondary cluster from an Aurora global // database cluster. The cluster changes from being read-only to a standalone cluster // with read-write capability. func ExampleRDS_RemoveFromGlobalCluster_shared00() { svc := rds.New(session.New()) input := &rds.RemoveFromGlobalClusterInput{ DbClusterIdentifier: aws.String("arn:aws:rds:us-west-2:123456789012:cluster:DB-1"), GlobalClusterIdentifier: aws.String("myglobalcluster"), } result, err := svc.RemoveFromGlobalCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeGlobalClusterNotFoundFault: fmt.Println(rds.ErrCodeGlobalClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidGlobalClusterStateFault: fmt.Println(rds.ErrCodeInvalidGlobalClusterStateFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To disassociate an Identity and Access Management (IAM) role from a DB cluster // // The following example removes a role from a DB cluster. func ExampleRDS_RemoveRoleFromDBCluster_shared00() { svc := rds.New(session.New()) input := &rds.RemoveRoleFromDBClusterInput{ DBClusterIdentifier: aws.String("mydbcluster"), RoleArn: aws.String("arn:aws:iam::123456789012:role/RDSLoadFromS3"), } result, err := svc.RemoveRoleFromDBCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterRoleNotFoundFault: fmt.Println(rds.ErrCodeDBClusterRoleNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To remove a source identifier from a subscription // // The following example removes the specified source identifier from an existing subscription. func ExampleRDS_RemoveSourceIdentifierFromSubscription_shared00() { svc := rds.New(session.New()) input := &rds.RemoveSourceIdentifierFromSubscriptionInput{ SourceIdentifier: aws.String("test-instance-repl"), SubscriptionName: aws.String("my-instance-events"), } result, err := svc.RemoveSourceIdentifierFromSubscription(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeSubscriptionNotFoundFault: fmt.Println(rds.ErrCodeSubscriptionNotFoundFault, aerr.Error()) case rds.ErrCodeSourceNotFoundFault: fmt.Println(rds.ErrCodeSourceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To remove tags from a resource // // The following example removes tags from a resource. func ExampleRDS_RemoveTagsFromResource_shared00() { svc := rds.New(session.New()) input := &rds.RemoveTagsFromResourceInput{ ResourceName: aws.String("arn:aws:rds:us-east-1:123456789012:db:mydbinstance"), TagKeys: []*string{ aws.String("Name"), aws.String("Environment"), }, } result, err := svc.RemoveTagsFromResource(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBProxyNotFoundFault: fmt.Println(rds.ErrCodeDBProxyNotFoundFault, aerr.Error()) case rds.ErrCodeDBProxyTargetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBProxyTargetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeBlueGreenDeploymentNotFoundFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To reset all parameters to their default values // // The following example resets all parameter values in a customer-created DB cluster // parameter group to their default values. func ExampleRDS_ResetDBClusterParameterGroup_shared00() { svc := rds.New(session.New()) input := &rds.ResetDBClusterParameterGroupInput{ DBClusterParameterGroupName: aws.String("mydbclpg"), ResetAllParameters: aws.Bool(true), } result, err := svc.ResetDBClusterParameterGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBParameterGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBParameterGroupStateFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To reset all parameters to their default values // // The following example resets all parameter values in a customer-created DB parameter // group to their default values. func ExampleRDS_ResetDBParameterGroup_shared00() { svc := rds.New(session.New()) input := &rds.ResetDBParameterGroupInput{ DBParameterGroupName: aws.String("mypg"), ResetAllParameters: aws.Bool(true), } result, err := svc.ResetDBParameterGroup(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBParameterGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBParameterGroupStateFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To restore an Amazon Aurora DB cluster from Amazon S3 // // The following example restores an Amazon Aurora MySQL version 5.7-compatible DB cluster // from a MySQL 5.7 DB backup file in Amazon S3. func ExampleRDS_RestoreDBClusterFromS3_shared00() { svc := rds.New(session.New()) input := &rds.RestoreDBClusterFromS3Input{ DBClusterIdentifier: aws.String("cluster-s3-restore"), Engine: aws.String("aurora-mysql"), MasterUserPassword: aws.String("mypassword"), MasterUsername: aws.String("admin"), S3BucketName: aws.String("mybucket"), S3IngestionRoleArn: aws.String("arn:aws:iam::123456789012:role/service-role/TestBackup"), S3Prefix: aws.String("test-backup"), SourceEngine: aws.String("mysql"), SourceEngineVersion: aws.String("5.7.28"), } result, err := svc.RestoreDBClusterFromS3(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBClusterQuotaExceededFault: fmt.Println(rds.ErrCodeDBClusterQuotaExceededFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBSubnetGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBSubnetGroupStateFault, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeInvalidS3BucketFault: fmt.Println(rds.ErrCodeInvalidS3BucketFault, aerr.Error()) case rds.ErrCodeDBClusterParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBClusterParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) case rds.ErrCodeInsufficientStorageClusterCapacityFault: fmt.Println(rds.ErrCodeInsufficientStorageClusterCapacityFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To restore a DB cluster from a snapshot // // The following example restores an Aurora PostgreSQL DB cluster compatible with PostgreSQL // version 10.7 from a DB cluster snapshot named test-instance-snapshot. func ExampleRDS_RestoreDBClusterFromSnapshot_shared00() { svc := rds.New(session.New()) input := &rds.RestoreDBClusterFromSnapshotInput{ DBClusterIdentifier: aws.String("newdbcluster"), Engine: aws.String("aurora-postgresql"), EngineVersion: aws.String("10.7"), SnapshotIdentifier: aws.String("test-instance-snapshot"), } result, err := svc.RestoreDBClusterFromSnapshot(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBClusterQuotaExceededFault: fmt.Println(rds.ErrCodeDBClusterQuotaExceededFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBClusterSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeInsufficientDBClusterCapacityFault: fmt.Println(rds.ErrCodeInsufficientDBClusterCapacityFault, aerr.Error()) case rds.ErrCodeInsufficientStorageClusterCapacityFault: fmt.Println(rds.ErrCodeInsufficientStorageClusterCapacityFault, aerr.Error()) case rds.ErrCodeInvalidDBSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBSnapshotStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterSnapshotStateFault, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeInvalidRestoreFault: fmt.Println(rds.ErrCodeInvalidRestoreFault, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBClusterParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To restore a DB cluster to a specified time // // The following example restores the DB cluster named database-4 to the latest possible // time. Using copy-on-write as the restore type restores the new DB cluster as a clone // of the source DB cluster. func ExampleRDS_RestoreDBClusterToPointInTime_shared00() { svc := rds.New(session.New()) input := &rds.RestoreDBClusterToPointInTimeInput{ DBClusterIdentifier: aws.String("sample-cluster-clone"), RestoreType: aws.String("copy-on-write"), SourceDBClusterIdentifier: aws.String("database-4"), UseLatestRestorableTime: aws.Bool(true), } result, err := svc.RestoreDBClusterToPointInTime(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterAlreadyExistsFault: fmt.Println(rds.ErrCodeDBClusterAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterQuotaExceededFault: fmt.Println(rds.ErrCodeDBClusterQuotaExceededFault, aerr.Error()) case rds.ErrCodeDBClusterSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBClusterSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeInsufficientDBClusterCapacityFault: fmt.Println(rds.ErrCodeInsufficientDBClusterCapacityFault, aerr.Error()) case rds.ErrCodeInsufficientStorageClusterCapacityFault: fmt.Println(rds.ErrCodeInsufficientStorageClusterCapacityFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterSnapshotStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBSnapshotStateFault, aerr.Error()) case rds.ErrCodeInvalidRestoreFault: fmt.Println(rds.ErrCodeInvalidRestoreFault, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBClusterParameterGroupNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To restore a DB instance from a DB snapshot // // The following example creates a new DB instance named db7-new-instance with the db.t3.small // DB instance class from the specified DB snapshot. The source DB instance from which // the snapshot was taken uses a deprecated DB instance class, so you can't upgrade // it. func ExampleRDS_RestoreDBInstanceFromDBSnapshot_shared00() { svc := rds.New(session.New()) input := &rds.RestoreDBInstanceFromDBSnapshotInput{ DBInstanceClass: aws.String("db.t3.small"), DBInstanceIdentifier: aws.String("db7-new-instance"), DBSnapshotIdentifier: aws.String("db7-test-snapshot"), } result, err := svc.RestoreDBInstanceFromDBSnapshot(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceAlreadyExistsFault: fmt.Println(rds.ErrCodeDBInstanceAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeInstanceQuotaExceededFault: fmt.Println(rds.ErrCodeInstanceQuotaExceededFault, aerr.Error()) case rds.ErrCodeInsufficientDBInstanceCapacityFault: fmt.Println(rds.ErrCodeInsufficientDBInstanceCapacityFault, aerr.Error()) case rds.ErrCodeInvalidDBSnapshotStateFault: fmt.Println(rds.ErrCodeInvalidDBSnapshotStateFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeInvalidRestoreFault: fmt.Println(rds.ErrCodeInvalidRestoreFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeProvisionedIopsNotAvailableInAZFault: fmt.Println(rds.ErrCodeProvisionedIopsNotAvailableInAZFault, aerr.Error()) case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) case rds.ErrCodeStorageTypeNotSupportedFault: fmt.Println(rds.ErrCodeStorageTypeNotSupportedFault, aerr.Error()) case rds.ErrCodeAuthorizationNotFoundFault: fmt.Println(rds.ErrCodeAuthorizationNotFoundFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeDBSecurityGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSecurityGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeBackupPolicyNotFoundFault: fmt.Println(rds.ErrCodeBackupPolicyNotFoundFault, aerr.Error()) case rds.ErrCodeNetworkTypeNotSupported: fmt.Println(rds.ErrCodeNetworkTypeNotSupported, aerr.Error()) case rds.ErrCodeDBClusterSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBClusterSnapshotNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To restore a DB instance to a point in time // // The following example restores test-instance to a new DB instance named restored-test-instance, // as of the specified time. func ExampleRDS_RestoreDBInstanceToPointInTime_shared00() { svc := rds.New(session.New()) input := &rds.RestoreDBInstanceToPointInTimeInput{ RestoreTime: parseTime("2006-01-02T15:04:05.999999999Z", "2018-07-30T23:45:00.000Z"), SourceDBInstanceIdentifier: aws.String("test-instance"), TargetDBInstanceIdentifier: aws.String("restored-test-instance"), } result, err := svc.RestoreDBInstanceToPointInTime(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceAlreadyExistsFault: fmt.Println(rds.ErrCodeDBInstanceAlreadyExistsFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeInstanceQuotaExceededFault: fmt.Println(rds.ErrCodeInstanceQuotaExceededFault, aerr.Error()) case rds.ErrCodeInsufficientDBInstanceCapacityFault: fmt.Println(rds.ErrCodeInsufficientDBInstanceCapacityFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodePointInTimeRestoreNotEnabledFault: fmt.Println(rds.ErrCodePointInTimeRestoreNotEnabledFault, aerr.Error()) case rds.ErrCodeStorageQuotaExceededFault: fmt.Println(rds.ErrCodeStorageQuotaExceededFault, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeInvalidRestoreFault: fmt.Println(rds.ErrCodeInvalidRestoreFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeProvisionedIopsNotAvailableInAZFault: fmt.Println(rds.ErrCodeProvisionedIopsNotAvailableInAZFault, aerr.Error()) case rds.ErrCodeOptionGroupNotFoundFault: fmt.Println(rds.ErrCodeOptionGroupNotFoundFault, aerr.Error()) case rds.ErrCodeStorageTypeNotSupportedFault: fmt.Println(rds.ErrCodeStorageTypeNotSupportedFault, aerr.Error()) case rds.ErrCodeAuthorizationNotFoundFault: fmt.Println(rds.ErrCodeAuthorizationNotFoundFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeDBSecurityGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSecurityGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDomainNotFoundFault: fmt.Println(rds.ErrCodeDomainNotFoundFault, aerr.Error()) case rds.ErrCodeBackupPolicyNotFoundFault: fmt.Println(rds.ErrCodeBackupPolicyNotFoundFault, aerr.Error()) case rds.ErrCodeDBParameterGroupNotFoundFault: fmt.Println(rds.ErrCodeDBParameterGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBInstanceAutomatedBackupNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceAutomatedBackupNotFoundFault, aerr.Error()) case rds.ErrCodeNetworkTypeNotSupported: fmt.Println(rds.ErrCodeNetworkTypeNotSupported, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To revoke ingress for a DB security group // // This example revokes ingress for the specified CIDR block associated with the specified // DB security group. func ExampleRDS_RevokeDBSecurityGroupIngress_shared00() { svc := rds.New(session.New()) input := &rds.RevokeDBSecurityGroupIngressInput{ CIDRIP: aws.String("203.0.113.5/32"), DBSecurityGroupName: aws.String("mydbsecuritygroup"), } result, err := svc.RevokeDBSecurityGroupIngress(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSecurityGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSecurityGroupNotFoundFault, aerr.Error()) case rds.ErrCodeAuthorizationNotFoundFault: fmt.Println(rds.ErrCodeAuthorizationNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBSecurityGroupStateFault: fmt.Println(rds.ErrCodeInvalidDBSecurityGroupStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To start a database activity stream // // The following example starts an asynchronous activity stream to monitor an Aurora // cluster named my-pg-cluster. func ExampleRDS_StartActivityStream_shared00() { svc := rds.New(session.New()) input := &rds.StartActivityStreamInput{ ApplyImmediately: aws.Bool(true), KmsKeyId: aws.String("arn:aws:kms:us-east-1:1234567890123:key/a12c345d-6ef7-890g-h123-456i789jk0l1"), Mode: aws.String("async"), ResourceArn: aws.String("arn:aws:rds:us-east-1:1234567890123:cluster:my-pg-cluster"), } result, err := svc.StartActivityStream(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeResourceNotFoundFault: fmt.Println(rds.ErrCodeResourceNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To start a DB cluster // // The following example starts a DB cluster and its DB instances. func ExampleRDS_StartDBCluster_shared00() { svc := rds.New(session.New()) input := &rds.StartDBClusterInput{ DBClusterIdentifier: aws.String("mydbcluster"), } result, err := svc.StartDBCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To start a DB instance // // The following example starts the specified DB instance. func ExampleRDS_StartDBInstance_shared00() { svc := rds.New(session.New()) input := &rds.StartDBInstanceInput{ DBInstanceIdentifier: aws.String("test-instance"), } result, err := svc.StartDBInstance(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeInsufficientDBInstanceCapacityFault: fmt.Println(rds.ErrCodeInsufficientDBInstanceCapacityFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupNotFoundFault: fmt.Println(rds.ErrCodeDBSubnetGroupNotFoundFault, aerr.Error()) case rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs: fmt.Println(rds.ErrCodeDBSubnetGroupDoesNotCoverEnoughAZs, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidSubnet: fmt.Println(rds.ErrCodeInvalidSubnet, aerr.Error()) case rds.ErrCodeInvalidVPCNetworkStateFault: fmt.Println(rds.ErrCodeInvalidVPCNetworkStateFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeAuthorizationNotFoundFault: fmt.Println(rds.ErrCodeAuthorizationNotFoundFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To enable cross-Region automated backups // // The following example replicates automated backups from a DB instance in the US East // (N. Virginia) Region. The backup retention period is 14 days. func ExampleRDS_StartDBInstanceAutomatedBackupsReplication_shared00() { svc := rds.New(session.New()) input := &rds.StartDBInstanceAutomatedBackupsReplicationInput{ BackupRetentionPeriod: aws.Int64(14), SourceDBInstanceArn: aws.String("arn:aws:rds:us-east-1:123456789012:db:new-orcl-db"), } result, err := svc.StartDBInstanceAutomatedBackupsReplication(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeDBInstanceAutomatedBackupQuotaExceededFault: fmt.Println(rds.ErrCodeDBInstanceAutomatedBackupQuotaExceededFault, aerr.Error()) case rds.ErrCodeStorageTypeNotSupportedFault: fmt.Println(rds.ErrCodeStorageTypeNotSupportedFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To export a snapshot to Amazon S3 // // The following example exports a DB snapshot named db5-snapshot-test to the Amazon // S3 bucket named mybucket. func ExampleRDS_StartExportTask_shared00() { svc := rds.New(session.New()) input := &rds.StartExportTaskInput{ ExportTaskIdentifier: aws.String("my-s3-export"), IamRoleArn: aws.String("arn:aws:iam::123456789012:role/service-role/ExportRole"), KmsKeyId: aws.String("arn:aws:kms:us-west-2:123456789012:key/abcd0000-7fca-4128-82f2-aabbccddeeff"), S3BucketName: aws.String("mybucket"), SourceArn: aws.String("arn:aws:rds:us-west-2:123456789012:snapshot:db5-snapshot-test"), } result, err := svc.StartExportTask(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterSnapshotNotFoundFault: fmt.Println(rds.ErrCodeDBClusterSnapshotNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeExportTaskAlreadyExistsFault: fmt.Println(rds.ErrCodeExportTaskAlreadyExistsFault, aerr.Error()) case rds.ErrCodeInvalidS3BucketFault: fmt.Println(rds.ErrCodeInvalidS3BucketFault, aerr.Error()) case rds.ErrCodeIamRoleNotFoundFault: fmt.Println(rds.ErrCodeIamRoleNotFoundFault, aerr.Error()) case rds.ErrCodeIamRoleMissingPermissionsFault: fmt.Println(rds.ErrCodeIamRoleMissingPermissionsFault, aerr.Error()) case rds.ErrCodeInvalidExportOnlyFault: fmt.Println(rds.ErrCodeInvalidExportOnlyFault, aerr.Error()) case rds.ErrCodeKMSKeyNotAccessibleFault: fmt.Println(rds.ErrCodeKMSKeyNotAccessibleFault, aerr.Error()) case rds.ErrCodeInvalidExportSourceStateFault: fmt.Println(rds.ErrCodeInvalidExportSourceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To stop a database activity stream // // The following example stops an activity stream in an Aurora cluster named my-pg-cluster. func ExampleRDS_StopActivityStream_shared00() { svc := rds.New(session.New()) input := &rds.StopActivityStreamInput{ ApplyImmediately: aws.Bool(true), ResourceArn: aws.String("arn:aws:rds:us-east-1:1234567890123:cluster:my-pg-cluster"), } result, err := svc.StopActivityStream(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeResourceNotFoundFault: fmt.Println(rds.ErrCodeResourceNotFoundFault, aerr.Error()) case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To stop a DB cluster // // The following example stops a DB cluster and its DB instances. func ExampleRDS_StopDBCluster_shared00() { svc := rds.New(session.New()) input := &rds.StopDBClusterInput{ DBClusterIdentifier: aws.String("mydbcluster"), } result, err := svc.StopDBCluster(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBClusterNotFoundFault: fmt.Println(rds.ErrCodeDBClusterNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To stop a DB instance // // The following example stops the specified DB instance. func ExampleRDS_StopDBInstance_shared00() { svc := rds.New(session.New()) input := &rds.StopDBInstanceInput{ DBInstanceIdentifier: aws.String("test-instance"), } result, err := svc.StopDBInstance(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) case rds.ErrCodeDBSnapshotAlreadyExistsFault: fmt.Println(rds.ErrCodeDBSnapshotAlreadyExistsFault, aerr.Error()) case rds.ErrCodeSnapshotQuotaExceededFault: fmt.Println(rds.ErrCodeSnapshotQuotaExceededFault, aerr.Error()) case rds.ErrCodeInvalidDBClusterStateFault: fmt.Println(rds.ErrCodeInvalidDBClusterStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To stop replicating automated backups // // The following example ends replication of automated backups. Replicated backups are // retained according to the set backup retention period. func ExampleRDS_StopDBInstanceAutomatedBackupsReplication_shared00() { svc := rds.New(session.New()) input := &rds.StopDBInstanceAutomatedBackupsReplicationInput{ SourceDBInstanceArn: aws.String("arn:aws:rds:us-east-1:123456789012:db:new-orcl-db"), } result, err := svc.StopDBInstanceAutomatedBackupsReplication(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeDBInstanceNotFoundFault: fmt.Println(rds.ErrCodeDBInstanceNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidDBInstanceStateFault: fmt.Println(rds.ErrCodeInvalidDBInstanceStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To switch a blue/green deployment for an RDS DB instance // // The following example promotes the specified green environment as the new production // environment. func ExampleRDS_SwitchoverBlueGreenDeployment_shared00() { svc := rds.New(session.New()) input := &rds.SwitchoverBlueGreenDeploymentInput{ BlueGreenDeploymentIdentifier: aws.String("bgd-wi89nwzglccsfake"), SwitchoverTimeout: aws.Int64(300), } result, err := svc.SwitchoverBlueGreenDeployment(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeBlueGreenDeploymentNotFoundFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidBlueGreenDeploymentStateFault: fmt.Println(rds.ErrCodeInvalidBlueGreenDeploymentStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) } // To promote a blue/green deployment for an Aurora MySQL DB cluster // // The following example promotes the specified green environment as the new production // environment. func ExampleRDS_SwitchoverBlueGreenDeployment_shared01() { svc := rds.New(session.New()) input := &rds.SwitchoverBlueGreenDeploymentInput{ BlueGreenDeploymentIdentifier: aws.String("bgd-wi89nwzglccsfake"), SwitchoverTimeout: aws.Int64(300), } result, err := svc.SwitchoverBlueGreenDeployment(input) if err != nil { if aerr, ok := err.(awserr.Error); ok { switch aerr.Code() { case rds.ErrCodeBlueGreenDeploymentNotFoundFault: fmt.Println(rds.ErrCodeBlueGreenDeploymentNotFoundFault, aerr.Error()) case rds.ErrCodeInvalidBlueGreenDeploymentStateFault: fmt.Println(rds.ErrCodeInvalidBlueGreenDeploymentStateFault, aerr.Error()) default: fmt.Println(aerr.Error()) } } else { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) } return } fmt.Println(result) }