worker

Documentation

Index

• Variables
• func SetLogger(l *zap.SugaredLogger)
• type Ticker
  • func NewTicker(l Workload, i time.Duration) *Ticker
  • func (w *Ticker) Start()
  • func (w *Ticker) Stop()
• type Workload

Variables

var ErrShutdown = errors.New("worker shut down")

var FatalError = errors.New("workload error")

Functions

func SetLogger

func SetLogger(l *zap.SugaredLogger)

Types

type Ticker

type Ticker struct {
	Interval time.Duration
	// contains filtered or unexported fields
}

func NewTicker

func NewTicker(l Workload, i time.Duration) *Ticker

func (*Ticker) Start

func (w *Ticker) Start()

func (*Ticker) Stop

func (w *Ticker) Stop()

type Workload

type Workload interface {
	Process() error
	Shutdown()
	IsShutdown() bool
}