scheduler

Documentation

Index

• type RunProcessorJob
  • func (j *RunProcessorJob) Run()
• type Service
  • func NewService(cfg *domain.Config, processorSvc *processor.Service) *Service
  • func (s *Service) AddJob(job cron.Job, interval string, identifier string) (int, error)
  • func (s *Service) Start()
  • func (s *Service) Stop()

Types

type RunProcessorJob

type RunProcessorJob struct {
	Name             string
	Log              zerolog.Logger
	ProcessorService *processor.Service
}

func (*RunProcessorJob) Run

func (j *RunProcessorJob) Run()

type Service

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

func NewService

func NewService(cfg *domain.Config, processorSvc *processor.Service) *Service

func (*Service) AddJob

func (s *Service) AddJob(job cron.Job, interval string, identifier string) (int, error)

func (*Service) Start

func (s *Service) Start()

func (*Service) Stop

func (s *Service) Stop()