MCPcopy
hub / github.com/elastic/go-elasticsearch / WithTimeout

Method WithTimeout

esapi/api.bulk.go:328–332  ·  view source on GitHub ↗

WithTimeout - explicit operation timeout.

(v time.Duration)

Source from the content-addressed store, hash-verified

326
327// WithTimeout - explicit operation timeout.
328func (f Bulk) WithTimeout(v time.Duration) func(*BulkRequest) {
329 return func(r *BulkRequest) {
330 r.Timeout = v
331 }
332}
333
334// WithWaitForActiveShards - sets the number of shard copies that must be active before proceeding with the bulk operation. defaults to 1, meaning the primary shard only. set to `all` for all shard copies, otherwise set to any non-negative value less than or equal to the total number of copies for the shard (number of replicas + 1).
335func (f Bulk) WithWaitForActiveShards(v string) func(*BulkRequest) {

Callers 15

TestCloseFunction · 0.45
BenchmarkClientAPIFunction · 0.45
mainFunction · 0.45
mainFunction · 0.45
mainFunction · 0.45
mainFunction · 0.45
index.goFile · 0.45
server.goFile · 0.45
search.goFile · 0.45
mainFunction · 0.45
mainFunction · 0.45
mainFunction · 0.45

Calls

no outgoing calls

Tested by 9

TestCloseFunction · 0.36
BenchmarkClientAPIFunction · 0.36
TestBulkIndexerFunction · 0.36
TestBulkIndexerFlushFunction · 0.36
ExampleNewBulkIndexerFunction · 0.36
ExampleBulkIndexer_FlushFunction · 0.36
BenchmarkAPIFunction · 0.36
TestAPIFunction · 0.36