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

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

// Create PeerConn Client object 
AK, SK := <your-access-key-id>, <your-secret-access-key> 
ENDPOINT := "bcc.bj.baidubce.com" 
client, _ := peerConn.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" 

args := &vpc.CreatePeerConnArgs{ 
	 // Set the bandwidth of the peer connection 
    BandwidthInMbps: 10, 
    // Set the description information of the peer connection 
    Description:      "test peer conn", 
    // Set the local port name of the peer connection 
    LocalIfName:      "local-interface", 
    // Set the id of the local vpc of the peer connection 
    LocalVpcId:      vpcId, 
    // Set the peer account ID of the peer connection. This field is only required when establishing a cross-account peer connection 
    peerAccountId:   peerAccountId, 
    // Set the id of the peer vpc of the peer connection 
    PeerVpcId:       peerVpcId, 
    // Set the peer zone of the peer connection 
    PeerRegion:      region, 
    // For the opposite terminal interface name of the peer connection, only the peer connection of the account allows to set the field. 
    PeerIfName:      "peer-interface", 
    // Set the billing information for peer connections 
    Billing: &vpc.Billing{ 
        PaymentTiming: vpc.PAYMENT_TIMING_POSTPAID, 
    }, 
} 
result, err := client.CreatePeerConn(args) 
if err != nil { 
    fmt.Println("create peerconn error: ", err) 
    return 
} 

fmt.Println("create peerconn success, peerconn id: ", result.PeerConnId) 

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

args := &vpc.ListPeerConnsArgs{ 
	 // Specify the vpc id to which the peer connection belongs 
	 VpcId: vpcId, 
	 // Specify the starting position of the query to obtain the list in batches 
	 Marker: marker, 
	 // Specify the maximum number per page, the maximum number does not exceed 1000. The default value is 1000. 
	 MaxKeys: maxKeys, 
} 
result, err := client.ListPeerConn(args) 
if err != nil { 
    fmt.Println("list peer conns error: ", err) 
    return 
} 

// Return the starting position of the mark query 
fmt.Println("peerconn 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("peerconn 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("peerconn list nextMarker: ", result.NextMarker) 
// Maximum number contained in each page. 
fmt.Println("peerconn list maxKeys: ", result.MaxKeys) 
// Get list information of peer connections 
for _, pc := range result.PeerConns { 
    fmt.Println("peerconn id: ", pc.PeerConnId) 
    fmt.Println("peerconn role: ", pc.Role) 
    fmt.Println("peerconn status: ", pc.Status) 
    fmt.Println("peerconn bandwithInMbp: ", pc.BandwidthInMbps) 
    fmt.Println("peerconn description: ", pc.Description) 
    fmt.Println("peerconn localIfId: ", pc.LocalIfId) 
    fmt.Println("peerconn localIfName: ", pc.LocalIfName) 
    fmt.Println("peerconn localVpcId: ", pc.LocalVpcId) 
    fmt.Println("peerconn localRegion: ", pc.LocalRegion) 
    fmt.Println("peerconn peerVpcId: ", pc.PeerVpcId) 
    fmt.Println("peerconn peerRegion: ", pc.PeerRegion) 
    fmt.Println("peerconn peerAccountId: ", pc.PeerAccountId) 
    fmt.Println("peerconn paymentTiming: ", pc.PaymentTiming) 
    fmt.Println("peerconn dnsStatus: ", pc.DnsStatus) 
    fmt.Println("peerconn createdTime: ", pc.CreatedTime) 
    fmt.Println("peerconn expiredTime: ", pc.ExpiredTime) 
} 

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

result, err := client.GetPeerConnDetail(peerConnId, vpc.PEERCONN_ROLE_INITIATOR) 
if err != nil { 
    fmt.Println("get peer conn detail error: ", err) 
    return 
} 

// Query to get the id of the peer connection 
fmt.Println("peerconn id: ", result.PeerConnId) 
// Query the role of the peer connection, "initiator" means the initiator and "acceptor" means the acceptor 
fmt.Println("peerconn role: ", result.Role) 
// Query to get the status of the peer connection 
fmt.Println("peerconn status: ", result.Status) 
// Query to get the bandwidth of the peer connection 
fmt.Println("peerconn bandwithInMbp: ", result.BandwidthInMbps) 
// Query to get the description of the peer connection 
fmt.Println("peerconn description: ", result.Description) 
// Query to get the local interface ID of the peer connection 
fmt.Println("peerconn localIfId: ", result.LocalIfId) 
// Query to get the local interface name of the peer connection 
fmt.Println("peerconn localIfName: ", result.LocalIfName) 
// Query to get the local VPC ID of the peer connection 
fmt.Println("peerconn localVpcId: ", result.LocalVpcId) 
// Query to get the local area of the peer connection 
fmt.Println("peerconn localRegion: ", result.LocalRegion) 
// Query to get the peer VPC ID of the peer connection 
fmt.Println("peerconn peerVpcId: ", result.PeerVpcId) 
// Query to get the peer area of the peer connection 
fmt.Println("peerconn peerRegion: ", result.PeerRegion) 
// Query to get the peer account ID of the peer connection 
fmt.Println("peerconn peerAccountId: ", result.PeerAccountId) 
// Query to get the charging method for peer connections 
fmt.Println("peerconn paymentTiming: ", result.PaymentTiming) 
// Query to get the dns status of the peer connection 
fmt.Println("peerconn dnsStatus: ", result.DnsStatus) 
// Query to get the creation time of the peer connection 
fmt.Println("peerconn createdTime: ", result.CreatedTime) 
// Query to get the expiration time of the peer connection 
fmt.Println("peerconn expiredTime: ", result.ExpiredTime) 

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

args := &vpc.UpdatePeerConnArgs{ 
	 // Set the interface ID of the peer connection immutable, required 
    LocalIfId:   localIfId, 
    // Set the local port name of the peer connection 
    LocalIfName: "test-update", 
    // Set the local port description of the peer connection 
    Description: "test-description", 
} 
if err := client.UpdatePeerConn(peerConnId, args); err != nil { 
    fmt.Println("update peer conn error: ", err) 
    return 
} 

fmt.Printf("update peer conn %s success", peerConnId) 

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

if err := client.AcceptPeerConnApply(peerConnId, clientToken); err != nil { 
    fmt.Println("accept peer conn error: ", err) 
    return 
} 

fmt.Printf("accept peer conn %s success.", peerConnId) 

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

if err := client.RejectPeerConnApply(peerConnId, clientToken); err != nil { 
    fmt.Println("reject peer conn error: ", err) 
    return 
} 

fmt.Printf("reject peer conn %s success.", peerConnId) 

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

if err := client.DeletePeerConn(peerConnId, clientToken); err != nil { 
    fmt.Println("delete peer conn error: ", err) 
    return 
} 

fmt.Printf("delete peer conn %s success", peerConnId) 

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

args := &vpc.ResizePeerConnArgs{ 
	 // Specify the bandwidth of the peer connection 
    NewBandwidthInMbps: 20, 
} 

if err := client.ResizePeerConn(peerConnId, args); err != nil { 
    fmt.Println("resize peer conn error: ", err) 
    return 
} 

fmt.Printf("resize peer conn %s success.", peerConnId) 

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

args := &vpc.RenewPeerConnArgs{ 
	 // Specify the renewal information of the peer connection 
    Billing: &vpc.Billing{ 
        Reservation: &vpc.Reservation{ 
            ReservationLength:   1, 
            ReservationTimeUnit: "month", 
        }, 
    }, 
} 

if err := client.RenewPeerConn(peerConnId, args); err != nil { 
    fmt.Println("renew peer conn error: ", err) 
    return 
} 

fmt.Printf("renew peer conn %s success.", peerConnId) 

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

args := &vpc.PeerConnSyncDNSArgs{ 
	 // Specify the role of the peer connection, the initiator is "initiator" and the acceptor "acceptor" 
    Role: vpc.PEERCONN_ROLE_INITIATOR, 
} 

if err := client.OpenPeerConnSyncDNS(peerConnId, args); err != nil { 
    fmt.Println("open peer conn sync dns error: ", err) 
    return 
} 

fmt.Printf("open peer conn %s sync dns success.", peerConnId) 

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

args := &vpc.PeerConnSyncDNSArgs{ 
	 // Specify the role of the peer connection, the initiator is "initiator" and the acceptor "acceptor" 
    Role: vpc.PEERCONN_ROLE_INITIATOR, 
} 

if err := client.ClosePeerConnSyncDNS(peerConnId, args); err != nil { 
    fmt.Println("close peer conn sync dns error: ", err) 
    return 
} 

fmt.Printf("close peer conn %s sync dns success.", peerConnId)