repeater

Повторитель задач.

Компонент для периодического повторения каких либо задач, является заменой крону. Реализует интерфейс Repeater, который доступен в контейнере объектов.

type Repeater interface {
	AddProcess(name string, delay time.Duration, process ProcessFunc) Repeater
	AddTasks(tasks ...Task) Repeater
	Serve(ctx context.Context)
	Use(middlewares ...MiddlewareFunc) Repeater
}

Задачи для периодического повторения, можно добавить двумя способами:

• через метод AddProcess, метод принимает следующие параметры:
  • name - имя задачи;
  • delay - периодичность повторения задачи, например значение 1s обозначает, что задача будет повториться каждую секунду;
  • process - метод следующей сигнатуры func(ctx context.Context) error, который будет вызываться повторителем задач.
• через метод AddTasks, метод принимает объект, который реализует интерфейс Task.

type Task interface {
	Process(ctx context.Context) error
	Name() string
	Delay() time.Duration
}

Пакет предоставляется метод NewTask(name string, delay time.Duration, processFunc ProcessFunc), сигнатура которого идентичная методу AddProcess, этот метод возвращает стандартную реализацию интерфейса Task.

Так же, компонент сам следит за закрытием контекста из компонента Отслеживание сигнала на закрытие приложения и останавливает повторитель задач при закрытии контекста.

Объект конфигурации.

type Config struct {
	Delay time.Duration
}

Описание полей:

Middleware.

Пакет предоставляет несколько готовых middleware, которые находятся в подпакете middleware:

• Logger - логирует информацию о времени старта задачи, состоянии с которым завершилась задача и время работы задачи;
• Locker - добавляет функционал для запуска только 1-ого экземпляра задач, актуально если необходимо, чтобы задачи выполнялись в единственном экземпляре.