diff --git a/pkg/es/es5.go b/pkg/es/es5.go index 8e20e92..ac5d404 100644 --- a/pkg/es/es5.go +++ b/pkg/es/es5.go @@ -4,6 +4,7 @@ import ( "bufio" "bytes" "context" + "crypto/tls" "encoding/json" "fmt" "github.com/CharellKing/ela/config" @@ -12,6 +13,7 @@ import ( "github.com/spf13/cast" "io" "log" + "net/http" "strings" "time" @@ -27,10 +29,17 @@ type V5 struct { } func NewESV5(esConfig *config.ESConfig, clusterVersion string) (*V5, error) { + transport := &http.Transport{ + TLSClientConfig: &tls.Config{ + InsecureSkipVerify: true, + }, + } + client, err := elasticsearch5.NewClient(elasticsearch5.Config{ Addresses: esConfig.Addresses, Username: esConfig.User, Password: esConfig.Password, + Transport: transport, }) if err != nil { return nil, errors.WithStack(err) diff --git a/pkg/es/es6.go b/pkg/es/es6.go index 46f7241..00e3465 100644 --- a/pkg/es/es6.go +++ b/pkg/es/es6.go @@ -4,6 +4,7 @@ import ( "bufio" "bytes" "context" + "crypto/tls" "encoding/json" "fmt" "github.com/CharellKing/ela/config" @@ -12,6 +13,7 @@ import ( "github.com/spf13/cast" "io" "log" + "net/http" "strings" "time" @@ -27,11 +29,19 @@ type V6 struct { } func NewESV6(esConfig *config.ESConfig, clusterVersion string) (*V6, error) { + transport := &http.Transport{ + TLSClientConfig: &tls.Config{ + InsecureSkipVerify: true, + }, + } + client, err := elasticsearch6.NewClient(elasticsearch6.Config{ Addresses: esConfig.Addresses, Username: esConfig.User, Password: esConfig.Password, + Transport: transport, }) + if err != nil { return nil, errors.WithStack(err) } diff --git a/pkg/es/es7.go b/pkg/es/es7.go index 69d7ae5..099c95e 100644 --- a/pkg/es/es7.go +++ b/pkg/es/es7.go @@ -4,6 +4,7 @@ import ( "bufio" "bytes" "context" + "crypto/tls" "encoding/json" "fmt" "github.com/CharellKing/ela/config" @@ -12,6 +13,7 @@ import ( "github.com/spf13/cast" "io" "log" + "net/http" "strings" "time" @@ -27,11 +29,19 @@ type V7 struct { } func NewESV7(esConfig *config.ESConfig, clusterVersion string) (*V7, error) { + transport := &http.Transport{ + TLSClientConfig: &tls.Config{ + InsecureSkipVerify: true, + }, + } + client, err := elasticsearch7.NewClient(elasticsearch7.Config{ Addresses: esConfig.Addresses, Username: esConfig.User, Password: esConfig.Password, + Transport: transport, }) + if err != nil { return nil, errors.WithStack(err) } diff --git a/pkg/es/es8.go b/pkg/es/es8.go index 8387d40..ad8992c 100644 --- a/pkg/es/es8.go +++ b/pkg/es/es8.go @@ -4,6 +4,7 @@ import ( "bufio" "bytes" "context" + "crypto/tls" "encoding/json" "fmt" "github.com/CharellKing/ela/config" @@ -12,6 +13,7 @@ import ( "github.com/spf13/cast" "io" "log" + "net/http" "strings" "time" @@ -27,11 +29,19 @@ type V8 struct { } func NewESV8(esConfig *config.ESConfig, clusterVersion string) (*V8, error) { + transport := &http.Transport{ + TLSClientConfig: &tls.Config{ + InsecureSkipVerify: true, + }, + } + client, err := elasticsearch8.NewClient(elasticsearch8.Config{ Addresses: esConfig.Addresses, Username: esConfig.User, Password: esConfig.Password, + Transport: transport, }) + if err != nil { return nil, errors.WithStack(err) }