jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(integrations): elasticsearch use apiKey

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-01-27 21:12:04 +01:00
parent 62d46df992
commit f60d1d02e2
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
backend/services/integrations/integration/elasticsearch.go
View file

@ -43,14 +43,14 @@ type elasticResponce struct {
func (es *elasticsearch) Request(c *client) error {
address := es.Host + ":" + es.Port.String()
api_key:=b64.StdEncoding.EncodeToString([]byte(es.ApiKeyId + ":" + es.ApiKey))
apiKey := b64.StdEncoding.EncodeToString([]byte(es.ApiKeyId + ":" + es.ApiKey))
cfg := elasticlib.Config{
Addresses: []string{
address,
},
Username: es.ApiKeyId,
Password: es.ApiKey,
//APIKey: b64.StdEncoding.EncodeToString([]byte(es.ApiKeyId + ":" + es.ApiKey)),
//Username: es.ApiKeyId,
//Password: es.ApiKey,
APIKey: apiKey,
}
log.Print("creating new ES client\n")
esC, err := elasticlib.NewClient(cfg)
@ -59,7 +59,7 @@ func (es *elasticsearch) Request(c *client) error {
return err
}
log.Printf("ES client created using User name and password")
log.Printf(api_key)
log.Printf(apiKey)
// TODO: ping/versions/ client host check
// res0, err := esC.Info()
// if err != nil {