task

Documentation

Index

• type Runner
• type TickerTask
  • func NewTickerTask(interval time.Duration, runner Runner) *TickerTask
  • func NewTickerTaskFromFunc(interval time.Duration, runner func() error) *TickerTask
  • func (t *TickerTask) Start()
  • func (t *TickerTask) Stop()

Types

type Runner

type Runner interface {
	Run() error
}

type TickerTask

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

func NewTickerTask

func NewTickerTask(interval time.Duration, runner Runner) *TickerTask

func NewTickerTaskFromFunc

func NewTickerTaskFromFunc(interval time.Duration, runner func() error) *TickerTask

func (*TickerTask) Start

func (t *TickerTask) Start()

Start runs the task immediately and then schedules the task to run periodically if a positive fetching interval has been specified.

func (*TickerTask) Stop

func (t *TickerTask) Stop()

Stop stops the periodic task but the task runner maintains state