joule

README

joule

Getting Started

From example/main.go:

workerFn := func(payload interface{}) error {
    v := payload.(int)
    log.Printf("%d * 2 = %d\n", v, v*2)

    // Fake some work.
    time.Sleep(time.Second * time.Duration(rand.Intn(3)))

    return nil
}

pool := joule.NewPool(workerFn, nil, 0, 0)
pool.Start(2)

for i := 1; i <= 10; i++ {
    pool.Enqueue(i)
}

pool.Stop()

Documentation

Index

• type ErrorFunc
• type Pool
  • func NewPool(workerFn WorkerFunc, errorFn ErrorFunc, nRetries, retryDelay int) *Pool
  • func (p *Pool) Enqueue(payload interface{})
  • func (p *Pool) Start(nWorkers int)
  • func (p *Pool) Stop()
• type WorkerFunc

Types

type ErrorFunc

type ErrorFunc func(payload interface{}, err error)

type Pool

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

func NewPool

func NewPool(workerFn WorkerFunc, errorFn ErrorFunc, nRetries, retryDelay int) *Pool

func (*Pool) Enqueue

func (p *Pool) Enqueue(payload interface{})

func (*Pool) Start

func (p *Pool) Start(nWorkers int)

func (*Pool) Stop

func (p *Pool) Stop()

type WorkerFunc

type WorkerFunc func(payload interface{}) error