Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Runner ¶
type Runner struct {
// contains filtered or unexported fields
}
Runner provides streaming operations on badger.DB.
func (*Runner) Process ¶
func (r *Runner) Process(ctx context.Context, process Process, errs chan<- error) (*sync.WaitGroup, error)
Process runs process on each Value in the database. process must be thread-safe as it may be called simultaneously by multiple threads.
Returns a WaitGroup which finishes after the last Value from the DB has been processed.
func (*Runner) ProcessIDs ¶
func (r *Runner) ProcessIDs(ctx context.Context, process Process, ids <-chan uint32, errs chan<- error) (*sync.WaitGroup, error)
ProcessIDs runs process on each id's corresponding value. process must be thread-safe as it may be called simultaneously by multiple threads.
Returns a WaitGroup which finishes after the last id has been processed.
Source Files
Click to show internal directories.
Click to hide internal directories.