根据系统内存调整访问日志队列长度

This commit is contained in:
GoEdgeLab
2023-03-10 22:31:40 +08:00
parent f3980e3635
commit db6a2203c4

View File

@@ -25,9 +25,12 @@ type HTTPAccessLogQueue struct {
// NewHTTPAccessLogQueue 获取新对象 // NewHTTPAccessLogQueue 获取新对象
func NewHTTPAccessLogQueue() *HTTPAccessLogQueue { func NewHTTPAccessLogQueue() *HTTPAccessLogQueue {
// 队列中最大的值,超出此数量的访问日志会被丢弃 // 队列中最大的值,超出此数量的访问日志会被丢弃
// TODO 需要可以在界面中设置 var maxSize = 2_000 * (1 + utils.SystemMemoryGB()/2)
maxSize := 20000 if maxSize > 20_000 {
queue := &HTTPAccessLogQueue{ maxSize = 20_000
}
var queue = &HTTPAccessLogQueue{
queue: make(chan *pb.HTTPAccessLog, maxSize), queue: make(chan *pb.HTTPAccessLog, maxSize),
} }
goman.New(func() { goman.New(func() {