转到弹性客户端：必须等待一段时间才能运行查询

Question

I use olivere elastic library to connect to elastic. So I have one client, connect with it, add a few documents. Then I have another client that make search. But I have to wait about seconds cause immediate response is empty

_, err := client.Index().
    Index(elasticTemplateName).
    Type(elasticType).
    Id(myID).
    BodyJson(myJson).
    Do(ctx)
require.NoError(t, err)

// wait cause of async elastic client
time.Sleep(1000 * time.Millisecond)

result, err := anotherClient.Search().Index(IndexName).SearchSource(searchSource).Do(ctx)

another client:

client, err := elastic.NewClient(
    elastic.SetURL(
        conf.Hosts...
    ),
    elastic.SetSniff(false),
)

Answer 1

You probably want to use the Refresh API see https://github.com/olivere/elastic/blob/release-branch.v6/indices_refresh.go

The insertion is real time but the indexes that the get uses are not