go-gost/x
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix parse

Browse Source
This commit is contained in:
Denis Galeev
2025-04-02 18:51:31 +03:00
committed by ginuerzh
parent 1eaf08c9c1
commit 4c99e11d81
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
config/parsing/recorder/parse.go
+12 -2
View File
@@ -73,11 +73,17 @@ func ParseRecorder(cfg *config.RecorderConfig) (r recorder.Recorder) {
} }
} }
return xrecorder.FileRecorder(out, xrecorder.SepRecorderOption(cfg.File.Sep)) return xrecorder.FileRecorder(out,
xrecorder.RecorderFileRecorderOption(cfg.Name),
xrecorder.SepFileRecorderOption(cfg.File.Sep),
)
} }
if cfg.TCP != nil && cfg.TCP.Addr != "" { if cfg.TCP != nil && cfg.TCP.Addr != "" {
return xrecorder.TCPRecorder(cfg.TCP.Addr, xrecorder.TimeoutTCPRecorderOption(cfg.TCP.Timeout)) return xrecorder.TCPRecorder(cfg.TCP.Addr,
xrecorder.RecorderTCPRecorderOption(cfg.Name),
xrecorder.TimeoutTCPRecorderOption(cfg.TCP.Timeout),
)
} }
if cfg.HTTP != nil && cfg.HTTP.URL != "" { if cfg.HTTP != nil && cfg.HTTP.URL != "" {
@@ -86,6 +92,7 @@ func ParseRecorder(cfg *config.RecorderConfig) (r recorder.Recorder) {
h.Add(k, v) h.Add(k, v)
} }
return xrecorder.HTTPRecorder(cfg.HTTP.URL, return xrecorder.HTTPRecorder(cfg.HTTP.URL,
xrecorder.RecorderHTTPRecorderOption(cfg.Name),
xrecorder.TimeoutHTTPRecorderOption(cfg.HTTP.Timeout), xrecorder.TimeoutHTTPRecorderOption(cfg.HTTP.Timeout),
xrecorder.HeaderHTTPRecorderOption(h), xrecorder.HeaderHTTPRecorderOption(h),
) )
@@ -97,6 +104,7 @@ func ParseRecorder(cfg *config.RecorderConfig) (r recorder.Recorder) {
switch cfg.Redis.Type { switch cfg.Redis.Type {
case "list": // redis list case "list": // redis list
return xrecorder.RedisListRecorder(cfg.Redis.Addr, return xrecorder.RedisListRecorder(cfg.Redis.Addr,
xrecorder.RecorderRedisRecorderOption(cfg.Name),
xrecorder.DBRedisRecorderOption(cfg.Redis.DB), xrecorder.DBRedisRecorderOption(cfg.Redis.DB),
xrecorder.KeyRedisRecorderOption(cfg.Redis.Key), xrecorder.KeyRedisRecorderOption(cfg.Redis.Key),
xrecorder.UsernameRedisRecorderOption(cfg.Redis.Username), xrecorder.UsernameRedisRecorderOption(cfg.Redis.Username),
@@ -104,6 +112,7 @@ func ParseRecorder(cfg *config.RecorderConfig) (r recorder.Recorder) {
) )
case "sset": // sorted set case "sset": // sorted set
return xrecorder.RedisSortedSetRecorder(cfg.Redis.Addr, return xrecorder.RedisSortedSetRecorder(cfg.Redis.Addr,
xrecorder.RecorderRedisRecorderOption(cfg.Name),
xrecorder.DBRedisRecorderOption(cfg.Redis.DB), xrecorder.DBRedisRecorderOption(cfg.Redis.DB),
xrecorder.KeyRedisRecorderOption(cfg.Redis.Key), xrecorder.KeyRedisRecorderOption(cfg.Redis.Key),
xrecorder.UsernameRedisRecorderOption(cfg.Redis.Username), xrecorder.UsernameRedisRecorderOption(cfg.Redis.Username),
@@ -111,6 +120,7 @@ func ParseRecorder(cfg *config.RecorderConfig) (r recorder.Recorder) {
) )
default: // redis set default: // redis set
return xrecorder.RedisSetRecorder(cfg.Redis.Addr, return xrecorder.RedisSetRecorder(cfg.Redis.Addr,
xrecorder.RecorderRedisRecorderOption(cfg.Name),
xrecorder.DBRedisRecorderOption(cfg.Redis.DB), xrecorder.DBRedisRecorderOption(cfg.Redis.DB),
xrecorder.KeyRedisRecorderOption(cfg.Redis.Key), xrecorder.KeyRedisRecorderOption(cfg.Redis.Key),
xrecorder.UsernameRedisRecorderOption(cfg.Redis.Username), xrecorder.UsernameRedisRecorderOption(cfg.Redis.Username),