forked from kubernetes/kops
-
Notifications
You must be signed in to change notification settings - Fork 0
/
subnet.go
92 lines (75 loc) · 2.12 KB
/
subnet.go
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
package gcetasks
import (
"fmt"
"github.com/golang/glog"
"google.golang.org/api/compute/v1"
"k8s.io/kops/upup/pkg/fi"
"k8s.io/kops/upup/pkg/fi/cloudup/gce"
"k8s.io/kops/upup/pkg/fi/cloudup/terraform"
)
//go:generate fitask -type=Subnet
type Subnet struct {
Name *string
Network *Network
Region *string
CIDR *string
}
var _ fi.CompareWithID = &Subnet{}
func (e *Subnet) CompareWithID() *string {
return e.Name
}
func (e *Subnet) Find(c *fi.Context) (*Subnet, error) {
cloud := c.Cloud.(*gce.GCECloud)
s, err := cloud.Compute.Subnetworks.Get(cloud.Project, cloud.Region, *e.Name).Do()
if err != nil {
if gce.IsNotFound(err) {
return nil, nil
}
return nil, fmt.Errorf("error listing Subnets: %v", err)
}
actual := &Subnet{}
actual.Name = &s.Name
actual.Network = &Network{Name: &s.Network}
actual.Region = &s.Region
actual.CIDR = &s.IpCidrRange
return actual, nil
}
func (e *Subnet) Run(c *fi.Context) error {
return fi.DefaultDeltaRunMethod(e, c)
}
func (_ *Subnet) CheckChanges(a, e, changes *Subnet) error {
return nil
}
func (_ *Subnet) RenderGCE(t *gce.GCEAPITarget, a, e, changes *Subnet) error {
if a == nil {
glog.V(2).Infof("Creating Subnet with CIDR: %q", *e.CIDR)
subnet := &compute.Subnetwork{
IpCidrRange: *e.CIDR,
Name: *e.Name,
Network: *e.Network.Name,
}
_, err := t.Cloud.Compute.Subnetworks.Insert(t.Cloud.Project, t.Cloud.Region, subnet).Do()
if err != nil {
return fmt.Errorf("error creating Subnet: %v", err)
}
}
return nil
}
type terraformSubnet struct {
Name *string `json:"name"`
Network *terraform.Literal `json:"network"`
Region *string `json:"region"`
CIDR *string `json:"ip_cidr_range"`
}
func (_ *Subnet) RenderSubnet(t *terraform.TerraformTarget, a, e, changes *Subnet) error {
tf := &terraformSubnet{
Name: e.Name,
Network: e.Network.TerraformName(),
Region: e.Region,
CIDR: e.CIDR,
}
return t.RenderResource("google_compute_subnetwork", *e.Name, tf)
}
func (i *Subnet) TerraformName() *terraform.Literal {
return terraform.LiteralProperty("google_compute_subnetwork", *i.Name, "name")
}