Function openWithBasicAuth

backend/plugin/db/elasticsearch/elasticsearch.go:140–188

(_ context.Context, config db.ConnectionConfig, address string)

}

func openWithBasicAuth(_ context.Context, config db.ConnectionConfig, address string) (db.Driver, error) {
	// Get TLS config that respects verify_tls_certificate setting
	tlsConfig, err := util.GetTLSConfig(config.DataSource)
	if err != nil {
		return nil, errors.Wrap(err, "failed to get TLS config")
	}

	// Default to insecure if no SSL is configured
	if tlsConfig == nil {
		tlsConfig = &tls.Config{
			MinVersion:         tls.VersionTLS12,
			InsecureSkipVerify: true,
		}
	} else {
		// Ensure minimum TLS version
		tlsConfig.MinVersion = tls.VersionTLS12
	}

	esConfig := newElasticsearchConfig(config, address, tlsConfig)
	// default http client.
	httpClient := &http.Client{
		Transport: &http.Transport{
			TLSClientConfig: tlsConfig,
		},
	}

	// typed elasticsearch client.
	typedClient, err := elasticsearch.NewClient(esConfig)
	if err != nil {
		return nil, errors.Wrapf(err, "failed to create elasticsearch client")
	}

	// generate basic authentication string for http client.
	encodedUsrAndPasswd := base64.StdEncoding.EncodeToString([]byte(fmt.Sprintf("%s:%s", config.DataSource.Username, config.Password)))
	basicAuthString := fmt.Sprintf("Basic %s", string(encodedUsrAndPasswd))

	return &Driver{
		typedClient: typedClient,
		basicAuthClient: &BasicAuthClient{
			httpClient: httpClient,
			addrScheduler: &AddressScheduler{
				addresses: []string{address},
				count:     0,
			},
			basicAuthString: basicAuthString,
		},
		config: config,
	}, nil
}

func newElasticsearchConfig(config db.ConnectionConfig, address string, tlsConfig *tls.Config) elasticsearch.Config {
	esConfig := elasticsearch.Config{