cron

Documentation

Index

• type CronJob
  • func NewCronJob(log *logrus.Entry, application *application.Application) *CronJob
  • func (c *CronJob) ClearDatabase(ctx context.Context)
  • func (c *CronJob) NotificationChannel() chan telegramconversation.TContext
  • func (c *CronJob) NotifyUsers(ctx context.Context)
  • func (c *CronJob) Start(ctx context.Context)

Types

type CronJob

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

CronJob triggers applications

func NewCronJob

func NewCronJob(
	log *logrus.Entry, application *application.Application) *CronJob

NewCronJob service

func (*CronJob) ClearDatabase

func (c *CronJob) ClearDatabase(ctx context.Context)

ClearDatabase delete old trainalarms from database

func (*CronJob) NotificationChannel

func (c *CronJob) NotificationChannel() chan telegramconversation.TContext

NotificationChannel returns the channel with telegram notifications

func (*CronJob) NotifyUsers

func (c *CronJob) NotifyUsers(ctx context.Context)

NotifyUsers about train delays

func (*CronJob) Start

func (c *CronJob) Start(ctx context.Context)

Start ticker