WithTimeout - explicit operation timeout.
(v time.Duration)
| 326 | |
| 327 | // WithTimeout - explicit operation timeout. |
| 328 | func (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). |
| 335 | func (f Bulk) WithWaitForActiveShards(v string) func(*BulkRequest) { |
no outgoing calls