Предыдущий код при использовании Elastigo
var es = elastigo.NewConn()
var indexer = es.NewBulkIndexer(50)
// Create a custom Sender Func, so that we can check what the error is
indexer.Sender = func(buf *bytes.Buffer) error {
resp, err := c_es.DoCommand("POST", "/_bulk", nil, buf)
if err != nil {
fmt.Println("Error", string(resp))
fmt.Println("Error", err)
}
if err == nil {
fmt.Println("Succeed")
}
return err
}
Я могу изменить какой-то код на olivere, но я не знаю, как изменить остальные.Подключение кasticsearch с использованием Olivere легко.
// Connect to elasticsearch
olivere_es, err = elastic.NewClient(elastic.SetURL("http:144.00.0.34:9400"))
//Replace the code for the var indexer = es.NewBulkIndexer(50)
var oliveIndexer = elastic.NewBulkService(olivere_es)
Но я понятия не имею, как изменить indexer.Sender и indexer.Start ().Кто-нибудь знает, что это за функции?
Спасибо