Function main

_examples/security/tls_with_ca.go:33–78

()

)

func main() {
	log.SetFlags(0)

	var (
		err error

		// --> Configure the path to the certificate authority and the password
		//
		cacert   = flag.String("cacert", "certificates/ca/ca.crt", "Path to the file with certificate authority")
		password = flag.String("password", "elastic", "Elasticsearch password")
	)
	flag.Parse()

	// --> Read the certificate from file
	//
	cert, err := ioutil.ReadFile(*cacert)
	if err != nil {
		log.Fatalf("ERROR: Unable to read CA from %q: %s", *cacert, err)
	}

	es, err := elasticsearch.New(
		elasticsearch.WithAddresses("https://localhost:9200"),
		elasticsearch.WithBasicAuth("elastic", *password),
		// --> Pass the certificate to the client
		//
		elasticsearch.WithCACert(cert),
	)
	if err != nil {
		log.Fatalf("ERROR: Unable to create client: %s", err)
	}
	defer func() {
		ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
		defer cancel()
		if err := es.Close(ctx); err != nil {
			log.Fatalf("Error closing the client: %s\n", err)
		}
	}()

	res, err := es.Info()
	if err != nil {
		log.Fatalf("ERROR: Unable to get response: %s", err)
	}
	defer res.Body.Close()

	log.Println(res)
}