diff --git a/internal/caches/writer_gzip.go b/internal/caches/writer_gzip.go index 360e80c..945843f 100644 --- a/internal/caches/writer_gzip.go +++ b/internal/caches/writer_gzip.go @@ -1,6 +1,8 @@ package caches -import "compress/gzip" +import ( + "compress/gzip" +) type gzipWriter struct { rawWriter Writer diff --git a/internal/nodes/http_client.go b/internal/nodes/http_client.go index ab4848b..aeabed5 100644 --- a/internal/nodes/http_client.go +++ b/internal/nodes/http_client.go @@ -5,13 +5,13 @@ import ( "net/http" ) -// HTTP客户端 +// HTTPClient HTTP客户端 type HTTPClient struct { rawClient *http.Client accessAt int64 } -// 获取新客户端对象 +// NewHTTPClient 获取新客户端对象 func NewHTTPClient(rawClient *http.Client) *HTTPClient { return &HTTPClient{ rawClient: rawClient, @@ -19,22 +19,22 @@ func NewHTTPClient(rawClient *http.Client) *HTTPClient { } } -// 获取原始客户端对象 +// RawClient 获取原始客户端对象 func (this *HTTPClient) RawClient() *http.Client { return this.rawClient } -// 更新访问时间 +// UpdateAccessTime 更新访问时间 func (this *HTTPClient) UpdateAccessTime() { this.accessAt = utils.UnixTime() } -// 获取访问时间 +// AccessTime 获取访问时间 func (this *HTTPClient) AccessTime() int64 { return this.accessAt } -// 关闭 +// Close 关闭 func (this *HTTPClient) Close() { this.rawClient.CloseIdleConnections() } diff --git a/internal/nodes/http_client_pool.go b/internal/nodes/http_client_pool.go index 5201fe0..3222262 100644 --- a/internal/nodes/http_client_pool.go +++ b/internal/nodes/http_client_pool.go @@ -14,17 +14,17 @@ import ( "time" ) -// HTTP客户端池单例 +// SharedHTTPClientPool HTTP客户端池单例 var SharedHTTPClientPool = NewHTTPClientPool() -// 客户端池 +// HTTPClientPool 客户端池 type HTTPClientPool struct { clientExpiredDuration time.Duration clientsMap map[string]*HTTPClient // backend key => client locker sync.Mutex } -// 获取新对象 +// NewHTTPClientPool 获取新对象 func NewHTTPClientPool() *HTTPClientPool { pool := &HTTPClientPool{ clientExpiredDuration: 3600 * time.Second, @@ -36,7 +36,7 @@ func NewHTTPClientPool() *HTTPClientPool { return pool } -// 根据地址获取客户端 +// Client 根据地址获取客户端 func (this *HTTPClientPool) Client(req *http.Request, origin *serverconfigs.OriginConfig, originAddr string) (rawClient *http.Client, err error) { if origin.Addr == nil { return nil, errors.New("origin addr should not be empty (originId:" + strconv.FormatInt(origin.Id, 10) + ")") diff --git a/internal/nodes/http_request.go b/internal/nodes/http_request.go index 2d57d5d..c7bc193 100644 --- a/internal/nodes/http_request.go +++ b/internal/nodes/http_request.go @@ -28,7 +28,7 @@ var bytePool1k = utils.NewBytePool(20480, 1024) var bytePool32k = utils.NewBytePool(20480, 32*1024) var bytePool128k = utils.NewBytePool(20480, 128*1024) -// HTTP请求 +// HTTPRequest HTTP请求 type HTTPRequest struct { // 外部参数 RawReq *http.Request @@ -95,7 +95,7 @@ func (this *HTTPRequest) init() { this.requestFromTime = time.Now() } -// 执行请求 +// Do 执行请求 func (this *HTTPRequest) Do() { // 初始化 this.init() @@ -433,7 +433,7 @@ func (this *HTTPRequest) configureWeb(web *serverconfigs.HTTPWebConfig, isTop bo return nil } -// 利用请求参数格式化字符串 +// Format 利用请求参数格式化字符串 func (this *HTTPRequest) Format(source string) string { if len(source) == 0 { return ""