Function main

_examples/fasthttp/cmd/main.go:52–121

()

}

func main() {
	log.SetFlags(0)

	es, err := elasticsearch.New(
		elasticsearch.WithTransportOptions(elastictransport.WithTransport(&fasthttp.Transport{})),
	)
	if err != nil {
		log.Fatalf("Error creating the client: %s", err)
	}
	defer func() {
		ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
		defer cancel()
		if err := es.Close(ctx); err != nil {
			fmt.Printf("Error closing the client: %s\n", err)
		}
	}()

	// Test sending the body as POST
	//
	ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond)
	defer cancel()

	go func() {
		res, err := es.Search(
			es.Search.WithBody(strings.NewReader(`{"query":{"match":{"title":"foo"}}}`)),
			es.Search.WithPretty(),
		)
		cancel()
		if err != nil {
			log.Fatalf("Error getting response: %s", err)
		}
		defer res.Body.Close()
		if res.IsError() {
			log.Fatalf("Error response: %s", res)
		}
	}()

	select {
	case <-ctx.Done():
		if ctx.Err() != context.Canceled {
			log.Fatalf("Timeout: %s", ctx.Err())
		}
	}

	// Run benchmark
	//
	t := time.Now()
	for i := 0; i < count; i++ {
		t0 := time.Now()
		res, err := es.Info()
		durations = append(durations, time.Now().Sub(t0))
		if err != nil {
			log.Fatalf("Error: %s", err)
		}
		res.Body.Close()
	}

	sorted := append(make([]time.Duration, 0), durations...)