worker

Documentation

Index

• func ErrorLogger(err error)
• type Worker
  • func NewWorker(ctx context.Context, d time.Duration, fn func() error, eh func(err error)) *Worker
  • func (w *Worker) Run()

Functions

func ErrorLogger

func ErrorLogger(err error)

ErrorLogger function defines a callback for handling errors

Types

type Worker

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

Worker struct

func NewWorker

func NewWorker(ctx context.Context, d time.Duration, fn func() error, eh func(err error)) *Worker

NewWorker creates a new Worker structure

func (*Worker) Run

func (w *Worker) Run()

Run starts the handling loop