// create index { // delete index if exists if existsRes, err := es.Indices.Exists("test").IsSuccess(context.Background()); err != nil { log.Println(err) return } else if existsRes { if ok, _ := es.Indices.Delete("test").IsSuccess(context.Background()); !ok { log.Fatalf("Error deleting index: %v\n", err) } log.Println("Index deleted:", "test") } else { log.Println("Index does not exist:", "test") } mappings := esdsl.NewTypeMapping(). AddProperty("name", esdsl.NewTextProperty()). AddProperty("age", esdsl.NewIntegerNumberProperty()) createRes, err := es.Indices.Create("test").Mappings(mappings).Do(context.Background()) if err != nil { log.Println(err) return } log.Printf("Index created: %#v\n", createRes) } // index document { documents := []Document{ {"Alice", 30}, {"Bob", 25}, {"Charlie", 35}, } bulk := es.Bulk().Index("test") for _, document := range documents { err := bulk.IndexOp(types.IndexOperation{}, document) if err != nil { log.Println("Error indexing document:", err) } } bulkRes, err := bulk.Refresh(refresh.Waitfor).Do(context.Background()) if err != nil { log.Println(err) return } if bulkRes.Errors { log.Println("Some documents failed to index") for _, item := range bulkRes.Items { for operationType, responseItem := range item { if responseItem.Error != nil { log.Println("Operation:", operationType) log.Println("Response:", responseItem) } } } } indexedDocs := 0 for _, item := range bulkRes.Items { for _, responseItem := range item { if responseItem.Error == nil { indexedDocs++ } } } log.Println("Documents indexed:", indexedDocs) } // calculate median age { searchRes, err := es.Search(). Index("test"). Size(0). AddAggregation("median_age", esdsl.NewPercentilesAggregation().Field("age").Percents(50)). Do(context.Background()) if err != nil { log.Println(err) return } if agg, ok := searchRes.Aggregations["median_age"].(*types.TDigestPercentilesAggregate); ok { if val, ok := agg.Values.(map[string]interface{})["50.0"]; ok { log.Println("Median age:", val) } } } // search documents { matchRes, err := es.Search(). Index("test"). Query(esdsl.NewBoolQuery(). Must(esdsl.NewMatchQuery("name", "Alice")). Filter(esdsl.NewNumberRangeQuery("age").Gte(20).Lte(40))). Sort(esdsl.NewSortOptions().AddSortOption("age", esdsl.NewFieldSort(sortorder.Asc))). Size(10). Do(context.Background()) if err != nil { log.Println(err) return } if matchRes.Hits.Total.Value > 0 { for _, hit := range matchRes.Hits.Hits { doc := Document{} err := json.Unmarshal(hit.Source_, &doc) if err != nil { log.Println("Error unmarshalling document:", err) continue } log.Printf("Document ID: %s, Name: %s, Age: %d\n", *hit.Id_, doc.Name, doc.Age) } } else { log.Println("No documents found") } }

baseClient, err := elasticsearch.NewBaseClient(elasticsearch.Config{ Addresses: []string{ "http://localhost:9200", }, }) if err != nil { log.Println(err) return } res, err := esapi.InfoRequest{ Pretty: false, Human: false, ErrorTrace: false, FilterPath: nil, Header: nil, Instrument: baseClient.InstrumentationEnabled(), }.Do(context.Background(), baseClient) if err != nil { log.Println(err) return } defer res.Body.Close() if res.IsError() { log.Println("Error response:", res) return } var infoMap map[string]interface{} if err := json.NewDecoder(res.Body).Decode(&infoMap); err != nil { log.Println("Error parsing response:", err) return } log.Printf("Elasticsearch version esapi: %s\n", infoMap["version"].(map[string]interface{})["number"]) typedRes, err := info.New(baseClient).Do(context.Background()) if err != nil { log.Println(err) return } log.Printf("Elasticsearch version typedapi: %s\n", typedRes.Version.Int)