workqueue

Documentation

Index

• Constants
• type WorkQueue
  • func New(workerCount, maxResults int, rangeMin uint64, rangeMax uint64, ...) *WorkQueue
  • func (ff *WorkQueue) Get(num uint64) er.R

Constants

const DefaultBacklog = 10

const DefaultWorkerCount = 6

Types

type WorkQueue

type WorkQueue struct {
	// contains filtered or unexported fields
}

func New

func New(workerCount,
	maxResults int,
	rangeMin uint64,
	rangeMax uint64,
	job func(key uint64) er.R,
) *WorkQueue

func (*WorkQueue) Get

func (ff *WorkQueue) Get(
	num uint64,
) er.R