parallel

Documentation

Index

• type WorkQueue
  • func NewWorkQueue(qps int, burst int) *WorkQueue
  • func (c *WorkQueue) Add(do func() error) <-chan error

Types

type WorkQueue

type WorkQueue struct {
	workqueue.RateLimitingInterface
	// contains filtered or unexported fields
}

WorkQueue is a thread safe task runner

func NewWorkQueue

func NewWorkQueue(qps int, burst int) *WorkQueue

NewWorkQueue instantiates a new WorkQueue

func (*WorkQueue) Add

func (c *WorkQueue) Add(do func() error) <-chan error

Add work to the queue, returns a channel that signals when the work is done.