feat: add username and password to es client

Trendyol · Aug 8, 2024 · 07765c0 · 07765c0
1 parent c4d9830
commit 07765c0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/config/config.go b/config/config.go
@@ -9,6 +9,8 @@ import (
 )
 
 type Elasticsearch struct {
+    Username                    string            `yaml:"username"`
+	Password                    string            `yaml:"password"`
 	BatchByteSizeLimit          any               `yaml:"batchByteSizeLimit"`
 	CollectionIndexMapping      map[string]string `yaml:"collectionIndexMapping"`
 	MaxConnsPerHost             *int              `yaml:"maxConnsPerHost"`

diff --git a/elasticsearch/client/client.go b/elasticsearch/client/client.go
@@ -12,6 +12,8 @@ import (
 
 func NewElasticClient(config *config.Config) (*elasticsearch.Client, error) {
 	es, err := elasticsearch.NewClient(elasticsearch.Config{
+		Username:              config.Elasticsearch.Username,
+		Password:              config.Elasticsearch.Password,
 		MaxRetries:            math.MaxInt,
 		Addresses:             config.Elasticsearch.Urls,
 		Transport:             newTransport(config.Elasticsearch),