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 NATClient 
	 natClient, 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 NAT service with the temporary STS applied, with Endpoint of default value. 
	 natClient, err := vpc.NewClient(stsObj.AccessKeyId, stsObj.SecretAccessKey, "bcc.bj.baidubce.com") 
	 if err != nil { 
	 	 fmt.Println("create nat 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 
	 } 
	 natClient.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> 
natClient, _ := vpc.NewClient(AK, SK, ENDPOINT) 

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

// Create NAT 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, _ := bcc.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, _ := bcc.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.CreateNatGatewayArgs{ 
	 // Set the name of the nat gateway 
    Name:  name, 
    // Set the vpc id to which the nat gateway belongs 
    VpcId: vpcId, 
    // Set the specifications of the nat gateway 
    Spec:  vpc.NAT_GATEWAY_SPEC_SMALL, 
    // Set eip list of nat gateway 
    Eips:  []string{eip}, 
    // Set the billing information of the nat gateway 
    Billing: &vpc.Billing{ 
        PaymentTiming: vpc.PAYMENT_TIMING_POSTPAID, 
    }, 
} 
result, err := client.CreateNatGateway(args) 
if err != nil { 
    fmt.Println("create nat gateway error: ", err) 
    return 
} 

fmt.Println("create nat gateway success, nat gateway id: ", result.NatId) 

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

args := &vpc.ListNatGatewayArgs{ 
	 // Set the vpc id to which the nat gateway belongs, required 
    VpcId: vpcId, 
    // Specify the Id of NAT to be queried. 
    NatId: natId, 
    // Specify the name of NAT to be queried. 
    Name: name, 
    // Specify the EIP bound to NAT to be queried. 
    Ip: ip, 
    // Set the starting position of the query of the nat gateway batch acquisition list 
    Marker: marker, 
    // Set nat gateway aximum number contained in each page, generally not exceeding 1000. The default value is 1000. 
    MaxKeys: maxKeys, 
} 
result, err := client.ListNatGateway(args) 
if err != nil { 
    fmt.Println("list nat gateway error: ", err) 
    return 
} 

// Return to the starting position of the mark query 
fmt.Println("nat 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("nat 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("nat list nextMarker: ", result.NextMarker) 
// Maximum number contained in each page. 
fmt.Println("nat list maxKeys: ", result.MaxKeys) 
// Get list information of nat 
for _, nat := range result.Nats { 
    fmt.Println("nat id: ", nat.Id) 
    fmt.Println("nat name: ", nat.Name) 
    fmt.Println("nat vpcId: ", nat.VpcId) 
    fmt.Println("nat spec: ", nat.Spec) 
    fmt.Println("nat eips: ", nat.Eips) 
    fmt.Println("nat status: ", nat.Status) 
    fmt.Println("nat paymentTiming: ", nat.PaymentTiming) 
    fmt.Println("nat expireTime: ", nat.ExpiredTime) 
} 

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

result, err := client.GetNatGatewayDetail(natId) 
if err != nil { 
    fmt.Println("get nat gateway details error: ", err) 
    return 
} 

// Query to get the id of the nat gateway 
fmt.Println("nat id: ", result.Id) 
// Query to get the name of the nat gateway 
fmt.Println("nat name: ", result.Name) 
// Query to get the vpc id to which the nat gateway belongs 
fmt.Println("nat vpcId: ", result.VpcId) 
// Query to get the size of the nat gateway 
fmt.Println("nat spec: ", result.Spec) 
// Query to get the IP address list of EIP bound to the nat gateway 
fmt.Println("nat eips: ", result.Eips) 
// Query to get the status of the nat gateway 
fmt.Println("nat status: ", result.Status) 
// Query to get the payment method of the nat gateway 
fmt.Println("nat paymentTiming: ", result.PaymentTiming) 
// Query to get the expiration time of the nat gateway 
fmt.Println("nat expireTime: ", result.ExpiredTime) 

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

args := &vpc.UpdateNatGatewayArgs{ 
	 // Set the latest name of the nat gateway 
    Name: "TestNatUpdate", 
} 

if err := client.UpdateNatGateway(natId, args); err != nil { 
    fmt.Println("update nat gateway error: ", err) 
    return 
} 

fmt.Printf("update nat gateway %s success.", natId) 

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

args := &vpc.BindEipsArgs{ 
	 // Set the list of bound EIP IDs 
    Eips: []string{eip}, 
} 
if err := client.BindEips(natId, args); err != nil { 
    fmt.Println("bind eips error: ", err) 
    return 
} 

fmt.Println("bind eips success.") 

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

args := &vpc.UnBindEipsArgs{ 
	 // Set list of unbound EIP IDs 
    Eips: []string{eip}, 
} 
if err := client.UnBindEips(natId, args); err != nil { 
    fmt.Println("unbind eips error: ", err) 
    return 
} 

fmt.Println("unbind eips success.") 

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

if err := client.DeleteNatGateway(natId, clientToken); err != nil { 
    fmt.Println("delete nat gateway error: ", err) 
    return 
} 

fmt.Printf("delete nat gateway %s success.", natId) 

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

args := &vpc.RenewNatGatewayArgs{ 
	 // Set the order information for nat gateway renewal 
    Billing: &vpc.Billing{ 
        Reservation: &vpc.Reservation{ 
            ReservationLength:   1, 
            ReservationTimeUnit: "month", 
        }, 
    }, 
} 
if err := client.RenewNatGateway(natId, args); err != nil { 
    fmt.Println("renew nat gateway error: ", err) 
    return 
} 

fmt.Printf("renew nat gateway %s success.", natId)