parallel

README

Overview

Parallel task management with error management.

Documentation

Index

• type Parallel
  • func New() *Parallel
  • func (parallel *Parallel) Cancel(err error)
  • func (parallel *Parallel) OnData(listener func(task Task)) *Parallel
  • func (parallel *Parallel) OnETA(listener func(current int, total int, eta time.Duration)) *Parallel
  • func (parallel *Parallel) OnFinish(listener func()) *Parallel
  • func (parallel *Parallel) Run(data interface{}, concurrency int) (err error)
• type Task
  • func (p *Task) Cancel(err error)
  • func (p *Task) Data() interface{}
  • func (p *Task) ETA() time.Duration
  • func (p *Task) Finish()
  • func (p *Task) Index() int
  • func (p *Task) Total() int

Types

type Parallel

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

func New

func New() *Parallel

func (*Parallel) Cancel

func (parallel *Parallel) Cancel(err error)

func (*Parallel) OnData

func (parallel *Parallel) OnData(listener func(task Task)) *Parallel

func (*Parallel) OnETA

func (parallel *Parallel) OnETA(listener func(current int, total int, eta time.Duration)) *Parallel

func (*Parallel) OnFinish

func (parallel *Parallel) OnFinish(listener func()) *Parallel

func (*Parallel) Run

func (parallel *Parallel) Run(data interface{}, concurrency int) (err error)

type Task

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

func (*Task) Cancel

func (p *Task) Cancel(err error)

func (*Task) Data

func (p *Task) Data() interface{}

func (*Task) ETA

func (p *Task) ETA() time.Duration

func (*Task) Finish

func (p *Task) Finish()

func (*Task) Index

func (p *Task) Index() int

func (*Task) Total

func (p *Task) Total() int