scheduler

Documentation

Index

• func GetTaskSchedulerService(path string, opts ...Option) (svr interfaces.TaskSchedulerService, err error)
• func NewTaskSchedulerService(opts ...Option) (svc2 interfaces.TaskSchedulerService, err error)
• func ProvideGetTaskSchedulerService(path string, opts ...Option) func() (svr interfaces.TaskSchedulerService, err error)
• func ProvideTaskSchedulerService(path string, opts ...Option) func() (svc interfaces.TaskSchedulerService, err error)
• type Option
  • func WithConfigPath(path string) Option
  • func WithInterval(interval time.Duration) Option
• type Service
  • func (svc *Service) Cancel(id primitive.ObjectID, args ...interface{}) (err error)
  • func (svc *Service) Dequeue() (tasks []interfaces.Task, err error)
  • func (svc *Service) DequeueAndSchedule()
  • func (svc *Service) Enqueue(t interfaces.Task) (err error)
  • func (svc *Service) Schedule(tasks []interfaces.Task) (err error)
  • func (svc *Service) SetInterval(interval time.Duration)
  • func (svc *Service) Start()

Functions

func GetTaskSchedulerService

func GetTaskSchedulerService(path string, opts ...Option) (svr interfaces.TaskSchedulerService, err error)

func NewTaskSchedulerService

func NewTaskSchedulerService(opts ...Option) (svc2 interfaces.TaskSchedulerService, err error)

func ProvideGetTaskSchedulerService

func ProvideGetTaskSchedulerService(path string, opts ...Option) func() (svr interfaces.TaskSchedulerService, err error)

func ProvideTaskSchedulerService

func ProvideTaskSchedulerService(path string, opts ...Option) func() (svc interfaces.TaskSchedulerService, err error)

Types

type Option

type Option func(svc interfaces.TaskSchedulerService)

func WithConfigPath

func WithConfigPath(path string) Option

func WithInterval

func WithInterval(interval time.Duration) Option

type Service

type Service struct {
	// dependencies
	interfaces.TaskBaseService
	// contains filtered or unexported fields
}

func (*Service) Cancel

func (svc *Service) Cancel(id primitive.ObjectID, args ...interface{}) (err error)

func (*Service) Dequeue

func (svc *Service) Dequeue() (tasks []interfaces.Task, err error)

func (*Service) DequeueAndSchedule

func (svc *Service) DequeueAndSchedule()

func (*Service) Enqueue

func (svc *Service) Enqueue(t interfaces.Task) (err error)

func (*Service) Schedule

func (svc *Service) Schedule(tasks []interfaces.Task) (err error)

func (*Service) SetInterval

func (svc *Service) SetInterval(interval time.Duration)

func (*Service) Start

func (svc *Service) Start()