elastic-issue-107-2.go

elastic-issue-107-2.go

package main

import (
	"fmt"
	"log"
	"sync"

	elastic "gopkg.in/olivere/elastic.v2"
)

var (
	clientInit sync.Once
	client     *elastic.Client
)

func Client() *elastic.Client {
	clientInit.Do(func() {
		c, err := elastic.NewClient()
		if err != nil {
			panic(err)
		}
		client = c
	})
	return client
}

func main() {
	var i int64
	for {
		_, _, err := Client().Ping().URL("http://127.0.0.1:9200").Do()
		if err != nil {
			log.Fatal(err)
		}
		i++
		fmt.Printf("%8d\r", i)
	}
}