job

package module

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

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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
}