feat: config defaults

Trendyol · Apr 10, 2023 · 574350f · 574350f
1 parent 5f9ffd8
commit 574350f
Show file tree

Hide file tree

Showing 11 changed files with 49 additions and 104 deletions.
diff --git a/README.md b/README.md
@@ -122,11 +122,11 @@ Check out on [go-dcp-client](https://github.com/Trendyol/go-dcp-client#configura
 | Variable                               | Type              | Required | Default |                                                             
 |----------------------------------------|-------------------|----------|---------|
 | `elasticsearch.collectionIndexMapping` | map[string]string | yes      |         |
-| `elasticsearch.typeName`               | string            | yes      |         |
 | `elasticsearch.urls`                   | []string          | yes      |         |
-| `elasticsearch.batchSizeLimit`         | int               | yes      |         |
-| `elasticsearch.batchTickerDuration`    | time.Duration     | yes      |         |
-| `elasticsearch.batchByteSizeLimit`     | int               | yes      |         |
+| `elasticsearch.typeName`               | string            | no       | _doc    |
+| `elasticsearch.batchSizeLimit`         | int               | no       | 1000    |
+| `elasticsearch.batchTickerDuration`    | time.Duration     | no       | 10s     |
+| `elasticsearch.batchByteSizeLimit`     | int               | no       | 10240   |
 
 ---
 

diff --git a/config/config.go b/config/config.go
@@ -3,7 +3,6 @@ package config
 import (
 	"time"
 
-	"github.com/Trendyol/go-dcp-client/helpers"
 	"github.com/Trendyol/go-elasticsearch-connect-couchbase/logger"
 
 	"github.com/gookit/config/v2"
@@ -12,21 +11,28 @@ import (
 
 type Elasticsearch struct {
 	CollectionIndexMapping map[string]string `yaml:"collectionIndexMapping"`
-	TypeName               string            `yaml:"typeName"`
+	TypeName               string            `yaml:"typeName" default:"_doc"`
 	Urls                   []string          `yaml:"urls"`
-	BatchSizeLimit         int               `yaml:"batchSizeLimit"`
+	BatchSizeLimit         int               `yaml:"batchSizeLimit" default:"1000"`
+	BatchByteSizeLimit     int               `yaml:"batchByteSizeLimit" default:"10240"`
 	BatchTickerDuration    time.Duration     `yaml:"batchTickerDuration"`
 }
 
 type Config struct {
-	Elasticsearch *Elasticsearch       `yaml:"elasticsearch"`
-	Metric        helpers.ConfigMetric `yaml:"metric"`
+	Elasticsearch Elasticsearch `yaml:"elasticsearch"`
 }
 
 func Options(opts *config.Options) {
 	opts.ParseTime = true
 	opts.Readonly = true
 	opts.EnableCache = true
+	opts.ParseDefault = true
+}
+
+func applyUnhandledDefaults(_config *Config) {
+	if _config.Elasticsearch.BatchTickerDuration == 0 {
+		_config.Elasticsearch.BatchTickerDuration = 10 * time.Second
+	}
 }
 
 func NewConfig(name string, filePath string, errorLogger logger.Logger) *Config {
@@ -44,5 +50,7 @@ func NewConfig(name string, filePath string, errorLogger logger.Logger) *Config
 		errorLogger.Printf("Error while reading config %v", err)
 	}
 
+	applyUnhandledDefaults(_config)
+
 	return _config
 }
diff --git a/connector.go b/connector.go
@@ -71,8 +71,7 @@ func newConnector(configPath string, mapper Mapper, logger logger.Logger, errorL
 	}
 	connector.dcp = dcp
 	connector.bulk, err = bulk.NewBulk(
-		c.Elasticsearch,
-		c.Metric.AverageWindowSec,
+		c,
 		logger,
 		errorLogger,
 		dcp.Commit,

diff --git a/elasticsearch/bulk/bulk.go b/elasticsearch/bulk/bulk.go
@@ -5,14 +5,12 @@ import (
 	"sync"
 	"time"
 
+	"github.com/Trendyol/go-dcp-client/models"
 	"github.com/Trendyol/go-elasticsearch-connect-couchbase/config"
 	"github.com/Trendyol/go-elasticsearch-connect-couchbase/elasticsearch/client"
 	"github.com/Trendyol/go-elasticsearch-connect-couchbase/elasticsearch/document"
 	"github.com/Trendyol/go-elasticsearch-connect-couchbase/helper"
 	"github.com/Trendyol/go-elasticsearch-connect-couchbase/logger"
-	"github.com/VividCortex/ewma"
-
-	"github.com/Trendyol/go-dcp-client/models"
 	"github.com/elastic/go-elasticsearch/v7"
 )
 
@@ -36,36 +34,34 @@ type Bulk struct {
 }
 
 type Metric struct {
-	ESConnectorLatency ewma.MovingAverage
+	ESConnectorLatency int64
 }
 
 func NewBulk(
-	esConfig *config.Elasticsearch,
-	averageWindowSec float64,
+	config *config.Config,
 	logger logger.Logger,
 	errorLogger logger.Logger,
 	dcpCheckpointCommit func(),
 ) (*Bulk, error) {
-	esClient, err := client.NewElasticClient(esConfig)
+	esClient, err := client.NewElasticClient(config)
 	if err != nil {
 		return nil, err
 	}
 
 	bulk := &Bulk{
-		batchTickerDuration: esConfig.BatchTickerDuration,
-		batchTicker:         time.NewTicker(esConfig.BatchTickerDuration),
-		actionCh:            make(chan document.ESActionDocument, esConfig.BatchSizeLimit),
-		batchSizeLimit:      esConfig.BatchSizeLimit,
-		isClosed:            make(chan bool, 1),
-		logger:              logger,
-		errorLogger:         errorLogger,
-		dcpCheckpointCommit: dcpCheckpointCommit,
-		esClient:            esClient,
-		metric: &Metric{
-			ESConnectorLatency: ewma.NewMovingAverage(averageWindowSec),
-		},
-		collectionIndexMapping: esConfig.CollectionIndexMapping,
-		typeName:               helper.Byte(esConfig.TypeName),
+		batchTickerDuration:    config.Elasticsearch.BatchTickerDuration,
+		batchTicker:            time.NewTicker(config.Elasticsearch.BatchTickerDuration),
+		actionCh:               make(chan document.ESActionDocument, config.Elasticsearch.BatchSizeLimit),
+		batchSizeLimit:         config.Elasticsearch.BatchSizeLimit,
+		batchByteSizeLimit:     config.Elasticsearch.BatchByteSizeLimit,
+		isClosed:               make(chan bool, 1),
+		logger:                 logger,
+		errorLogger:            errorLogger,
+		dcpCheckpointCommit:    dcpCheckpointCommit,
+		esClient:               esClient,
+		metric:                 &Metric{},
+		collectionIndexMapping: config.Elasticsearch.CollectionIndexMapping,
+		typeName:               helper.Byte(config.Elasticsearch.TypeName),
 	}
 
 	go bulk.StartBulk()
@@ -106,7 +102,7 @@ func (b *Bulk) AddAction(
 	ctx.Ack()
 	b.flushLock.Unlock()
 
-	b.metric.ESConnectorLatency.Add(float64(time.Since(eventTime).Milliseconds()))
+	b.metric.ESConnectorLatency = time.Since(eventTime).Milliseconds()
 
 	if b.batchSize == b.batchSizeLimit || len(b.batch) >= b.batchByteSizeLimit {
 		err := b.flushMessages()

diff --git a/elasticsearch/client/client.go b/elasticsearch/client/client.go
@@ -8,14 +8,13 @@ import (
 	"github.com/elastic/go-elasticsearch/v7"
 )
 
-func NewElasticClient(elasticConfig *config.Elasticsearch) (*elasticsearch.Client, error) {
-	config := elasticsearch.Config{
+func NewElasticClient(config *config.Config) (*elasticsearch.Client, error) {
+	es, err := elasticsearch.NewClient(elasticsearch.Config{
 		MaxRetries:           math.MaxInt,
-		Addresses:            elasticConfig.Urls,
+		Addresses:            config.Elasticsearch.Urls,
 		DiscoverNodesOnStart: true,
 		Transport:            &Transport{},
-	}
-	es, err := elasticsearch.NewClient(config)
+	})
 	if err != nil {
 		return nil, err
 	}

diff --git a/example/config.yml b/example/config.yml
@@ -3,26 +3,15 @@ hosts:
 username: user
 password: password
 bucketName: dcp-test
-metadata:
-  config:
-    bucket: dcp-test-meta
 dcp:
-  listener:
-    bufferSize: 1000
   group:
     name: groupName
     membership:
       type: static
-      memberNumber: 1
-      totalMembers: 1
 elasticsearch:
-  typeName: _doc
   collectionIndexMapping:
     _default: indexname
   urls:
     - "http://localhost:9200"
-  batchSizeLimit: 1000
-  batchTickerDuration: 15s
-  batchByteSizeLimit: 1000
 checkpoint:
   type: manual
diff --git a/example/go.mod b/example/go.mod
@@ -7,7 +7,7 @@ replace github.com/Trendyol/go-elasticsearch-connect-couchbase => ../.
 require github.com/Trendyol/go-elasticsearch-connect-couchbase v0.0.0
 
 require (
-	github.com/Trendyol/go-dcp-client v0.0.45 // indirect
+	github.com/Trendyol/go-dcp-client v0.0.46 // indirect
 	github.com/VividCortex/ewma v1.2.0 // indirect
 	github.com/andybalholm/brotli v1.0.5 // indirect
 	github.com/ansrivas/fiberprometheus/v2 v2.6.0 // indirect

diff --git a/example/go.sum b/example/go.sum
@@ -31,14 +31,11 @@ cloud.google.com/go/storage v1.6.0/go.mod h1:N7U0C8pVQ/+NIKOBQyamJIeKQKkZ+mxpohl
 cloud.google.com/go/storage v1.8.0/go.mod h1:Wv1Oy7z6Yz3DshWRJFhqM/UCfaWIRTdp0RXyy7KQOVs=
 cloud.google.com/go/storage v1.10.0/go.mod h1:FLPqc6j+Ki4BU591ie1oL6qBQGu2Bl/tZ9ullr3+Kg0=
 dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
-github.com/Azure/go-ansiterm v0.0.0-20210617225240-d185dfc1b5a1 h1:UQHMgLO+TxOElx5B5HZ4hJQsoJ/PvUvKRhJHDQXO8P8=
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
-github.com/Microsoft/go-winio v0.5.2 h1:a9IhgEQBCUEk6QCdml9CiJGhAws+YwffDHEMp1VMrpA=
-github.com/Microsoft/hcsshim v0.9.4 h1:mnUj0ivWy6UzbB1uLFqKR6F+ZyiDc7j4iGgHTpO+5+I=
 github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
-github.com/Trendyol/go-dcp-client v0.0.45 h1:bmkgxyNyYfEdy3RdYMk1hv7oNFPlFGC5+edq6aFwpo4=
-github.com/Trendyol/go-dcp-client v0.0.45/go.mod h1:wz/TaBdcWlQ0Vs2AsGMD7Tf4niDhpc309v2DAVQ/dnQ=
+github.com/Trendyol/go-dcp-client v0.0.46 h1:1fBc2OYS4UIZPREdk8X0ouRe/3lCFT3ZFYNd3pdBfNk=
+github.com/Trendyol/go-dcp-client v0.0.46/go.mod h1:wz/TaBdcWlQ0Vs2AsGMD7Tf4niDhpc309v2DAVQ/dnQ=
 github.com/VividCortex/ewma v1.2.0 h1:f58SaIzcDXrSy3kWaHNvuJgJ3Nmz59Zji6XoJR/q1ow=
 github.com/VividCortex/ewma v1.2.0/go.mod h1:nz4BbCtbLyFDeC9SUHbtcT5644juEuWfUAUnGx7j5l4=
 github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
@@ -59,7 +56,6 @@ github.com/beorn7/perks v1.0.0/go.mod h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+Ce
 github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=
 github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=
 github.com/buger/jsonparser v1.1.1/go.mod h1:6RYKKt7H4d4+iWqouImQ9R2FZql3VbhNgx27UK13J/0=
-github.com/cenkalti/backoff/v4 v4.1.3 h1:cFAlzYUlVYDysBEH2T5hyJZMh3+5+WCBvSnK6Q8UtC4=
 github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
 github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc=
 github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
@@ -73,8 +69,6 @@ github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDk
 github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
 github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
 github.com/cncf/xds/go v0.0.0-20210312221358-fbca930ec8ed/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs=
-github.com/containerd/cgroups v1.0.4 h1:jN/mbWBEaz+T1pi5OFtnkQ+8qnmEbAr1Oo1FRm5B0dA=
-github.com/containerd/containerd v1.6.8 h1:h4dOFDwzHmqFEP754PgfgTeVXFnLiRc6kiqC7tplDJs=
 github.com/couchbase/gocbcore/v10 v10.2.3-0.20230404070112-cab6da1895ae h1:16BDUoyAqRzv4UGmUJarXOtmup2FdTzFHAk6rrhIfFE=
 github.com/couchbase/gocbcore/v10 v10.2.3-0.20230404070112-cab6da1895ae/go.mod h1:lYQIIk+tzoMcwtwU5GzPbDdqEkwkH3isI2rkSpfL0oM=
 github.com/couchbaselabs/gocaves/client v0.0.0-20230307083111-cc3960c624b1 h1:H7OK4q4WsDxqNIB/Ba8BQBXBHFilZnyItHrLr3qmsKA=
@@ -83,10 +77,6 @@ github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ3
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/docker/distribution v2.8.1+incompatible h1:Q50tZOPR6T/hjNsyc9g8/syEs6bk8XXApsHjKukMl68=
-github.com/docker/docker v20.10.17+incompatible h1:JYCuMrWaVNophQTOrMMoSwudOVEfcegoZZrleKc1xwE=
-github.com/docker/go-connections v0.4.0 h1:El9xVISelRB7BuFusrZozjnkIM5YnzCViNKohAFqRJQ=
-github.com/docker/go-units v0.5.0 h1:69rxXcBk27SvSaaxTtLh/8llcHD8vYHT7WSdRZ/jvr4=
 github.com/docopt/docopt-go v0.0.0-20180111231733-ee0de3bc6815/go.mod h1:WwZ+bS3ebgob9U8Nd0kOddGdZWjyMGR8Wziv+TBNwSE=
 github.com/elastic/go-elasticsearch/v7 v7.17.7 h1:pcYNfITNPusl+cLwLN6OLmVT+F73Els0nbaWOmYachs=
 github.com/elastic/go-elasticsearch/v7 v7.17.7/go.mod h1:OJ4wdbtDNk5g503kvlHLyErCgQwwzmDtaFC4XyOxXA4=
@@ -247,7 +237,6 @@ github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/leodido/go-urn v1.2.0 h1:hpXL4XnriNwQ/ABnpepYM/1vCLWNDfUNts8dX3xTG6Y=
-github.com/magiconair/properties v1.8.6 h1:5ibWZ6iY0NctNGWo87LalDlEZ6R41TqbbDamhfG/Qzo=
 github.com/mailru/easyjson v0.7.7 h1:UGYAvKxe3sBsEDzO8ZeWOSlIQfWFlxbzLZe7hwFURr0=
 github.com/mailru/easyjson v0.7.7/go.mod h1:xzfreul335JAWq5oZzymOObrkdz5UnU4kGfJJLY9Nlc=
 github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA=
@@ -263,26 +252,19 @@ github.com/matttproud/golang_protobuf_extensions v1.0.4 h1:mmDVorXM7PCGKw94cs5zk
 github.com/matttproud/golang_protobuf_extensions v1.0.4/go.mod h1:BSXmuO+STAnVfrANrmjBb36TMTDstsz7MSK+HVaYKv4=
 github.com/mitchellh/mapstructure v1.5.0 h1:jeMsZIYE/09sWLaz43PL7Gy6RuMjD2eJVyuac5Z2hdY=
 github.com/mitchellh/mapstructure v1.5.0/go.mod h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo=
-github.com/moby/sys/mount v0.3.3 h1:fX1SVkXFJ47XWDoeFW4Sq7PdQJnV2QIDZAqjNqgEjUs=
-github.com/moby/sys/mountinfo v0.6.2 h1:BzJjoreD5BMFNmD9Rus6gdd1pLuecOFPt8wC+Vygl78=
-github.com/moby/term v0.0.0-20210619224110-3f7ff695adc6 h1:dcztxKSvZ4Id8iPpHERQBbIJfabdt4wUm5qy3wOL2Zc=
 github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
 github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg=
 github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
 github.com/modern-go/reflect2 v0.0.0-20180701023420-4b7aa43c6742/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
 github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
 github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M=
 github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
-github.com/morikuni/aec v1.0.0 h1:nP9CBfwrvYnBRgY6qfDQkygYDmYwOilePFkwzv4dU8A=
 github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA=
 github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ=
 github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
 github.com/mwitkow/go-conntrack v0.0.0-20190716064945-2f068394615f/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
 github.com/onsi/ginkgo/v2 v2.4.0 h1:+Ig9nvqgS5OBSACXNk15PLdp0U9XPYROt9CFzVdFGIs=
 github.com/onsi/gomega v1.23.0 h1:/oxKu9c2HVap+F3PfKort2Hw5DEU+HGlW8n+tguWsys=
-github.com/opencontainers/go-digest v1.0.0 h1:apOUWs51W5PlhuyGyz9FCeeBIOUDA/6nW8Oi/yOhh5U=
-github.com/opencontainers/image-spec v1.0.3-0.20211202183452-c5a74bcca799 h1:rc3tiVYb5z54aKaDfakKn0dDjIyPpTtszkjuMzyt7ec=
-github.com/opencontainers/runc v1.1.3 h1:vIXrkId+0/J2Ymu2m7VjGvbSlAId9XNRPhn2p4b+d8w=
 github.com/philhofer/fwd v1.1.1/go.mod h1:gk3iGcWd9+svBvR0sR+KPcfE+RNWozjowpeBVG3ZVNU=
 github.com/philhofer/fwd v1.1.2 h1:bnDivRJ1EWPjUIRXV5KfORO897HTbpFAQddBdE8t7Gw=
 github.com/philhofer/fwd v1.1.2/go.mod h1:qkPdfjR2SIEbspLqpe1tO4n5yICnr2DY7mqEx2tUTP0=
@@ -333,7 +315,6 @@ github.com/savsgio/gotils v0.0.0-20230208104028-c358bd845dee/go.mod h1:qwtSXrKuJ
 github.com/sirupsen/logrus v1.2.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo=
 github.com/sirupsen/logrus v1.4.2/go.mod h1:tLMulIdttU9McNUspp0xgXVQah82FyeX6MwdIuYE2rE=
 github.com/sirupsen/logrus v1.6.0/go.mod h1:7uNnSEd1DgxDLC74fIahvMZmmYsHGZGEOFrfsX/uA88=
-github.com/sirupsen/logrus v1.8.1 h1:dJKuHgqk1NNQlqoA6BTlM1Wf9DOH3NBjQyu0h9+AZZE=
 github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
 github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
 github.com/stoewer/go-strcase v1.2.0/go.mod h1:IBiWB2sKIp3wVVQ3Y035++gc+knqhUQag1KpM8ahLw8=
@@ -351,7 +332,6 @@ github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO
 github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
 github.com/stretchr/testify v1.8.2 h1:+h33VjcLVPDHtOdpUCuF+7gSuG3yGIftsP1YvFihtJ8=
 github.com/stretchr/testify v1.8.2/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
-github.com/testcontainers/testcontainers-go v0.14.0 h1:h0D5GaYG9mhOWr2qHdEKDXpkce/VlvaYOCzTRi6UBi8=
 github.com/tinylib/msgp v1.1.6/go.mod h1:75BAfg2hauQhs3qedfdDZmWAPcFMAvJE5b9rGOMufyw=
 github.com/tinylib/msgp v1.1.8 h1:FCXC1xanKO4I8plpHGH2P7koL/RzZs12l/+r7vakfm0=
 github.com/tinylib/msgp v1.1.8/go.mod h1:qkpG+2ldGg4xRFmx+jfTvZPxfGFhi64BcnL9vkCm/Tw=
@@ -378,7 +358,6 @@ go.opencensus.io v0.22.0/go.mod h1:+kGneAE2xo2IficOXnaByMWTGM9T73dGwxeWcUqIpI8=
 go.opencensus.io v0.22.2/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
 go.opencensus.io v0.22.3/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
 go.opencensus.io v0.22.4/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
-go.opencensus.io v0.23.0 h1:gqCw0LfLxScz8irSi8exQc7fyQ0fKQU/qnC/X8+V/1M=
 go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI=
 golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
@@ -661,7 +640,6 @@ google.golang.org/genproto v0.0.0-20200729003335-053ba62fc06f/go.mod h1:FWY/as6D
 google.golang.org/genproto v0.0.0-20200804131852-c06518451d9c/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
 google.golang.org/genproto v0.0.0-20200825200019-8632dd797987/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no=
 google.golang.org/genproto v0.0.0-20220107163113-42d7afdf6368/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc=
-google.golang.org/genproto v0.0.0-20220617124728-180714bec0ad h1:kqrS+lhvaMHCxul6sKQvKJ8nAAhlVItmZV822hYFH/U=
 google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
 google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38=
 google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM=
@@ -677,7 +655,6 @@ google.golang.org/grpc v1.31.0/go.mod h1:N36X2cJ7JwdamYAgDz+s+rVMFjt3numwzf/HckM
 google.golang.org/grpc v1.33.1/go.mod h1:fr5YgcSWrqhRRxogOsw7RzIpsmvOZ6IcH4kBYTpR3n0=
 google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU=
 google.golang.org/grpc v1.40.0/go.mod h1:ogyxbiOoUXAkP+4+xa6PZSE9DZgIHtSpzjDTB9KAK34=
-google.golang.org/grpc v1.47.0 h1:9n77onPX5F3qfFCqjy9dhn8PbNQsIKeVU04J9G7umt8=
 google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
 google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
 google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM=

diff --git a/go.mod b/go.mod
@@ -3,15 +3,15 @@ module github.com/Trendyol/go-elasticsearch-connect-couchbase
 go 1.20
 
 require (
-	github.com/Trendyol/go-dcp-client v0.0.45
-	github.com/VividCortex/ewma v1.2.0
+	github.com/Trendyol/go-dcp-client v0.0.46
 	github.com/elastic/go-elasticsearch/v7 v7.17.7
 	github.com/gookit/config/v2 v2.2.1
 	github.com/prometheus/client_golang v1.14.0
 	github.com/valyala/fasthttp v1.45.0
 )
 
 require (
+	github.com/VividCortex/ewma v1.2.0 // indirect
 	github.com/andybalholm/brotli v1.0.5 // indirect
 	github.com/ansrivas/fiberprometheus/v2 v2.6.0 // indirect
 	github.com/avast/retry-go/v4 v4.3.3 // indirect