(bdp []*BleveDestPartition, bdpMaxSeqNums []uint64, index bleve.Index, batch *bleve.Batch)
| 2522 | } |
| 2523 | |
| 2524 | func executeBatch(bdp []*BleveDestPartition, bdpMaxSeqNums []uint64, |
| 2525 | index bleve.Index, batch *bleve.Batch) { |
| 2526 | _, err := execute(bdp, bdpMaxSeqNums, index, batch) |
| 2527 | if err != nil { |
| 2528 | bdp[0].setLastAsyncBatchErr(err) |
| 2529 | } |
| 2530 | } |
| 2531 | |
| 2532 | func execute(bdp []*BleveDestPartition, bdpMaxSeqNums []uint64, |
| 2533 | bindex bleve.Index, batch *bleve.Batch) (bool, error) { |
no test coverage detected