From c76cc6c0a045a9d96b24791dee3eb7768eb6169f Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Sun, 20 Mar 2022 10:53:35 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=B8=80=E4=B8=AA=E6=B5=8B?= =?UTF-8?q?=E8=AF=95=E7=94=A8=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/http_access_log_queue.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/nodes/http_access_log_queue.go b/internal/nodes/http_access_log_queue.go index d07a34a..1f1fc18 100644 --- a/internal/nodes/http_access_log_queue.go +++ b/internal/nodes/http_access_log_queue.go @@ -94,7 +94,7 @@ Loop: // 是否包含了invalid UTF-8 if strings.Contains(err.Error(), "string field contains invalid UTF-8") { for _, accessLog := range accessLogs { - this.toValidUTF8(accessLog) + this.ToValidUTF8(accessLog) } // 重新提交 @@ -108,7 +108,7 @@ Loop: return nil } -func (this *HTTPAccessLogQueue) toValidUTF8(accessLog *pb.HTTPAccessLog) { +func (this *HTTPAccessLogQueue) ToValidUTF8(accessLog *pb.HTTPAccessLog) { accessLog.RemoteUser = utils.ToValidUTF8string(accessLog.RemoteUser) accessLog.RequestURI = utils.ToValidUTF8string(accessLog.RequestURI) accessLog.RequestPath = utils.ToValidUTF8string(accessLog.RequestPath)