package awsrds import ( _init_ "github.com/aws/aws-cdk-go/awscdk/v2/jsii" _jsii_ "github.com/aws/jsii-runtime-go/runtime" "github.com/aws/aws-cdk-go/awscdk/v2" "github.com/aws/aws-cdk-go/awscdk/v2/awsec2" "github.com/aws/aws-cdk-go/awscdk/v2/awsiam" "github.com/aws/aws-cdk-go/awscdk/v2/awsrds/internal" "github.com/aws/aws-cdk-go/awscdk/v2/awssecretsmanager" "github.com/aws/constructs-go/constructs/v10" ) // Create an Aurora Serverless Cluster. // // Example: // // Build a data source for AppSync to access the database. // var api graphqlApi // // Create username and password secret for DB Cluster // secret := rds.NewDatabaseSecret(this, jsii.String("AuroraSecret"), &DatabaseSecretProps{ // Username: jsii.String("clusteradmin"), // }) // // // The VPC to place the cluster in // vpc := ec2.NewVpc(this, jsii.String("AuroraVpc")) // // // Create the serverless cluster, provide all values needed to customise the database. // cluster := rds.NewServerlessCluster(this, jsii.String("AuroraCluster"), &ServerlessClusterProps{ // Engine: rds.DatabaseClusterEngine_AURORA_MYSQL(), // Vpc: Vpc, // Credentials: map[string]*string{ // "username": jsii.String("clusteradmin"), // }, // ClusterIdentifier: jsii.String("db-endpoint-test"), // DefaultDatabaseName: jsii.String("demos"), // }) // rdsDS := api.AddRdsDataSource(jsii.String("rds"), cluster, secret, jsii.String("demos")) // // // Set up a resolver for an RDS query. // rdsDS.CreateResolver(jsii.String("QueryGetDemosRdsResolver"), &BaseResolverProps{ // TypeName: jsii.String("Query"), // FieldName: jsii.String("getDemosRds"), // RequestMappingTemplate: appsync.MappingTemplate_FromString(jsii.String(` // { // "version": "2018-05-29", // "statements": [ // "SELECT * FROM demos" // ] // } // `)), // ResponseMappingTemplate: appsync.MappingTemplate_*FromString(jsii.String(` // $utils.toJson($utils.rds.toJsonObject($ctx.result)[0]) // `)), // }) // // // Set up a resolver for an RDS mutation. // rdsDS.CreateResolver(jsii.String("MutationAddDemoRdsResolver"), &BaseResolverProps{ // TypeName: jsii.String("Mutation"), // FieldName: jsii.String("addDemoRds"), // RequestMappingTemplate: appsync.MappingTemplate_*FromString(jsii.String(` // { // "version": "2018-05-29", // "statements": [ // "INSERT INTO demos VALUES (:id, :version)", // "SELECT * WHERE id = :id" // ], // "variableMap": { // ":id": $util.toJson($util.autoId()), // ":version": $util.toJson($ctx.args.version) // } // } // `)), // ResponseMappingTemplate: appsync.MappingTemplate_*FromString(jsii.String(` // $utils.toJson($utils.rds.toJsonObject($ctx.result)[1][0]) // `)), // }) // type ServerlessCluster interface { awscdk.Resource IServerlessCluster // The ARN of the cluster. ClusterArn() *string // The endpoint to use for read/write operations. ClusterEndpoint() Endpoint // Identifier of the cluster. ClusterIdentifier() *string // The endpoint to use for read/write operations. ClusterReadEndpoint() Endpoint // Access to the network connections. Connections() awsec2.Connections EnableDataApi() *bool SetEnableDataApi(val *bool) // The environment this resource belongs to. // // For resources that are created and managed by the CDK // (generally, those created by creating new class instances like Role, Bucket, etc.), // this is always the same as the environment of the stack they belong to; // however, for imported resources // (those obtained from static methods like fromRoleArn, fromBucketName, etc.), // that might be different than the stack they were imported into. Env() *awscdk.ResourceEnvironment NewCfnProps() *CfnDBClusterProps // The tree node. Node() constructs.Node // Returns a string-encoded token that resolves to the physical name that should be passed to the CloudFormation resource. // // This value will resolve to one of the following: // - a concrete value (e.g. `"my-awesome-bucket"`) // - `undefined`, when a name should be generated by CloudFormation // - a concrete name generated automatically during synthesis, in // cross-environment scenarios. PhysicalName() *string // The secret attached to this cluster. Secret() awssecretsmanager.ISecret SecurityGroups() *[]awsec2.ISecurityGroup // The stack in which this resource is defined. Stack() awscdk.Stack // Adds the multi user rotation to this cluster. AddRotationMultiUser(id *string, options *RotationMultiUserOptions) awssecretsmanager.SecretRotation // Adds the single user rotation of the master password to this cluster. AddRotationSingleUser(options *RotationSingleUserOptions) awssecretsmanager.SecretRotation // Apply the given removal policy to this resource. // // The Removal Policy controls what happens to this resource when it stops // being managed by CloudFormation, either because you've removed it from the // CDK application or because you've made a change that requires the resource // to be replaced. // // The resource can be deleted (`RemovalPolicy.DESTROY`), or left in your AWS // account for data recovery and cleanup later (`RemovalPolicy.RETAIN`). ApplyRemovalPolicy(policy awscdk.RemovalPolicy) // Renders the secret attachment target specifications. AsSecretAttachmentTarget() *awssecretsmanager.SecretAttachmentTargetProps GeneratePhysicalName() *string // Returns an environment-sensitive token that should be used for the resource's "ARN" attribute (e.g. `bucket.bucketArn`). // // Normally, this token will resolve to `arnAttr`, but if the resource is // referenced across environments, `arnComponents` will be used to synthesize // a concrete ARN with the resource's physical name. Make sure to reference // `this.physicalName` in `arnComponents`. GetResourceArnAttribute(arnAttr *string, arnComponents *awscdk.ArnComponents) *string // Returns an environment-sensitive token that should be used for the resource's "name" attribute (e.g. `bucket.bucketName`). // // Normally, this token will resolve to `nameAttr`, but if the resource is // referenced across environments, it will be resolved to `this.physicalName`, // which will be a concrete name. GetResourceNameAttribute(nameAttr *string) *string // Grant the given identity to access to the Data API, including read access to the secret attached to the cluster if present. GrantDataApiAccess(grantee awsiam.IGrantable) awsiam.Grant // Returns a string representation of this construct. ToString() *string } // The jsii proxy struct for ServerlessCluster type jsiiProxy_ServerlessCluster struct { internal.Type__awscdkResource jsiiProxy_IServerlessCluster } func (j *jsiiProxy_ServerlessCluster) ClusterArn() *string { var returns *string _jsii_.Get( j, "clusterArn", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) ClusterEndpoint() Endpoint { var returns Endpoint _jsii_.Get( j, "clusterEndpoint", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) ClusterIdentifier() *string { var returns *string _jsii_.Get( j, "clusterIdentifier", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) ClusterReadEndpoint() Endpoint { var returns Endpoint _jsii_.Get( j, "clusterReadEndpoint", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) Connections() awsec2.Connections { var returns awsec2.Connections _jsii_.Get( j, "connections", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) EnableDataApi() *bool { var returns *bool _jsii_.Get( j, "enableDataApi", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) Env() *awscdk.ResourceEnvironment { var returns *awscdk.ResourceEnvironment _jsii_.Get( j, "env", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) NewCfnProps() *CfnDBClusterProps { var returns *CfnDBClusterProps _jsii_.Get( j, "newCfnProps", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) Node() constructs.Node { var returns constructs.Node _jsii_.Get( j, "node", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) PhysicalName() *string { var returns *string _jsii_.Get( j, "physicalName", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) Secret() awssecretsmanager.ISecret { var returns awssecretsmanager.ISecret _jsii_.Get( j, "secret", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) SecurityGroups() *[]awsec2.ISecurityGroup { var returns *[]awsec2.ISecurityGroup _jsii_.Get( j, "securityGroups", &returns, ) return returns } func (j *jsiiProxy_ServerlessCluster) Stack() awscdk.Stack { var returns awscdk.Stack _jsii_.Get( j, "stack", &returns, ) return returns } func NewServerlessCluster(scope constructs.Construct, id *string, props *ServerlessClusterProps) ServerlessCluster { _init_.Initialize() if err := validateNewServerlessClusterParameters(scope, id, props); err != nil { panic(err) } j := jsiiProxy_ServerlessCluster{} _jsii_.Create( "aws-cdk-lib.aws_rds.ServerlessCluster", []interface{}{scope, id, props}, &j, ) return &j } func NewServerlessCluster_Override(s ServerlessCluster, scope constructs.Construct, id *string, props *ServerlessClusterProps) { _init_.Initialize() _jsii_.Create( "aws-cdk-lib.aws_rds.ServerlessCluster", []interface{}{scope, id, props}, s, ) } func (j *jsiiProxy_ServerlessCluster)SetEnableDataApi(val *bool) { _jsii_.Set( j, "enableDataApi", val, ) } // Import an existing DatabaseCluster from properties. func ServerlessCluster_FromServerlessClusterAttributes(scope constructs.Construct, id *string, attrs *ServerlessClusterAttributes) IServerlessCluster { _init_.Initialize() if err := validateServerlessCluster_FromServerlessClusterAttributesParameters(scope, id, attrs); err != nil { panic(err) } var returns IServerlessCluster _jsii_.StaticInvoke( "aws-cdk-lib.aws_rds.ServerlessCluster", "fromServerlessClusterAttributes", []interface{}{scope, id, attrs}, &returns, ) return returns } // Checks if `x` is a construct. // // Use this method instead of `instanceof` to properly detect `Construct` // instances, even when the construct library is symlinked. // // Explanation: in JavaScript, multiple copies of the `constructs` library on // disk are seen as independent, completely different libraries. As a // consequence, the class `Construct` in each copy of the `constructs` library // is seen as a different class, and an instance of one class will not test as // `instanceof` the other class. `npm install` will not create installations // like this, but users may manually symlink construct libraries together or // use a monorepo tool: in those cases, multiple copies of the `constructs` // library can be accidentally installed, and `instanceof` will behave // unpredictably. It is safest to avoid using `instanceof`, and using // this type-testing method instead. // // Returns: true if `x` is an object created from a class which extends `Construct`. func ServerlessCluster_IsConstruct(x interface{}) *bool { _init_.Initialize() if err := validateServerlessCluster_IsConstructParameters(x); err != nil { panic(err) } var returns *bool _jsii_.StaticInvoke( "aws-cdk-lib.aws_rds.ServerlessCluster", "isConstruct", []interface{}{x}, &returns, ) return returns } // Returns true if the construct was created by CDK, and false otherwise. func ServerlessCluster_IsOwnedResource(construct constructs.IConstruct) *bool { _init_.Initialize() if err := validateServerlessCluster_IsOwnedResourceParameters(construct); err != nil { panic(err) } var returns *bool _jsii_.StaticInvoke( "aws-cdk-lib.aws_rds.ServerlessCluster", "isOwnedResource", []interface{}{construct}, &returns, ) return returns } // Check whether the given construct is a Resource. func ServerlessCluster_IsResource(construct constructs.IConstruct) *bool { _init_.Initialize() if err := validateServerlessCluster_IsResourceParameters(construct); err != nil { panic(err) } var returns *bool _jsii_.StaticInvoke( "aws-cdk-lib.aws_rds.ServerlessCluster", "isResource", []interface{}{construct}, &returns, ) return returns } func (s *jsiiProxy_ServerlessCluster) AddRotationMultiUser(id *string, options *RotationMultiUserOptions) awssecretsmanager.SecretRotation { if err := s.validateAddRotationMultiUserParameters(id, options); err != nil { panic(err) } var returns awssecretsmanager.SecretRotation _jsii_.Invoke( s, "addRotationMultiUser", []interface{}{id, options}, &returns, ) return returns } func (s *jsiiProxy_ServerlessCluster) AddRotationSingleUser(options *RotationSingleUserOptions) awssecretsmanager.SecretRotation { if err := s.validateAddRotationSingleUserParameters(options); err != nil { panic(err) } var returns awssecretsmanager.SecretRotation _jsii_.Invoke( s, "addRotationSingleUser", []interface{}{options}, &returns, ) return returns } func (s *jsiiProxy_ServerlessCluster) ApplyRemovalPolicy(policy awscdk.RemovalPolicy) { if err := s.validateApplyRemovalPolicyParameters(policy); err != nil { panic(err) } _jsii_.InvokeVoid( s, "applyRemovalPolicy", []interface{}{policy}, ) } func (s *jsiiProxy_ServerlessCluster) AsSecretAttachmentTarget() *awssecretsmanager.SecretAttachmentTargetProps { var returns *awssecretsmanager.SecretAttachmentTargetProps _jsii_.Invoke( s, "asSecretAttachmentTarget", nil, // no parameters &returns, ) return returns } func (s *jsiiProxy_ServerlessCluster) GeneratePhysicalName() *string { var returns *string _jsii_.Invoke( s, "generatePhysicalName", nil, // no parameters &returns, ) return returns } func (s *jsiiProxy_ServerlessCluster) GetResourceArnAttribute(arnAttr *string, arnComponents *awscdk.ArnComponents) *string { if err := s.validateGetResourceArnAttributeParameters(arnAttr, arnComponents); err != nil { panic(err) } var returns *string _jsii_.Invoke( s, "getResourceArnAttribute", []interface{}{arnAttr, arnComponents}, &returns, ) return returns } func (s *jsiiProxy_ServerlessCluster) GetResourceNameAttribute(nameAttr *string) *string { if err := s.validateGetResourceNameAttributeParameters(nameAttr); err != nil { panic(err) } var returns *string _jsii_.Invoke( s, "getResourceNameAttribute", []interface{}{nameAttr}, &returns, ) return returns } func (s *jsiiProxy_ServerlessCluster) GrantDataApiAccess(grantee awsiam.IGrantable) awsiam.Grant { if err := s.validateGrantDataApiAccessParameters(grantee); err != nil { panic(err) } var returns awsiam.Grant _jsii_.Invoke( s, "grantDataApiAccess", []interface{}{grantee}, &returns, ) return returns } func (s *jsiiProxy_ServerlessCluster) ToString() *string { var returns *string _jsii_.Invoke( s, "toString", nil, // no parameters &returns, ) return returns }