schedule

Documentation

Index

• type Option
  • func WithCaption(value string) Option
  • func WithTasks(values ...mrworker.Task) Option
• type TaskScheduler
  • func NewTaskScheduler(errorHandler mrcore.ErrorHandler, opts ...Option) *TaskScheduler
  • func (s *TaskScheduler) Caption() string
  • func (s *TaskScheduler) ReadyTimeout() time.Duration
  • func (s *TaskScheduler) Shutdown(ctx context.Context) error
  • func (s *TaskScheduler) Start(ctx context.Context, ready func()) error

Types

type Option

type Option func(s *TaskScheduler)

Option - настройка объекта TaskScheduler.

func WithCaption

func WithCaption(value string) Option

WithCaption - устанавливает опцию caption для TaskScheduler.

func WithTasks

func WithTasks(values ...mrworker.Task) Option

WithTasks - устанавливает опцию tasks для TaskScheduler.

type TaskScheduler

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

TaskScheduler - многопоточный сервис запуска задач по расписанию (планировщик задач).

func NewTaskScheduler

func NewTaskScheduler(errorHandler mrcore.ErrorHandler, opts ...Option) *TaskScheduler

NewTaskScheduler - создаёт объект TaskScheduler.

func (*TaskScheduler) Caption

func (s *TaskScheduler) Caption() string

Caption - возвращает название планировщика задач.

func (*TaskScheduler) ReadyTimeout

func (s *TaskScheduler) ReadyTimeout() time.Duration

ReadyTimeout - возвращает максимальное время, за которое должен быть запущен планировщик со всеми его задачами.

func (*TaskScheduler) Shutdown

func (s *TaskScheduler) Shutdown(ctx context.Context) error

Shutdown - корректная остановка планировщика задач.

func (*TaskScheduler) Start

func (s *TaskScheduler) Start(ctx context.Context, ready func()) error

Start - запуск планировщика задач.