A golang package to help queue up, consume entries from a pipeline, return results and stop consuming as required.
Rather that check every minute for completed queue items to check pruning,
we should also allow the called to set a prune "every" value. Eg prune every
hour (5 mins is the default) and only prune items older than 10 mins (1 hour
is the default)