From 8069f20c77a2ba83e2194c2c76bea688d5030c02 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Wed, 25 Aug 2021 16:46:05 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/http_access_log_queue.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/internal/nodes/http_access_log_queue.go b/internal/nodes/http_access_log_queue.go index 95a4835..9eb9e82 100644 --- a/internal/nodes/http_access_log_queue.go +++ b/internal/nodes/http_access_log_queue.go @@ -9,14 +9,14 @@ import ( var sharedHTTPAccessLogQueue = NewHTTPAccessLogQueue() -// HTTP访问日志队列 +// HTTPAccessLogQueue HTTP访问日志队列 type HTTPAccessLogQueue struct { queue chan *pb.HTTPAccessLog } -// 获取新对象 +// NewHTTPAccessLogQueue 获取新对象 func NewHTTPAccessLogQueue() *HTTPAccessLogQueue { - // 队列中最大的值,超出此数量的访问日志会被抛弃 + // 队列中最大的值,超出此数量的访问日志会被丢弃 // TODO 需要可以在界面中设置 maxSize := 10000 queue := &HTTPAccessLogQueue{ @@ -27,7 +27,7 @@ func NewHTTPAccessLogQueue() *HTTPAccessLogQueue { return queue } -// 开始处理访问日志 +// Start 开始处理访问日志 func (this *HTTPAccessLogQueue) Start() { ticker := time.NewTicker(1 * time.Second) for range ticker.C { @@ -38,7 +38,7 @@ func (this *HTTPAccessLogQueue) Start() { } } -// 加入新访问日志 +// Push 加入新访问日志 func (this *HTTPAccessLogQueue) Push(accessLog *pb.HTTPAccessLog) { select { case this.queue <- accessLog: