From 9849de2c293f3fd3bc228fde0e01856a05e52d73 Mon Sep 17 00:00:00 2001 From: Kevin Franklin Kim Date: Fri, 7 Mar 2025 16:46:53 +0100 Subject: [PATCH] fix: parameter --- persistence/mongo/persistor.go | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/persistence/mongo/persistor.go b/persistence/mongo/persistor.go index 6401861..2904a13 100644 --- a/persistence/mongo/persistor.go +++ b/persistence/mongo/persistor.go @@ -45,6 +45,18 @@ func WithOtelEnabled(v bool) Option { } } +func WithOtelOptions(v ...otelmongo.Option) Option { + return func(o *Options) { + o.OtelOptions = append(o.OtelOptions, v...) + } +} + +func WithClientOptions(v ...ClientOption) Option { + return func(o *Options) { + o.ClientOptions = append(o.ClientOptions, v...) + } +} + func WithClientLogger(v *zap.Logger) Option { return func(o *Options) { o.ClientLoggerOptions = append(o.ClientLoggerOptions, func(o *options.LoggerOptions) { @@ -61,7 +73,7 @@ func WithClientLoggerComponentLevel(c options.LogComponent, l options.LogLevel) } } -func WithClientCompression(v *zap.Logger) Option { +func WithClientCompression() Option { return func(o *Options) { o.ClientOptions = append(o.ClientOptions, func(o *options.ClientOptions) { o.SetCompressors([]string{"snappy", "zstd"}) @@ -69,18 +81,6 @@ func WithClientCompression(v *zap.Logger) Option { } } -func WithOtelOptions(v ...otelmongo.Option) Option { - return func(o *Options) { - o.OtelOptions = append(o.OtelOptions, v...) - } -} - -func WithClientOptions(v ...ClientOption) Option { - return func(o *Options) { - o.ClientOptions = append(o.ClientOptions, v...) - } -} - func WithDatabaseOptions(v ...DatabaseOption) Option { return func(o *Options) { o.DatabaseOptions = append(o.DatabaseOptions, v...)