增加http参数配置

factory/db_factory.go

@@ -107,6 +107,7 @@ func (f *DBFactory) Close() error {
 	if f.db != nil {
 		err := f.db.Close()
 		f.db = nil
+		fmt.Println("Database connection closed gracefully")
 		return err
 	}
 	return nil

factory/doris_factory.go

@@ -3,89 +3,94 @@ package factory
 import (
 	"encoding/json"
 	"fmt"
-	"io"
-	"net/http"
-	"strings"
+	"sync"
 	"time"
 
 	"git.x2erp.com/qdy/go-base/config"
+	"github.com/go-resty/resty/v2"
 )
 
 // DorisFactory Doris HTTP客户端工厂
 type DorisFactory struct {
-	config     config.IConfig
-	httpClient *http.Client
+	client   *resty.Client // 线程安全
+	FEHost   string        // 只读
+	FEPort   int           // 只读
+	Username string        // 只读
+	Password string        // 只读
+	Timeout  time.Duration // 只读
+
+	isClosed bool         // 需要原子操作或锁保护
+	closedMu sync.RWMutex // 只保护 isClosed 字段
 }
 
-// NewDorisFactory 创建Doris HTTP客户端工厂
-func NewDorisFactory(httpFactory *HTTPFactory) (*DorisFactory, error) {
-	cfg := config.GetConfig()
-
-	if err := config.GetInitError(); err != nil {
-		return nil, fmt.Errorf("failed to load config: %v", err)
-	}
+var (
+	instance     *DorisFactory
+	instanceOnce sync.Once
+)
 
-	if !cfg.IsDorisConfigured() {
-		return nil, fmt.Errorf("doris configuration is incomplete")
+// GetDorisFactory 获取Doris工厂单例
+func GetDorisFactory(httpFactory *HTTPFactory) (*DorisFactory, error) {
+	var initErr error
+	instanceOnce.Do(func() {
+		cfg := config.GetConfig()
+
+		if err := config.GetInitError(); err != nil {
+			initErr = fmt.Errorf("failed to load config: %v", err)
+			return
+		}
+
+		if !cfg.IsDorisConfigured() {
+			initErr = fmt.Errorf("doris configuration is incomplete")
+			return
+		}
+
+		dorisConfig := cfg.GetDoris()
+		instance = &DorisFactory{
+			client:   httpFactory.CreateClient().client,
+			FEHost:   dorisConfig.FEHost,
+			FEPort:   dorisConfig.FEPort,
+			Username: dorisConfig.FEUsername,
+			Password: dorisConfig.FEPassword,
+			Timeout:  time.Duration(dorisConfig.StreamLoadTimeout) * time.Second,
+			isClosed: false,
+		}
+	})
+
+	if initErr != nil {
+		return nil, initErr
 	}
 
-	return &DorisFactory{
-		config:     cfg,
-		httpClient: httpFactory.CreateHTTPClient(),
-	}, nil
+	return instance, nil
 }
 
-// CreateDorisClient 创建Doris HTTP客户端
-func (f *DorisFactory) CreateDorisClient() *DorisClient {
-	dorisConfig := f.config.GetDoris()
-
-	return &DorisClient{
-		httpClient: f.httpClient,
-		FEHost:     dorisConfig.FEHost,
-		FEPort:     dorisConfig.FEPort,
-		Username:   dorisConfig.FEUsername,
-		Password:   dorisConfig.FEPassword,
-		Timeout:    time.Duration(dorisConfig.StreamLoadTimeout) * time.Second,
+// InsertCSV 插入CSV数据到Doris
+func (f *DorisFactory) InsertCSV(database, table, csvData string, skipHeader bool) error {
+	// 检查关闭状态
+	if f.IsClosed() {
+		return fmt.Errorf("doris client is closed")
 	}
-}
 
-// DorisClient Doris HTTP客户端
-type DorisClient struct {
-	httpClient *http.Client
-	FEHost     string
-	FEPort     int
-	Username   string
-	Password   string
-	Timeout    time.Duration
-}
-
-// InsertCSV 插入CSV数据到Doris 只认数据次序
-func (c *DorisClient) DorisInsertCSV(database, table, csvData string, skipHeader bool) error {
-	url := fmt.Sprintf("http://%s:%d/api/%s/%s/_stream_load", c.FEHost, c.FEPort, database, table)
-
-	req, err := http.NewRequest("PUT", url, strings.NewReader(csvData))
-	if err != nil {
-		return fmt.Errorf("创建请求失败: %v", err)
-	}
+	url := fmt.Sprintf("http://%s:%d/api/%s/%s/_stream_load", f.FEHost, f.FEPort, database, table)
 
-	req.SetBasicAuth(c.Username, c.Password)
-	req.Header.Set("Content-Type", "text/plain")
-	req.Header.Set("format", "csv")
-	req.Header.Set("column_separator", ",")
+	// 使用 resty 的 API
+	resp, err := f.client.R().
+		SetBasicAuth(f.Username, f.Password).
+		SetHeader("Content-Type", "text/plain").
+		SetHeader("format", "csv").
+		SetHeader("column_separator", ",").
+		SetBody(csvData).
+		Put(url)
 
 	if skipHeader {
-		req.Header.Set("skip_header", "1")
+		resp.Request.SetHeader("skip_header", "1")
 	}
 
-	resp, err := c.httpClient.Do(req)
 	if err != nil {
 		return fmt.Errorf("请求失败: %v", err)
 	}
-	defer resp.Body.Close()
 
-	body, _ := io.ReadAll(resp.Body)
-	if resp.StatusCode != 200 {
-		return fmt.Errorf("插入失败: %s", string(body))
+	if resp.StatusCode() != 200 {
+		return fmt.Errorf("插入失败: %s", string(resp.Body()))
 	}
 
 	// 解析Stream Load响应
@@ -93,7 +98,7 @@ func (c *DorisClient) DorisInsertCSV(database, table, csvData string, skipHeader
 		Status  string `json:"Status"`
 		Message string `json:"Message"`
 	}
-	if err := json.Unmarshal(body, &result); err != nil {
+	if err := json.Unmarshal(resp.Body(), &result); err != nil {
 		return fmt.Errorf("解析响应失败: %v", err)
 	}
 
@@ -103,3 +108,23 @@ func (c *DorisClient) DorisInsertCSV(database, table, csvData string, skipHeader
 
 	return nil
 }
+
+// Close 关闭Doris客户端
+func (f *DorisFactory) Close() error {
+	f.closedMu.Lock()
+	defer f.closedMu.Unlock()
+
+	if f.isClosed {
+		return nil
+	}
+
+	f.isClosed = true
+	return nil
+}
+
+// IsClosed 检查客户端是否已关闭
+func (f *DorisFactory) IsClosed() bool {
+	f.closedMu.RLock()
+	defer f.closedMu.RUnlock()
+	return f.isClosed
+}

factory/http_factory.go

@@ -1,48 +1,301 @@
 package factory
 
 import (
+	"encoding/base64"
 	"fmt"
 	"net/http"
+	"sync"
 	"time"
 
 	"git.x2erp.com/qdy/go-base/config"
+	"github.com/go-resty/resty/v2"
 )
 
+// HTTPClient 简化的HTTP客户端
+type HTTPClient struct {
+	client *resty.Client
+}
+
 // HTTPFactory HTTP客户端工厂
 type HTTPFactory struct {
 	config config.IConfig
-	client *http.Client
+	client *resty.Client
+}
+
+var (
+	httpFactoryInstance *HTTPFactory
+	httpFactoryOnce     sync.Once
+	httpFactoryInitErr  error
+)
+
+// GetHTTPFactory 获取HTTP工厂单例实例
+func GetHTTPFactory() (*HTTPFactory, error) {
+	httpFactoryOnce.Do(func() {
+		cfg := config.GetConfig()
+
+		if err := config.GetInitError(); err != nil {
+			httpFactoryInitErr = fmt.Errorf("failed to load config: %v", err)
+			return
+		}
+
+		httpConfig := cfg.GetHTTP()
+
+		// 创建共享的resty客户端（线程安全）
+		client := resty.New()
+		client.SetTimeout(time.Duration(httpConfig.Timeout) * time.Second)
+		client.SetTransport(&http.Transport{
+			MaxIdleConns:        httpConfig.MaxIdleConns,
+			MaxIdleConnsPerHost: httpConfig.MaxIdleConnsPerHost,
+			IdleConnTimeout:     time.Duration(httpConfig.IdleConnTimeout) * time.Second,
+			MaxConnsPerHost:     httpConfig.MaxConnsPerHost,
+			DisableCompression:  httpConfig.DisableCompression,
+			DisableKeepAlives:   httpConfig.DisableKeepAlives,
+		})
+
+		// 设置默认headers
+		client.SetHeaders(map[string]string{
+			"Content-Type": "application/json",
+			"Accept":       "application/json",
+		})
+
+		httpFactoryInstance = &HTTPFactory{
+			config: cfg,
+			client: client,
+		}
+	})
+
+	return httpFactoryInstance, httpFactoryInitErr
+}
+
+// CreateClient 创建HTTP客户端包装器（共享底层resty.Client）
+func (f *HTTPFactory) CreateClient() *HTTPClient {
+	return &HTTPClient{
+		client: f.client, // 共享同一个线程安全的客户端
+	}
+}
+
+// CreateClient 全局便捷函数：创建HTTP客户端
+func CreateClient() (*HTTPClient, error) {
+	factory, err := GetHTTPFactory()
+	if err != nil {
+		return nil, err
+	}
+	return factory.CreateClient(), nil
+}
+
+// GetInitError 获取初始化错误（如果有）
+func GetInitError() error {
+	return httpFactoryInitErr
+}
+
+// ==================== HTTPClient 方法 ====================
+
+// SetAuthToken 设置认证token（请求级别）
+func (c *HTTPClient) SetAuthToken(token string) *HTTPClient {
+	// 注意：这里设置的是客户端级别的token，会影响所有使用该客户端的请求
+	// 对于多用户场景，应该在请求级别设置
+	c.client.SetAuthToken(token)
+	return c
 }
 
-// NewHTTPFactory 创建HTTP客户端工厂
-func NewHTTPFactory() (*HTTPFactory, error) {
-	cfg := config.GetConfig()
+// SetBearerToken 设置Bearer Token认证头（请求级别）
+func (c *HTTPClient) SetBearerToken(token string) *HTTPClient {
+	if token != "" {
+		c.client.SetHeader("Authorization", "Bearer "+token)
+	} else {
+		c.client.Header.Del("Authorization")
+	}
+	return c
+}
 
-	if err := config.GetInitError(); err != nil {
-		return nil, fmt.Errorf("failed to load config: %v", err)
+// SetBasicAuth 设置Basic认证头（请求级别）
+func (c *HTTPClient) SetBasicAuth(username, password string) *HTTPClient {
+	if username != "" && password != "" {
+		auth := username + ":" + password
+		token := base64.StdEncoding.EncodeToString([]byte(auth))
+		c.client.SetHeader("Authorization", "Basic "+token)
+	} else {
+		c.client.Header.Del("Authorization")
 	}
+	return c
+}
+
+// SetJSONContentType 设置Content-Type为application/json
+func (c *HTTPClient) SetJSONContentType() *HTTPClient {
+	c.client.SetHeader("Content-Type", "application/json")
+	return c
+}
+
+// SetHeader 设置请求头
+func (c *HTTPClient) SetHeader(key, value string) *HTTPClient {
+	c.client.SetHeader(key, value)
+	return c
+}
+
+// SetHeaders 批量设置请求头
+func (c *HTTPClient) SetHeaders(headers map[string]string) *HTTPClient {
+	c.client.SetHeaders(headers)
+	return c
+}
 
-	client := &http.Client{
-		Timeout: 30 * time.Second,
-		Transport: &http.Transport{
-			MaxIdleConns:        100,
-			MaxIdleConnsPerHost: 10,
-			IdleConnTimeout:     90 * time.Second,
-		},
+// SetAuthHeaders 设置认证相关的headers
+func (c *HTTPClient) SetAuthHeaders(token string) *HTTPClient {
+	return c.SetJSONContentType().SetBearerToken(token)
+}
+
+// SetBasicAuthHeaders 设置Basic认证相关的headers
+func (c *HTTPClient) SetBasicAuthHeaders(username, password string) *HTTPClient {
+	return c.SetJSONContentType().SetBasicAuth(username, password)
+}
+
+// Post 发送POST请求（在请求级别设置认证信息，避免多用户相互影响）
+func (c *HTTPClient) Post(url string, data interface{}) (*resty.Response, error) {
+	return c.client.R().SetBody(data).Post(url)
+}
+
+// PostWithResult 发送POST请求并解析结果
+func (c *HTTPClient) PostWithResult(url string, data interface{}, result interface{}) (*resty.Response, error) {
+	return c.client.R().SetBody(data).SetResult(result).Post(url)
+}
+
+// PostWithAuth 发送带Bearer Token的POST请求（推荐用于多用户场景）
+func (c *HTTPClient) PostWithAuth(url string, data interface{}, token string, result interface{}) (*resty.Response, error) {
+	req := c.client.R().SetBody(data)
+	if token != "" {
+		req.SetHeader("Authorization", "Bearer "+token)
 	}
+	if result != nil {
+		req.SetResult(result)
+	}
+	return req.Post(url)
+}
 
-	return &HTTPFactory{
-		config: cfg,
-		client: client,
-	}, nil
+// Get 发送GET请求
+func (c *HTTPClient) Get(url string) (*resty.Response, error) {
+	return c.client.R().Get(url)
 }
 
-// CreateHTTPClient 创建HTTP客户端
-func (f *HTTPFactory) CreateHTTPClient() *http.Client {
-	return f.client
+// GetWithResult 发送GET请求并解析结果
+func (c *HTTPClient) GetWithResult(url string, result interface{}) (*resty.Response, error) {
+	return c.client.R().SetResult(result).Get(url)
 }
 
-// GetConfig 获取配置信息
-func (f *HTTPFactory) GetConfig() config.IConfig {
-	return f.config
+// GetWithAuth 发送带Bearer Token的GET请求（推荐用于多用户场景）
+func (c *HTTPClient) GetWithAuth(url string, token string, result interface{}) (*resty.Response, error) {
+	req := c.client.R()
+	if token != "" {
+		req.SetHeader("Authorization", "Bearer "+token)
+	}
+	if result != nil {
+		req.SetResult(result)
+	}
+	return req.Get(url)
+}
+
+// Put 发送PUT请求
+func (c *HTTPClient) Put(url string, data interface{}) (*resty.Response, error) {
+	return c.client.R().SetBody(data).Put(url)
+}
+
+// PutWithResult 发送PUT请求并解析结果
+func (c *HTTPClient) PutWithResult(url string, data interface{}, result interface{}) (*resty.Response, error) {
+	return c.client.R().SetBody(data).SetResult(result).Put(url)
+}
+
+// Delete 发送DELETE请求
+func (c *HTTPClient) Delete(url string) (*resty.Response, error) {
+	return c.client.R().Delete(url)
+}
+
+// DeleteWithResult 发送DELETE请求并解析结果
+func (c *HTTPClient) DeleteWithResult(url string, result interface{}) (*resty.Response, error) {
+	return c.client.R().SetResult(result).Delete(url)
+}
+
+// ==================== 便捷函数（修正版） ====================
+
+// PostJSON 便捷函数：直接发送POST请求
+func PostJSON(url string, data interface{}, result interface{}) (*resty.Response, error) {
+	client, err := CreateClient()
+	if err != nil {
+		return nil, err
+	}
+
+	if result != nil {
+		return client.PostWithResult(url, data, result)
+	}
+	return client.Post(url, data)
+}
+
+// PostJSONWithBearerToken 便捷函数：使用Bearer Token发送POST请求
+func PostJSONWithBearerToken(token, url string, data interface{}, result interface{}) (*resty.Response, error) {
+	client, err := CreateClient()
+	if err != nil {
+		return nil, err
+	}
+
+	return client.PostWithAuth(url, data, token, result)
+}
+
+// PostJSONWithBasicAuth 便捷函数：使用Basic认证发送POST请求
+func PostJSONWithBasicAuth(username, password, url string, data interface{}, result interface{}) (*resty.Response, error) {
+	client, err := CreateClient()
+	if err != nil {
+		return nil, err
+	}
+
+	// 为这个特定请求设置Basic Auth
+	req := client.client.R().SetBody(data)
+	if username != "" && password != "" {
+		auth := username + ":" + password
+		token := base64.StdEncoding.EncodeToString([]byte(auth))
+		req.SetHeader("Authorization", "Basic "+token)
+	}
+	if result != nil {
+		req.SetResult(result)
+	}
+	return req.Post(url)
+}
+
+// GetJSON 便捷函数：直接发送GET请求
+func GetJSON(url string, result interface{}) (*resty.Response, error) {
+	client, err := CreateClient()
+	if err != nil {
+		return nil, err
+	}
+
+	if result != nil {
+		return client.GetWithResult(url, result)
+	}
+	return client.Get(url)
+}
+
+// GetJSONWithBearerToken 便捷函数：使用Bearer Token发送GET请求
+func GetJSONWithBearerToken(token, url string, result interface{}) (*resty.Response, error) {
+	client, err := CreateClient()
+	if err != nil {
+		return nil, err
+	}
+
+	return client.GetWithAuth(url, token, result)
+}
+
+// GetJSONWithBasicAuth 便捷函数：使用Basic认证发送GET请求
+func GetJSONWithBasicAuth(username, password, url string, result interface{}) (*resty.Response, error) {
+	client, err := CreateClient()
+	if err != nil {
+		return nil, err
+	}
+
+	// 为这个特定请求设置Basic Auth
+	req := client.client.R()
+	if username != "" && password != "" {
+		auth := username + ":" + password
+		token := base64.StdEncoding.EncodeToString([]byte(auth))
+		req.SetHeader("Authorization", "Basic "+token)
+	}
+	if result != nil {
+		req.SetResult(result)
+	}
+	return req.Get(url)
 }

go.mod

@@ -13,17 +13,19 @@ require (
 require (
 	github.com/cespare/xxhash/v2 v2.1.2 // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
+	golang.org/x/net v0.43.0 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 )
 
 require (
 	filippo.io/edwards25519 v1.1.0 // indirect
-	git.x2erp.com/qdy/go-base v0.1.10
+	git.x2erp.com/qdy/go-base v0.1.11
 	github.com/go-redis/redis/v8 v8.11.5
+	github.com/go-resty/resty/v2 v2.17.0
 	github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 // indirect
 	github.com/golang-sql/sqlexp v0.1.0 // indirect
 	github.com/google/uuid v1.6.0 // indirect
 	github.com/jmoiron/sqlx v1.4.0
-	golang.org/x/crypto v0.38.0 // indirect
-	golang.org/x/text v0.25.0 // indirect
+	golang.org/x/crypto v0.41.0 // indirect
+	golang.org/x/text v0.28.0 // indirect
 )

go.sum

@@ -4,6 +4,8 @@ git.x2erp.com/qdy/go-base v0.1.9 h1:SuyYSt3Gp7aXiUQRCBNwhrusJ53wlCnagiTYs5eITlY=
 git.x2erp.com/qdy/go-base v0.1.9/go.mod h1:Q+YLwpCoU8CVSnzATLdz2LAzVMlz/CEGzo8DePf7cug=
 git.x2erp.com/qdy/go-base v0.1.10 h1:qHvRNSBoQHZfYrXUpZ42r925OO7aT95tIZK/qh6Cd60=
 git.x2erp.com/qdy/go-base v0.1.10/go.mod h1:Q+YLwpCoU8CVSnzATLdz2LAzVMlz/CEGzo8DePf7cug=
+git.x2erp.com/qdy/go-base v0.1.11 h1:STHT6z+zaN8kMIiXfggUdPaP4vcz+kpXaxHkw5ziXzA=
+git.x2erp.com/qdy/go-base v0.1.11/go.mod h1:Q+YLwpCoU8CVSnzATLdz2LAzVMlz/CEGzo8DePf7cug=
 github.com/Azure/azure-sdk-for-go/sdk/azcore v1.18.0 h1:Gt0j3wceWMwPmiazCa8MzMA0MfhmPIz0Qp0FJ6qcM0U=
 github.com/Azure/azure-sdk-for-go/sdk/azcore v1.18.0/go.mod h1:Ot/6aikWnKWi4l9QB7qVSwa8iMphQNqkWALMoNT3rzM=
 github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.10.1 h1:B+blDbyVIG3WaikNxPnhPiJ1MThR03b3vKGtER95TP4=
@@ -24,6 +26,8 @@ github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/r
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
 github.com/go-redis/redis/v8 v8.11.5 h1:AcZZR7igkdvfVmQTPnu9WE37LRrO/YrBH5zWyjDC0oI=
 github.com/go-redis/redis/v8 v8.11.5/go.mod h1:gREzHqY1hg6oD9ngVRbLStwAWKhA0FEgq8Jd4h5lpwo=
+github.com/go-resty/resty/v2 v2.17.0 h1:pW9DeXcaL4Rrym4EZ8v7L19zZiIlWPg5YXAcVmt+gN0=
+github.com/go-resty/resty/v2 v2.17.0/go.mod h1:kCKZ3wWmwJaNc7S29BRtUhJwy7iqmn+2mLtQrOyQlVA=
 github.com/go-sql-driver/mysql v1.8.1/go.mod h1:wEBSXgmK//2ZFJyE+qWnIsVGmvmEKlqwuVSjsCm7DZg=
 github.com/go-sql-driver/mysql v1.9.3 h1:U/N249h2WzJ3Ukj8SowVFjdtZKfu9vlLZxjPXV1aweo=
 github.com/go-sql-driver/mysql v1.9.3/go.mod h1:qn46aNg1333BRMNU69Lq93t8du/dwxI64Gl8i5p1WMU=
@@ -54,12 +58,18 @@ github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOf
 github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
 golang.org/x/crypto v0.38.0 h1:jt+WWG8IZlBnVbomuhg2Mdq0+BBQaHbtqHEFEigjUV8=
 golang.org/x/crypto v0.38.0/go.mod h1:MvrbAqul58NNYPKnOra203SB9vpuZW0e+RRZV+Ggqjw=
+golang.org/x/crypto v0.41.0 h1:WKYxWedPGCTVVl5+WHSSrOBT0O8lx32+zxmHxijgXp4=
+golang.org/x/crypto v0.41.0/go.mod h1:pO5AFd7FA68rFak7rOAGVuygIISepHftHnr8dr6+sUc=
 golang.org/x/net v0.40.0 h1:79Xs7wF06Gbdcg4kdCCIQArK11Z1hr5POQ6+fIYHNuY=
 golang.org/x/net v0.40.0/go.mod h1:y0hY0exeL2Pku80/zKK7tpntoX23cqL3Oa6njdgRtds=
+golang.org/x/net v0.43.0 h1:lat02VYK2j4aLzMzecihNvTlJNQUq316m2Mr9rnM6YE=
+golang.org/x/net v0.43.0/go.mod h1:vhO1fvI4dGsIjh73sWfUVjj3N7CA9WkKJNQm2svM6Jg=
 golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=
 golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
 golang.org/x/text v0.25.0 h1:qVyWApTSYLk/drJRO5mDlNYskwQznZmkpV2c8q9zls4=
 golang.org/x/text v0.25.0/go.mod h1:WEdwpYrmk1qmdHvhkSTNPm3app7v4rsT8F2UD6+VHIA=
+golang.org/x/text v0.28.0 h1:rhazDwis8INMIwQ4tpjLDzUhx6RlXqZNPEM0huQojng=
+golang.org/x/text v0.28.0/go.mod h1:U8nCwOR8jO/marOQ0QbDiOngZVEBB7MAiitBuMjXiNU=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=