gojob

README

gojob

Job manager in Golang

Documentation

Index

• func Close()
• func Go(task Task, values context.Context, onError OnError)
• func Wait()
• type Job
• type Manager
  • func NewManager(maxWorkers int64) *Manager
  • func (m *Manager) Close()
  • func (m *Manager) Go(task Task, values context.Context, onError OnError)
  • func (m *Manager) Wait()
• type OnError
• type Task
• type TaskID

Functions

func Close

func Close()

func Go

func Go(task Task, values context.Context, onError OnError)

func Wait

func Wait()

Types

type Job

type Job struct {
}

type Manager

type Manager struct {
	sync.WaitGroup
	context.Context
	sync.Map
	// contains filtered or unexported fields
}

var (
	DefaultManager *Manager
)

func NewManager

func NewManager(maxWorkers int64) *Manager

func (*Manager) Close

func (m *Manager) Close()

func (*Manager) Go

func (m *Manager) Go(task Task, values context.Context, onError OnError)

func (*Manager) Wait

func (m *Manager) Wait()

type OnError

type OnError func(error)

type Task

type Task func(ctx context.Context, id TaskID) error

type TaskID

type TaskID = int32