mattbaird/elastigo

bulkindexer: get insights into how many docs are pending to be flushed

Opened this issue · 3 comments

I want to track how many items are pending to be flushed.
should be doable but with a simple len() on the channel, except that it's a private property, so it needs a wrapper function

can you submit a PR?

also, don't you want the value of docCt in bulk.go? or would you rather have the len of bulkChannel?

i'm not sure TBH. i was looking at the code and couldn't figure out how it works.