taskmanager

Documentation

Index

• func StartWithGracefulShutdown(c context.Context, tm TaskManager) error
• type IntervalExecutor
• type Task
  • func IntervalExecutorTask(executor IntervalExecutor, initialDelay time.Duration) Task
  • func NewTask(name string, start func(c context.Context, sigCh <-chan os.Signal) error) Task
• type TaskManager
  • func NewChainedTaskManager() TaskManager

Functions

func StartWithGracefulShutdown

func StartWithGracefulShutdown(c context.Context, tm TaskManager) error

Types

type IntervalExecutor

type IntervalExecutor interface {
	Name() string
	Execute(context.Context) (time.Duration, error)
	Close(context.Context) error
}

type Task

type Task interface {
	Name() string
	Start(c context.Context, sigCh <-chan os.Signal) error
}

func IntervalExecutorTask

func IntervalExecutorTask(executor IntervalExecutor, initialDelay time.Duration) Task

func NewTask

func NewTask(name string, start func(c context.Context, sigCh <-chan os.Signal) error) Task

type TaskManager

type TaskManager interface {
	Start(c context.Context, sigCh <-chan os.Signal) error
	WithTask(Task) TaskManager
}

func NewChainedTaskManager

func NewChainedTaskManager() TaskManager