jxyowen 7 anos atrás
pai
commit
18cf6fbbc9

+ 1 - 1
sdk/client.go

@@ -333,7 +333,7 @@ func (client *Client) AddAsyncTask(task func()) (err error) {
 	return
 }
 
-func (client *Client)GetConfig() *Config {
+func (client *Client) GetConfig() *Config {
 	return client.config
 }
 

+ 1 - 1
sdk/config.go

@@ -30,7 +30,7 @@ type Config struct {
 	EnableAsync       bool            `default:"false"`
 	MaxTaskQueueSize  int             `default:"1000"`
 	GoRoutinePoolSize int             `default:"5"`
-	Scheme string             `default:"HTTP"`
+	Scheme            string          `default:"HTTP"`
 }
 
 func NewConfig() (config *Config) {

+ 2 - 1
sdk/endpoints/mapping_resolver.go

@@ -20,7 +20,8 @@ import (
 )
 
 const keyFormatter = "%s::%s"
-var endpointMapping = make(map[string]string )
+
+var endpointMapping = make(map[string]string)
 
 func AddEndpointMapping(regionId, productId, endpoint string) (err error) {
 	key := fmt.Sprintf(keyFormatter, strings.ToLower(regionId), strings.ToLower(productId))

+ 4 - 4
sdk/endpoints/mapping_resolver_test.go

@@ -1,16 +1,16 @@
 package endpoints
 
 import (
-	"testing"
-	"github.com/stretchr/testify/assert"
 	"fmt"
+	"github.com/stretchr/testify/assert"
+	"testing"
 )
 
 func TestMappingResolver_TryResolve(t *testing.T) {
 	AddEndpointMapping("cn-hangzhou", "Ecs", "unreachable.aliyuncs.com")
 	resolveParam := &ResolveParam{
-		RegionId:"cn-hangzhou",
-		Product:"ecs",
+		RegionId: "cn-hangzhou",
+		Product:  "ecs",
 	}
 	endpoint, err := Resolve(resolveParam)
 	assert.Nil(t, err)

+ 2 - 2
sdk/log/log.go

@@ -22,8 +22,8 @@ var (
 	PanicLevel = logrus.PanicLevel
 	FatalLevel = logrus.FatalLevel
 	ErrorLevel = logrus.ErrorLevel
-	WarnLevel = logrus.WarnLevel
-	InfoLevel = logrus.InfoLevel
+	WarnLevel  = logrus.WarnLevel
+	InfoLevel  = logrus.InfoLevel
 	DebugLevel = logrus.DebugLevel
 
 	SetLevel = logrus.SetLevel

+ 4 - 4
sdk/requests/common_request.go

@@ -1,11 +1,11 @@
 package requests
 
 import (
+	"bytes"
+	"fmt"
 	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/errors"
 	"io"
 	"strings"
-	"bytes"
-	"fmt"
 )
 
 type CommonRequest struct {
@@ -38,7 +38,7 @@ func (request *CommonRequest) String() string {
 
 	resultBuilder := bytes.Buffer{}
 
-	mapOutput := func (m map[string]string) {
+	mapOutput := func(m map[string]string) {
 		if len(m) > 0 {
 			for key, value := range m {
 				resultBuilder.WriteString(key + ": " + value + "\n")
@@ -51,7 +51,7 @@ func (request *CommonRequest) String() string {
 	resultBuilder.WriteString(fmt.Sprintf("%s %s %s/1.1\n", request.Method, request.GetQueries(), strings.ToUpper(request.Scheme)))
 
 	// Headers
-	resultBuilder.WriteString( "Host" + ": " + request.Domain + "\n")
+	resultBuilder.WriteString("Host" + ": " + request.Domain + "\n")
 	mapOutput(request.Headers)
 
 	resultBuilder.WriteString("\n")

+ 1 - 1
sdk/responses/response.go

@@ -17,11 +17,11 @@ package responses
 import (
 	"bytes"
 	"encoding/xml"
+	"fmt"
 	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/errors"
 	"io/ioutil"
 	"net/http"
 	"strings"
-	"fmt"
 )
 
 type AcsResponse interface {