async

Documentation

Index

• type DoWorkFn
• type Worker
  • func NewWorker(fn DoWorkFn) *Worker
  • func (w *Worker) Cancel()
  • func (w *Worker) Done() <-chan struct{}
  • func (w *Worker) Error() error
  • func (w *Worker) Start()

Types

type DoWorkFn

type DoWorkFn func() error

type Worker

type Worker struct {
	Delay time.Duration // Delay between doWork calls
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(fn DoWorkFn) *Worker

func (*Worker) Cancel

func (w *Worker) Cancel()

Cancel stops the worker

func (*Worker) Done

func (w *Worker) Done() <-chan struct{}

Done is closed when the work loop ended

func (*Worker) Error

func (w *Worker) Error() error

func (*Worker) Start

func (w *Worker) Start()

Start starts the worker, does nothing when already running