Skip to content

Commit b6b6457

Browse files
gke backup plan iam (#7092) (#13508)
Signed-off-by: Modular Magician <[email protected]> Signed-off-by: Modular Magician <[email protected]>
1 parent 799d954 commit b6b6457

5 files changed

+701
-2
lines changed

.changelog/7092.txt

+9
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
```release-note:new-resource
2+
google_gke_backup_backup_plan_iam_binding
3+
```
4+
```release-note:new-resource
5+
google_gke_backup_backup_plan_iam_member
6+
```
7+
```release-note:new-resource
8+
google_gke_backup_backup_plan_iam_policy
9+
```

google/iam_gke_backup_backup_plan.go

+223
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,223 @@
1+
// ----------------------------------------------------------------------------
2+
//
3+
// *** AUTO GENERATED CODE *** Type: MMv1 ***
4+
//
5+
// ----------------------------------------------------------------------------
6+
//
7+
// This file is automatically generated by Magic Modules and manual
8+
// changes will be clobbered when the file is regenerated.
9+
//
10+
// Please read more about how to change this file in
11+
// .github/CONTRIBUTING.md.
12+
//
13+
// ----------------------------------------------------------------------------
14+
15+
package google
16+
17+
import (
18+
"fmt"
19+
20+
"github.com/hashicorp/errwrap"
21+
"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
22+
"google.golang.org/api/cloudresourcemanager/v1"
23+
)
24+
25+
var GKEBackupBackupPlanIamSchema = map[string]*schema.Schema{
26+
"project": {
27+
Type: schema.TypeString,
28+
Computed: true,
29+
Optional: true,
30+
ForceNew: true,
31+
},
32+
"location": {
33+
Type: schema.TypeString,
34+
Computed: true,
35+
Optional: true,
36+
ForceNew: true,
37+
},
38+
"name": {
39+
Type: schema.TypeString,
40+
Required: true,
41+
ForceNew: true,
42+
DiffSuppressFunc: compareSelfLinkOrResourceName,
43+
},
44+
}
45+
46+
type GKEBackupBackupPlanIamUpdater struct {
47+
project string
48+
location string
49+
name string
50+
d TerraformResourceData
51+
Config *Config
52+
}
53+
54+
func GKEBackupBackupPlanIamUpdaterProducer(d TerraformResourceData, config *Config) (ResourceIamUpdater, error) {
55+
values := make(map[string]string)
56+
57+
project, _ := getProject(d, config)
58+
if project != "" {
59+
if err := d.Set("project", project); err != nil {
60+
return nil, fmt.Errorf("Error setting project: %s", err)
61+
}
62+
}
63+
values["project"] = project
64+
location, _ := getLocation(d, config)
65+
if location != "" {
66+
if err := d.Set("location", location); err != nil {
67+
return nil, fmt.Errorf("Error setting location: %s", err)
68+
}
69+
}
70+
values["location"] = location
71+
if v, ok := d.GetOk("name"); ok {
72+
values["name"] = v.(string)
73+
}
74+
75+
// We may have gotten either a long or short name, so attempt to parse long name if possible
76+
m, err := getImportIdQualifiers([]string{"projects/(?P<project>[^/]+)/locations/(?P<location>[^/]+)/backupPlans/(?P<name>[^/]+)", "(?P<project>[^/]+)/(?P<location>[^/]+)/(?P<name>[^/]+)", "(?P<location>[^/]+)/(?P<name>[^/]+)", "(?P<name>[^/]+)"}, d, config, d.Get("name").(string))
77+
if err != nil {
78+
return nil, err
79+
}
80+
81+
for k, v := range m {
82+
values[k] = v
83+
}
84+
85+
u := &GKEBackupBackupPlanIamUpdater{
86+
project: values["project"],
87+
location: values["location"],
88+
name: values["name"],
89+
d: d,
90+
Config: config,
91+
}
92+
93+
if err := d.Set("project", u.project); err != nil {
94+
return nil, fmt.Errorf("Error setting project: %s", err)
95+
}
96+
if err := d.Set("location", u.location); err != nil {
97+
return nil, fmt.Errorf("Error setting location: %s", err)
98+
}
99+
if err := d.Set("name", u.GetResourceId()); err != nil {
100+
return nil, fmt.Errorf("Error setting name: %s", err)
101+
}
102+
103+
return u, nil
104+
}
105+
106+
func GKEBackupBackupPlanIdParseFunc(d *schema.ResourceData, config *Config) error {
107+
values := make(map[string]string)
108+
109+
project, _ := getProject(d, config)
110+
if project != "" {
111+
values["project"] = project
112+
}
113+
114+
location, _ := getLocation(d, config)
115+
if location != "" {
116+
values["location"] = location
117+
}
118+
119+
m, err := getImportIdQualifiers([]string{"projects/(?P<project>[^/]+)/locations/(?P<location>[^/]+)/backupPlans/(?P<name>[^/]+)", "(?P<project>[^/]+)/(?P<location>[^/]+)/(?P<name>[^/]+)", "(?P<location>[^/]+)/(?P<name>[^/]+)", "(?P<name>[^/]+)"}, d, config, d.Id())
120+
if err != nil {
121+
return err
122+
}
123+
124+
for k, v := range m {
125+
values[k] = v
126+
}
127+
128+
u := &GKEBackupBackupPlanIamUpdater{
129+
project: values["project"],
130+
location: values["location"],
131+
name: values["name"],
132+
d: d,
133+
Config: config,
134+
}
135+
if err := d.Set("name", u.GetResourceId()); err != nil {
136+
return fmt.Errorf("Error setting name: %s", err)
137+
}
138+
d.SetId(u.GetResourceId())
139+
return nil
140+
}
141+
142+
func (u *GKEBackupBackupPlanIamUpdater) GetResourceIamPolicy() (*cloudresourcemanager.Policy, error) {
143+
url, err := u.qualifyBackupPlanUrl("getIamPolicy")
144+
if err != nil {
145+
return nil, err
146+
}
147+
148+
project, err := getProject(u.d, u.Config)
149+
if err != nil {
150+
return nil, err
151+
}
152+
var obj map[string]interface{}
153+
154+
userAgent, err := generateUserAgentString(u.d, u.Config.userAgent)
155+
if err != nil {
156+
return nil, err
157+
}
158+
159+
policy, err := sendRequest(u.Config, "GET", project, url, userAgent, obj)
160+
if err != nil {
161+
return nil, errwrap.Wrapf(fmt.Sprintf("Error retrieving IAM policy for %s: {{err}}", u.DescribeResource()), err)
162+
}
163+
164+
out := &cloudresourcemanager.Policy{}
165+
err = Convert(policy, out)
166+
if err != nil {
167+
return nil, errwrap.Wrapf("Cannot convert a policy to a resource manager policy: {{err}}", err)
168+
}
169+
170+
return out, nil
171+
}
172+
173+
func (u *GKEBackupBackupPlanIamUpdater) SetResourceIamPolicy(policy *cloudresourcemanager.Policy) error {
174+
json, err := ConvertToMap(policy)
175+
if err != nil {
176+
return err
177+
}
178+
179+
obj := make(map[string]interface{})
180+
obj["policy"] = json
181+
182+
url, err := u.qualifyBackupPlanUrl("setIamPolicy")
183+
if err != nil {
184+
return err
185+
}
186+
project, err := getProject(u.d, u.Config)
187+
if err != nil {
188+
return err
189+
}
190+
191+
userAgent, err := generateUserAgentString(u.d, u.Config.userAgent)
192+
if err != nil {
193+
return err
194+
}
195+
196+
_, err = sendRequestWithTimeout(u.Config, "POST", project, url, userAgent, obj, u.d.Timeout(schema.TimeoutCreate))
197+
if err != nil {
198+
return errwrap.Wrapf(fmt.Sprintf("Error setting IAM policy for %s: {{err}}", u.DescribeResource()), err)
199+
}
200+
201+
return nil
202+
}
203+
204+
func (u *GKEBackupBackupPlanIamUpdater) qualifyBackupPlanUrl(methodIdentifier string) (string, error) {
205+
urlTemplate := fmt.Sprintf("{{GKEBackupBasePath}}%s:%s", fmt.Sprintf("projects/%s/locations/%s/backupPlans/%s", u.project, u.location, u.name), methodIdentifier)
206+
url, err := replaceVars(u.d, u.Config, urlTemplate)
207+
if err != nil {
208+
return "", err
209+
}
210+
return url, nil
211+
}
212+
213+
func (u *GKEBackupBackupPlanIamUpdater) GetResourceId() string {
214+
return fmt.Sprintf("projects/%s/locations/%s/backupPlans/%s", u.project, u.location, u.name)
215+
}
216+
217+
func (u *GKEBackupBackupPlanIamUpdater) GetMutexKey() string {
218+
return fmt.Sprintf("iam-gkebackup-backupplan-%s", u.GetResourceId())
219+
}
220+
221+
func (u *GKEBackupBackupPlanIamUpdater) DescribeResource() string {
222+
return fmt.Sprintf("gkebackup backupplan %q", u.GetResourceId())
223+
}

0 commit comments

Comments
 (0)