cron

Sep 25, 2023

Changes in this version

+ type Runner struct

+ func New(opts RunnerOptions[T]) Runner[T]

+ func (r Runner[T]) Start(ctx context.Context) error

+ func (r Runner[T]) Stop(_ context.Context) error

+ type RunnerOptions struct

+ Config TasksConfig[T]

+ Sender sender.Serder[T]

+ Storage storage.Storage[T]

+ type ScheduleTask interface

+ Chats func() []int64

+ GetSchedules func() []string

+ type Task struct

+ ChatIDs []int64

+ Config T

+ Schedules []string

+ func (t Task[A, T]) Chats() []int64

+ func (t Task[A, T]) GetSchedules() []string

+ func (t Task[A, T]) Name() string

+ func (t Task[A, T]) Run(ctx context.Context, opts tasks.TaskRunOptions[A]) error

+ type TaskAction string

+ const TaskSendLastEntries

+ type TasksConfig struct

+ Backup Task[T, tasks.Backup[T]]

+ Cleanup Task[T, tasks.Cleanup[T]]

+ SendLastEntries Task[T, tasks.SendLastEntries[T]]

+ SendLastStories Task[T, tasks.SendLastStories[T]]

+ Timezone *time.Location