From 7781169005cec0bd4697a1b0fd4191128a6aca16 Mon Sep 17 00:00:00 2001 From: TangBin Date: Sat, 20 Oct 2018 18:38:52 +0800 Subject: [PATCH] add network operation method --- pkg/util/aws/network.go | 19 ++++++++++++++++--- 1 file changed, 16 insertions(+), 3 deletions(-) diff --git a/pkg/util/aws/network.go b/pkg/util/aws/network.go index cf88091b10..4f6c5ca787 100644 --- a/pkg/util/aws/network.go +++ b/pkg/util/aws/network.go @@ -108,7 +108,17 @@ func (self *SNetwork) GetAllocTimeoutSeconds() int { } func (self *SRegion) createNetwork(zoneId string, vpcId string, name string, cidr string, desc string) (string, error) { - return "", nil + params := &ec2.CreateSubnetInput{} + params.SetAvailabilityZone(zoneId) + params.SetVpcId(vpcId) + params.SetCidrBlock(cidr) + + ret, err := self.ec2Client.CreateSubnet(params) + if err != nil { + return "", err + } else { + return *ret.Subnet.SubnetId, nil + } } func (self *SRegion) getNetwork(networkId string) (*SNetwork, error) { @@ -122,8 +132,11 @@ func (self *SRegion) getNetwork(networkId string) (*SNetwork, error) { return &networks[0], nil } -func (self *SRegion) deleteNetwork(vswitchId string) error { - return nil +func (self *SRegion) deleteNetwork(networkId string) error { + params := &ec2.DeleteSubnetInput{} + params.SetSubnetId(networkId) + _, err := self.ec2Client.DeleteSubnet(params) + return err } func (self *SRegion) GetNetwroks(ids []string, vpcId string) ([]SNetwork, int, error) {