createElasticClient.go

createElasticClient.go

/**
* Create an elasticearch instance
**/
package main

import (
	"crypto/tls"
	"log"
	"net/http"

	"github.com/olivere/elastic/v7"
	"github.com/spf13/viper"
)

func createElasticClient() *elastic.Client {
	client, err := elastic.NewClient(
		elastic.SetURL(viper.GetString("ELASTIC_ENDPOINT")),
		elastic.SetBasicAuth(
			viper.GetString("ELASTIC_USER"),
			viper.GetString("ELASTIC_PASSWORD"),
		),
		elastic.SetHttpClient(&http.Client{
			Transport: &http.Transport{
				TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
			},
		}),
		elastic.SetSniff(false),
	)
	if err != nil {
		log.Fatalf("Error creating client: %v", err)
	}
	return client
}