jobs

Documentation

Index

• func RegisterTasks(server *machinery.Server, repo db.Repository, appConfig config.AppConfig, ...)
• type JobQueue
  • func (q *JobQueue) DueDateNotification(notificationId uuid.UUID) error
• type JobTasks
  • func (t *JobTasks) DueDateNotification(dueDateIDEncoded string, taskIDEncoded string) (bool, error)
  • func (t *JobTasks) ScheduleDueDateNotifications() (bool, error)
• type MachineryLogger
  • func (m *MachineryLogger) Fatal(args ...interface{})
  • func (m *MachineryLogger) Fatalf(format string, args ...interface{})
  • func (m *MachineryLogger) Fatalln(args ...interface{})
  • func (m *MachineryLogger) Panic(args ...interface{})
  • func (m *MachineryLogger) Panicf(format string, args ...interface{})
  • func (m *MachineryLogger) Panicln(args ...interface{})
  • func (m *MachineryLogger) Print(args ...interface{})
  • func (m *MachineryLogger) Printf(format string, args ...interface{})
  • func (m *MachineryLogger) Println(args ...interface{})
• type NotifiedData

Functions

func RegisterTasks

func RegisterTasks(server *machinery.Server, repo db.Repository, appConfig config.AppConfig, messageQueue *redis.Client)

Types

type JobQueue

type JobQueue struct {
	AppConfig  config.AppConfig
	Repository db.Repository
	Server     *machinery.Server
}

func (*JobQueue) DueDateNotification

func (q *JobQueue) DueDateNotification(notificationId uuid.UUID) error

type JobTasks

type JobTasks struct {
	AppConfig    config.AppConfig
	Repository   db.Repository
	Server       *machinery.Server
	MessageQueue *redis.Client
}

func (*JobTasks) DueDateNotification

func (t *JobTasks) DueDateNotification(dueDateIDEncoded string, taskIDEncoded string) (bool, error)

func (*JobTasks) ScheduleDueDateNotifications

func (t *JobTasks) ScheduleDueDateNotifications() (bool, error)

type MachineryLogger

type MachineryLogger struct{}

MachineryLogger is a customer logger for machinery worker

func (*MachineryLogger) Fatal

func (m *MachineryLogger) Fatal(args ...interface{})

Fatal sends to logrus.Fatal

func (*MachineryLogger) Fatalf

func (m *MachineryLogger) Fatalf(format string, args ...interface{})

Fatalf sends to logrus.Fatalf

func (*MachineryLogger) Fatalln

func (m *MachineryLogger) Fatalln(args ...interface{})

Fatalln sends to logrus.Fatal

func (*MachineryLogger) Panic

func (m *MachineryLogger) Panic(args ...interface{})

Panic sends to logrus.Panic

func (*MachineryLogger) Panicf

func (m *MachineryLogger) Panicf(format string, args ...interface{})

Panicf sends to logrus.Panic

func (*MachineryLogger) Panicln

func (m *MachineryLogger) Panicln(args ...interface{})

Panicln sends to logrus.Panic

func (*MachineryLogger) Print

func (m *MachineryLogger) Print(args ...interface{})

Print sends to logrus.Info

func (*MachineryLogger) Printf

func (m *MachineryLogger) Printf(format string, args ...interface{})

Printf sends to logrus.Infof

func (*MachineryLogger) Println

func (m *MachineryLogger) Println(args ...interface{})

Println sends to logrus.Info

type NotifiedData

type NotifiedData struct {
	Data map[string]string
}