1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
module Fog
module AWS
class RDS
class Real
require 'fog/aws/parsers/rds/create_db_cluster'
# Create a db cluster
#
# @see http://docs.aws.amazon.com/AmazonRDS/latest/APIReference/API_CreateDBCluster.html
#
# ==== Parameters ====
# * AvailabilityZones<~Array> - A list of EC2 Availability Zones that instances in the DB cluster can be created in
# * BackupRetentionPeriod<~String> - The number of days for which automated backups are retained
# * CharacterSetName<~String> - A value that indicates that the DB cluster should be associated with the specified CharacterSet
# * DatabaseName<~String> - The name for your database of up to 8 alpha-numeric characters. If you do not provide a name, Amazon RDS will not create a database in the DB cluster you are creating
# * DBClusterIdentifier<~String> - The DB cluster identifier. This parameter is stored as a lowercase string
# * DBClusterParameterGroupName<~String> - The name of the DB cluster parameter group to associate with this DB cluster
# * DBSubnetGroupName<~String> - A DB subnet group to associate with this DB cluster
# * Engine<~String> - The name of the database engine to be used for this DB cluster
# * EngineVersion<~String> - The version number of the database engine to use
# * KmsKeyId<~String> - The KMS key identifier for an encrypted DB cluster
# * MasterUsername<~String> - The name of the master user for the client DB cluster
# * MasterUserPassword<~String> - The password for the master database user
# * OptionGroupName<~String> - A value that indicates that the DB cluster should be associated with the specified option group
# * Port<~Integer> - The port number on which the instances in the DB cluster accept connections
# * PreferredBackupWindow<~String> - The daily time range during which automated backups are created if automated backups are enabled using the BackupRetentionPeriod parameter
# * PreferredMaintenanceWindow<~String> - The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC)
# * StorageEncrypted<~Boolean> - Specifies whether the DB cluster is encrypted
# * Tags<~Array> - A list of tags
# * VpcSecurityGroups<~Array> - A list of EC2 VPC security groups to associate with this DB cluster
#
# ==== Returns ====
# * response<~Excon::Response>:
# * body<~Hash>:
def create_db_cluster(cluster_name, options={})
if security_groups = options.delete('VpcSecurityGroups')
options.merge!(Fog::AWS.indexed_param('VpcSecurityGroupIds.member.%d', [*security_groups]))
end
request({
'Action' => 'CreateDBCluster',
'DBClusterIdentifier' => cluster_name,
:parser => Fog::Parsers::AWS::RDS::CreateDBCluster.new,
}.merge(options))
end
end
class Mock
def create_db_cluster(cluster_name, options={})
response = Excon::Response.new
if self.data[:clusters][cluster_name]
raise Fog::AWS::RDS::IdentifierTaken.new("DBClusterAlreadyExists")
end
required_params = %w(Engine MasterUsername MasterUserPassword)
required_params.each do |key|
unless options.key?(key) && options[key] && !options[key].to_s.empty?
raise Fog::AWS::RDS::NotFound.new("The request must contain the parameter #{key}")
end
end
vpc_security_groups = Array(options.delete("VpcSecurityGroups")).map do |group_id|
{"VpcSecurityGroupId" => group_id }
end
data = {
'AllocatedStorage' => "1",
'BackupRetentionPeriod' => (options["BackupRetentionPeriod"] || 35).to_s,
'ClusterCreateTime' => Time.now,
'DBClusterIdentifier' => cluster_name,
'DBClusterMembers' => [],
'DBClusterParameterGroup' => options['DBClusterParameterGroup'] || "default.aurora5.6",
'DBSubnetGroup' => options["DBSubnetGroup"] || "default",
'Endpoint' => "#{cluster_name}.cluster-#{Fog::Mock.random_hex(8)}.#{@region}.rds.amazonaws.com",
'Engine' => options["Engine"] || "aurora5.6",
'EngineVersion' => options["EngineVersion"] || "5.6.10a",
'MasterUsername' => options["MasterUsername"],
'Port' => options["Port"] || "3306",
'PreferredBackupWindow' => options["PreferredBackupWindow"] || "04:45-05:15",
'PreferredMaintenanceWindow' => options["PreferredMaintenanceWindow"] || "sat:05:56-sat:06:26",
'Status' => "available",
'StorageEncrypted' => options["StorageEncrypted"] || false,
'VpcSecurityGroups' => vpc_security_groups,
}
self.data[:clusters][cluster_name] = data
response.body = {
"ResponseMetadata" => { "RequestId" => Fog::AWS::Mock.request_id },
"CreateDBClusterResult" => { "DBCluster" => data.dup.reject { |k,v| k == 'ClusterCreateTime' } }
}
response.status = 200
response
end
end
end
end
end
|
