tasks

Documentation

Overview

TODO check pool load on add TODO ignore to frequent progress updates TODO context TODO gracefully stop pool TODO give get status a timeout

Index

• type Hub
  • func NewHub() *Hub
  • func (h *Hub) Add(id string, fn func(Task) error)
  • func (h *Hub) Status(id string) Status
• type Progress
  • func (p Progress) Percent() int
• type State
• type Status
  • func (s Status) Done() bool
  • func (s Status) Failed() bool
  • func (s Status) Running() bool
  • func (s Status) Waiting() bool
• type Task
  • func (t Task) Progress(num int, denom int)

Types

type Hub

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

func NewHub

func NewHub() *Hub

func (*Hub) Add

func (h *Hub) Add(id string, fn func(Task) error)

func (*Hub) Status

func (h *Hub) Status(id string) Status

type Progress

type Progress struct {
	Numerator, Denominator int
}

func (Progress) Percent

func (p Progress) Percent() int

type State

type State int

const (
	Waiting State = iota
	Running
	Done
	Failed
)

type Status

type Status struct {
	State     State
	Progress  Progress
	Error     error
	StartTime time.Time
	EndTime   time.Time
}

func (Status) Done

func (s Status) Done() bool

func (Status) Failed

func (s Status) Failed() bool

func (Status) Running

func (s Status) Running() bool

func (Status) Waiting

func (s Status) Waiting() bool

type Task

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

func (Task) Progress

func (t Task) Progress(num int, denom int)