job

package module

v0.0.0-...-e7d0e91 Latest Latest Go to latest Published: Nov 13, 2014 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func Work(jobs <-chan interface{}, options *Options) <-chan interface{}

type Clock struct {
	C <-chan interface{}
	// contains filtered or unexported fields
}

Clock sends the value given to the Send function after the delay specified in NewClock. Sending another value will restart the timer.

func NewClock(d time.Duration) *Clock

NewClock constructs a new Clock with the given delay. Call Close to stop the clock's goroutine.

func (c *Clock) Close()

Close stops the timer. Close will panic if Close has already been called.

func (c *Clock) Send(v interface{})

Send restarts the timer with the new value. Start will panic if Close has been called.

type Options struct {
	Work       func(interface{}) interface{}
	NumWorkers int // default 1
	MaxWaiting int // default 10
}