background

Documentation

Index

• Variables
• type Worker
  • func NewWorker(parent context.Context) *Worker
  • func (b *Worker) Close(ctx context.Context, err error) error
  • func (b *Worker) Context() context.Context
  • func (b *Worker) Done() <-chan struct{}
  • func (b *Worker) Start(name string, f func(ctx context.Context))

Variables

var ErrAlreadyClosed = errors.New("background worker already closed")

Types

type Worker

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

A Worker must not be copied after first use

func NewWorker

func NewWorker(parent context.Context) *Worker

func (*Worker) Close

func (b *Worker) Close(ctx context.Context, err error) error

func (*Worker) Context

func (b *Worker) Context() context.Context

func (*Worker) Done

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

func (*Worker) Start

func (b *Worker) Start(name string, f func(ctx context.Context))