From f6a779fad7f976e58adb6d9b74f61c5e8fc1db73 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=99=BD=E8=8C=B6=E6=B8=85=E6=AC=A2?= Date: Sun, 27 Apr 2025 14:51:42 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E9=85=8D=E7=BD=AE=E5=88=9D?= =?UTF-8?q?=E5=A7=8B=E5=80=BC=E6=A3=80=E6=B5=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- define.go | 5 +++-- zinc_search.go | 9 +++++++++ 2 files changed, 12 insertions(+), 2 deletions(-) diff --git a/define.go b/define.go index d07f2d9..9b2899f 100644 --- a/define.go +++ b/define.go @@ -166,8 +166,9 @@ type ZincConfig struct { } const ( - DefaultTimeout = 5000 // 默认超时时间 - DefaultBufferSize = 1000 // 默认buffer大小 + DefaultTimeout = 5000 // 默认超时时间 + DefaultBufferSize = 1000 // 默认buffer大小 + DefaultForceFlushLogTime = 1000 // 强制刷新日志的时间间隔, 单位毫秒 ) const ( diff --git a/zinc_search.go b/zinc_search.go index 4334da3..28cd9b7 100644 --- a/zinc_search.go +++ b/zinc_search.go @@ -21,6 +21,15 @@ import ( ) func NewZincLogConnect(cfg *ZincConfig) io.Writer { + if cfg.Timeout <= 0 { + cfg.Timeout = DefaultTimeout + } + if cfg.BufferSize <= 0 { + cfg.BufferSize = DefaultBufferSize + } + if cfg.ForceSyncTime <= 0 { + cfg.ForceSyncTime = DefaultForceFlushLogTime + } zlc := &zincLogConnect{ config: cfg, lock: &sync.RWMutex{},