TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-12-16 07:46:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改注释

Browse Source
This commit is contained in:
刘祥超
2021-08-25 16:46:05 +08:00
parent 8161270f47
commit 8069f20c77
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
internal/nodes/http_access_log_queue.go
View File

@@ -9,14 +9,14 @@ import (
var sharedHTTPAccessLogQueue = NewHTTPAccessLogQueue() var sharedHTTPAccessLogQueue = NewHTTPAccessLogQueue()
// HTTP访问日志队列 // HTTPAccessLogQueue HTTP访问日志队列
type HTTPAccessLogQueue struct { type HTTPAccessLogQueue struct {
queue chan *pb.HTTPAccessLog queue chan *pb.HTTPAccessLog
} }
// 获取新对象 // NewHTTPAccessLogQueue 获取新对象
func NewHTTPAccessLogQueue() *HTTPAccessLogQueue { func NewHTTPAccessLogQueue() *HTTPAccessLogQueue {
// 队列中最大的值，超出此数量的访问日志会被抛弃 // 队列中最大的值，超出此数量的访问日志会被丢弃
// TODO 需要可以在界面中设置 // TODO 需要可以在界面中设置
maxSize := 10000 maxSize := 10000
queue := &HTTPAccessLogQueue{ queue := &HTTPAccessLogQueue{
@@ -27,7 +27,7 @@ func NewHTTPAccessLogQueue() *HTTPAccessLogQueue {
return queue return queue
} }
// 开始处理访问日志 // Start 开始处理访问日志
func (this *HTTPAccessLogQueue) Start() { func (this *HTTPAccessLogQueue) Start() {
ticker := time.NewTicker(1 * time.Second) ticker := time.NewTicker(1 * time.Second)
for range ticker.C { for range ticker.C {
@@ -38,7 +38,7 @@ func (this *HTTPAccessLogQueue) Start() {
} }
} }
// 加入新访问日志 // Push 加入新访问日志
func (this *HTTPAccessLogQueue) Push(accessLog *pb.HTTPAccessLog) { func (this *HTTPAccessLogQueue) Push(accessLog *pb.HTTPAccessLog) {
select { select {
case this.queue <- accessLog: case this.queue <- accessLog: