From d0a063469731638d8e0b508d35c7a3d9ec5d72ff Mon Sep 17 00:00:00 2001 From: varnit goyal Date: Sat, 21 Dec 2024 18:18:23 +0530 Subject: [PATCH] NTP-19782 | fix call state type:gst --- pkg/log/log.go | 2 +- pkg/log/zapConfig.go | 27 +++++++++++++++++++++++++++ service/searchService.go | 2 +- 3 files changed, 29 insertions(+), 2 deletions(-) create mode 100644 pkg/log/zapConfig.go diff --git a/pkg/log/log.go b/pkg/log/log.go index 32d2a46..d575f64 100644 --- a/pkg/log/log.go +++ b/pkg/log/log.go @@ -17,7 +17,7 @@ type Logger struct { var Log *Logger func initiateLogger() *zap.Logger { - config := zap.NewProductionConfig() + config := NewCustomZapConfig() config.EncoderConfig = ecszap.ECSCompatibleEncoderConfig(config.EncoderConfig) log, err := config.Build(ecszap.WrapCoreOption(), zap.AddCallerSkip(1)) log = log.With(zap.String("service", "cybertron")) diff --git a/pkg/log/zapConfig.go b/pkg/log/zapConfig.go new file mode 100644 index 0000000..edbc852 --- /dev/null +++ b/pkg/log/zapConfig.go @@ -0,0 +1,27 @@ +package log + +import ( + "encoding/json" + "go.uber.org/zap" +) + +func NewCustomZapConfig() zap.Config { + rawJSON := []byte(`{ + "level": "debug", + "development": false, + "sampling": { + "initial": 100, + "thereafter": 100 + }, + "disableCaller": true, + "encoding": "json", + "OutputPaths": ["stdout"], + "ErrorOutputPaths": ["stderr"] + }`) + + var cfg zap.Config + if err := json.Unmarshal(rawJSON, &cfg); err != nil { + panic(err) + } + return cfg +} diff --git a/service/searchService.go b/service/searchService.go index 0148b55..91774a9 100644 --- a/service/searchService.go +++ b/service/searchService.go @@ -120,7 +120,7 @@ func (s *SearchService) GetErrorListV2(c *gin.Context) { final_terms_aggs_query := utils.CreateAggregationQuery(terms_aggs_query_with_name) final_query := utils.CreateEsQuery(search_query, size_query, final_terms_aggs_query) - println("final query %v", final_query) + //println("final query %v", final_query) fields := []string{"error", "significant_stack", "title"} var _, aggs, total, err = s.elasticSearchClient.SearchDocuments(final_query, fields)