import ( 
	 "github.com/baidubce/bce-sdk-go/services/vpc" 
) 

func main() { 
	 // Access Key ID and Secret Access Key of users 
	 ACCESS_KEY_ID, SECRET_ACCESS_KEY := <your-access-key-id>, <your-secret-access-key> 

	 // User specified Endpoint 
	 ENDPOINT := <domain-name> 

	 // Initialize a subnetClient 
	 subnetClient, err := vpc.NewClient(AK, SK, ENDPOINT) 
} 

import ( 
	 "fmt" 

	 "github.com/baidubce/bce-sdk-go/auth"         // Import authentication module 
	 "github.com/baidubce/bce-sdk-go/services/vpc" // Import VPC service module 
	 "github.com/baidubce/bce-sdk-go/services/sts" // Import STS service module 
) 

func main() { 
	 // Create the Client object of STS service, with Endpoint of default value 
	 AK, SK := <your-access-key-id>, <your-secret-access-key> 
	 stsClient, err := sts.NewClient(AK, SK) 
	 if err != nil { 
	 	 fmt.Println("create sts client object :", err) 
	 	 return 
	 } 

	 // Obtain a temporary authentication token, with a valid period of 60 sec, and ACL null 
	 stsObj, err := stsClient.GetSessionToken(60, "") 
	 if err != nil { 
	 	 fmt.Println("get session token failed:", err) 
	 	 return 
    } 
	 fmt.Println("GetSessionToken result:") 
	 fmt.Println("  accessKeyId:", stsObj.AccessKeyId) 
	 fmt.Println("  secretAccessKey:", stsObj.SecretAccessKey) 
	 fmt.Println("  sessionToken:", stsObj.SessionToken) 
	 fmt.Println("  createTime:", stsObj.CreateTime) 
	 fmt.Println("  expiration:", stsObj.Expiration) 
	 fmt.Println("  userId:", stsObj.UserId) 

	 // Create the Client object of VPC service with the temporary STS applied, with Endpoint of default value. 
	 subnetClient, err := vpc.NewClient(stsObj.AccessKeyId, stsObj.SecretAccessKey, "bcc.bj.baidubce.com") 
	 if err != nil { 
	 	 fmt.Println("create vpc client failed:", err) 
	 	 return 
	 } 
	 stsCredential, err := auth.NewSessionBceCredentials( 
	 	 stsObj.AccessKeyId, 
	 	 stsObj.SecretAccessKey, 
	 	 stsObj.SessionToken) 
	 if err != nil { 
	 	 fmt.Println("create sts credential object failed:", err) 
	 	 return 
	 } 
	 subnetClient.Config.Credentials = stsCredential 
} 

// import "github.com/baidubce/bce-sdk-go/services/vpc" 

ENDPOINT := "https://bcc.bj.baidubce.com" // Indicate the use of HTTPS 
AK, SK := <your-access-key-id>, <your-secret-access-key> 
subnetClient, _ := vpc.NewClient(AK, SK, ENDPOINT) 

// import "github.com/baidubce/bce-sdk-go/services/vpc" 

// Create Subnet Client object 
AK, SK := <your-access-key-id>, <your-secret-access-key> 
ENDPOINT := "bcc.bj.baidubce.com" 
client, _ := vpc.NewClient(AK, SK, ENDPOINT) 

// The agent uses the local 8080 port 
client.Config.ProxyUrl = "127.0.0.1:8080"

// import "github.com/baidubce/bce-sdk-go/services/vpc" 

AK, SK := <your-access-key-id>, <your-secret-access-key> 
ENDPOINT := "bcc.bj.baidubce.com" 
client, _ := vpc.NewClient(AK, SK, ENDPOINT) 

// Configuration is not retried, and the default is Back Off retry 
client.Config.Retry = bce.NewNoRetryPolicy() 

// Configure the connection time-out period as 30sec 
client.Config.ConnectionTimeoutInMillis = 30 * 1000

// import "github.com/baidubce/bce-sdk-go/services/vpc" 

AK, SK := <your-access-key-id>, <your-secret-access-key> 
ENDPOINT := "bcc.bj.baidubce.com" 
client, _ := vpc.NewClient(AK, SK, ENDPOINT) 

// Configure the HTTPS request header for signature as `Host` 
headersToSign := map[string]struct{}{"Host": struct{}{}} 
client.Config.SignOption.HeadersToSign = HeadersToSign 

// Configure the valid period of signature as 30sec 
client.Config.SignOption.ExpireSeconds = 30

 Where the default values of HeadersToSign are `Host`, `Content-Type`, `Content-Length` and `Content- MD5`; TimeStamp is generally zero, indicating the time stamp when call is used to generate string, and generally the value of that field should not be specified expressly; the default value of ExpireSeconds is 1,800sec, i.e. 30min. 

//import "github.com/baidubce/bce-sdk-go/services/vpc" 

args := &vpc.CreateSubnetArgs{ 
	 // Set the name of the subnet 
    Name:        "TestSDK-Subnet", 
    // Set the zone name of the subnet 
    ZoneName:    "cn-bj-a", 
    // Set the cidr of the subnet 
    Cidr:        "192.168.1.0/24", 
    // Set Id of vpc to which the subnet belongs 
    VpcId:       "vpc-4njbqurm0uag", 
    // Set the type of subnet, including "BCC", "BCC_NAT" and "BBC" 
    SubnetType:  vpc.SUBNET_TYPE_BCC, 
    // Set the description of the subnet 
    Description: "test subnet", 
    // Set the tag key-value pair list of the subnet 
    Tags: []model.TagModel{ 
        { 
            TagKey:   "tagK", 
            TagValue: "tagV", 
        }, 
    }, 
} 
result, err := client.CreateSubnet(args) 
if err != nil { 
    fmt.Println("create subnet error: ", err) 
    return 
} 

fmt.Println("create subnet success, subnet id: ", result.SubnetId) 

//import "github.com/baidubce/bce-sdk-go/services/vpc" 

args := &vpc.ListSubnetArgs{ 
	 // The starting location of query for batch acquisition of lists, and is one string generated by the system. 
	 Marker:     marker, 
	 // Set the maximum number contained in each page, generally not exceeding 1000. The default value is 1000. 
	 MaxKeys:    maxKeys, 
	 // Set Id of vpc belongs 
    VpcId:      vpcId, 
    // Set name of the available zone affiliated 
    ZoneName:   zoneName, 
    // Set subnet type 
    SubnetType: vpc.SUBNET_TYPE_BCC, 
} 
result, err := client.ListSubnets(args) 
if err != nil { 
    fmt.Println("list subnets error: ", err) 
    return 
} 

// Return to the starting position of the mark query 
fmt.Println("subnet list marker: ", result.Marker) 
// True means there are additional data in the following pages and false means the current page is the last page. 
fmt.Println("subnet list isTruncated: ", result.IsTruncated) 
// The marker value requiring to be passed in order to acquire the next page. The domain doesn't appear when isTruncated is false. 
fmt.Println("subnet list nextMarker: ", result.NextMarker) 
// Maximum number contained in each page. 
fmt.Println("subnet list maxKeys: ", result.MaxKeys) 
// Get specific information about subnet 
for _, sub := range result.Subnets { 
    fmt.Println("subnet id: ", sub.SubnetId) 
    fmt.Println("subnet name: ", sub.Name) 
    fmt.Println("subnet zoneName: ", sub.ZoneName) 
    fmt.Println("subnet cidr: ", sub.Cidr) 
    fmt.Println("subnet vpcId: ", sub.VPCId) 
    fmt.Println("subnet subnetType: ", sub.SubnetType) 
    fmt.Println("subnet description: ", sub.Description) 
    fmt.Println("subnet availableIp: ", sub.AvailableIp) 
    fmt.Println("subnet tags: ", sub.Tags) 
} 

//import "github.com/baidubce/bce-sdk-go/services/vpc" 

result, err := client.GetSubnetDetail(subnetId) 
if err != nil { 
    fmt.Println("get subnet detail error: ", err) 
    return 
} 

// Query to get the id of the subnet 
fmt.Println("subnet id: ", result.Subnet.SubnetId) 
// Query to get the name of the subnet 
fmt.Println("subnet name: ", result.Subnet.Name) 
// Query to get the name of the zone to which the subnet belongs 
fmt.Println("subnet zoneName: ", result.Subnet.ZoneName) 
// Query to get the cidr of the subnet 
fmt.Println("subnet cidr: ", result.Subnet.Cidr) 
// Query to get the id of the vpc to which the subnet belongs 
fmt.Println("subnet vpcId: ", result.Subnet.VPCId) 
// Query to get the type of subnet 
fmt.Println("subnet subnetType: ", result.Subnet.SubnetType) 
// Query to get the description of the subnet 
fmt.Println("subnet description: ", result.Subnet.Description) 
// Query to get the number of available IPs in the subnet 
fmt.Println("subnet availableIp: ", result.Subnet.AvailableIp) 
// Query to get the list of tags bound to the subnet 
fmt.Println("subnet tags: ", result.Subnet.Tags) 

//import "github.com/baidubce/bce-sdk-go/services/vpc" 

if err := client.DeleteSubnet(subnetId, clientToken); err != nil { 
    fmt.Println("delete subnet error: ", err) 
    return 
} 

fmt.Printf("delete subnet %s success.", subnetId) 

//import "github.com/baidubce/bce-sdk-go/services/vpc" 

args := &vpc.UpdateSubnetArgs{ 
	 // Set the idempotent token used for update operations 
    ClientToken: clientToken, 
    // Set the updated subnet name 
    Name:        "TestSDK-Subnet-update", 
    // Set the updated subnet description 
    Description: "subnet update", 
} 
if err := client.UpdateSubnet(subnetId, args); err != nil { 
    fmt.Println("update subnet error: ", err) 
    return 
} 

fmt.Printf("update subnet %s success.", subnetId)