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

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

// Create RouteClient 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

 Among them, HeadersToSign defaults to `Host`, `Content-Type`, `Content-Length`, `Content-MD5`; TimeStamp is generally zero, indicating the timestamp when the authentication string is generated by the call, and the user should generally not clearly specify the value of this field; ExpireSeconds defaults to 1800 seconds or 30 minutes. 

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

// Method 1: Query by route table id 
result, err := client.GetRouteTableDetail(routeTableId, "") 
if err != nil { 
    fmt.Println("get route table error: ", err) 
    return 
} 

// Method 2: Query by vpc id 
result, err := client.GetRouteTableDetail("", vpcId) 
if err != nil { 
    fmt.Println("get route table error: ", err) 
    return 
} 

// Query route table id 
fmt.Println("result of route table id: ", result.RouteTableId) 
// Query to get vpc id 
fmt.Println("result of vpc id: ", result.VpcId) 
// Query to get a list of all routroutees 
for _, route := range result.RouteRules { 
    fmt.Println("route rule id: ", route.RouteRuleId) 
    fmt.Println("route rule routeTableId: ", route.RouteTableId) 
    fmt.Println("route rule sourceAddress: ", route.SourceAddress) 
    fmt.Println("route rule destinationAddress: ", route.DestinationAddress) 
    fmt.Println("route rule nexthopId: ", route.NexthopId) 
    fmt.Println("route rule nexthopType: ", route.NexthopType) 
    fmt.Println("route rule description: ", route.Description) 
} 

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

args := &vpc.CreateRouteRuleArgs{ 
	 // Set route table id, required 
    RouteTableId:       RouteTableID, 
    // Set source network segment, required 
    SourceAddress:      "192.168.1.0/24", 
    // Set the destination network segment, required 
    DestinationAddress: "172.17.0.0/16", 
    // Set the next hop type, required 
    NexthopType:        vpc.NEXTHOP_TYPE_NAT, 
    // Set the next hop id, required 
    NexthopId:          NatID, 
    // Set the description information of the route rule, optional 
    Description:        "test route rule", 
} 
result, err := client.CreateRouteRule(args) 
if err != nil { 
    fmt.Println("create route rule error: ", err) 
    return 
} 
fmt.Println("create route rule success, route rule id: ", result.RouteRuleId) 

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

if err := client.DeleteRouteRule(routeRuleId, clientToken); err != nil { 
    fmt.Println("delete route rule error: ", err) 
    return 
} 

fmt.Printf("delete route rule %s success.", routeRuleId)