jobs

package
v0.0.0-...-a5c5f28 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 22, 2019 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 1 more Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Jobs

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

Jobs Handle multiple jobs enqueuing in buffered channel

func (*Jobs) Close

func (jobs *Jobs) Close()

Close close job channel

func (*Jobs) Get

func (jobs *Jobs) Get() (interface{}, error)

Get gets a job from the buffered channel if error is returned Close() function have been called

func (*Jobs) Len

func (jobs *Jobs) Len() int

Len Gets the length of jobs to do

func (*Jobs) Open

func (jobs *Jobs) Open()

Open creates jobs channel

func (*Jobs) Put

func (jobs *Jobs) Put(job interface{})

Put send job to channel

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL