From 4c99e11d814ebe98b50b84a8a6bc52d9e4873a1b Mon Sep 17 00:00:00 2001 From: Denis Galeev Date: Wed, 2 Apr 2025 18:51:31 +0300 Subject: [PATCH] fix parse --- config/parsing/recorder/parse.go | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/config/parsing/recorder/parse.go b/config/parsing/recorder/parse.go index 41944e0b..107a6446 100644 --- a/config/parsing/recorder/parse.go +++ b/config/parsing/recorder/parse.go @@ -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 != "" { - 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 != "" { @@ -86,6 +92,7 @@ func ParseRecorder(cfg *config.RecorderConfig) (r recorder.Recorder) { h.Add(k, v) } return xrecorder.HTTPRecorder(cfg.HTTP.URL, + xrecorder.RecorderHTTPRecorderOption(cfg.Name), xrecorder.TimeoutHTTPRecorderOption(cfg.HTTP.Timeout), xrecorder.HeaderHTTPRecorderOption(h), ) @@ -97,6 +104,7 @@ func ParseRecorder(cfg *config.RecorderConfig) (r recorder.Recorder) { switch cfg.Redis.Type { case "list": // redis list return xrecorder.RedisListRecorder(cfg.Redis.Addr, + xrecorder.RecorderRedisRecorderOption(cfg.Name), xrecorder.DBRedisRecorderOption(cfg.Redis.DB), xrecorder.KeyRedisRecorderOption(cfg.Redis.Key), xrecorder.UsernameRedisRecorderOption(cfg.Redis.Username), @@ -104,6 +112,7 @@ func ParseRecorder(cfg *config.RecorderConfig) (r recorder.Recorder) { ) case "sset": // sorted set return xrecorder.RedisSortedSetRecorder(cfg.Redis.Addr, + xrecorder.RecorderRedisRecorderOption(cfg.Name), xrecorder.DBRedisRecorderOption(cfg.Redis.DB), xrecorder.KeyRedisRecorderOption(cfg.Redis.Key), xrecorder.UsernameRedisRecorderOption(cfg.Redis.Username), @@ -111,6 +120,7 @@ func ParseRecorder(cfg *config.RecorderConfig) (r recorder.Recorder) { ) default: // redis set return xrecorder.RedisSetRecorder(cfg.Redis.Addr, + xrecorder.RecorderRedisRecorderOption(cfg.Name), xrecorder.DBRedisRecorderOption(cfg.Redis.DB), xrecorder.KeyRedisRecorderOption(cfg.Redis.Key), xrecorder.UsernameRedisRecorderOption(cfg.Redis.Username),