scheduler

Documentation

Index

• type Option
  • func WithConfigPath(path string) Option
  • func WithInterval(interval time.Duration) Option
• type ServiceV2
  • func GetTaskSchedulerServiceV2() (svr *ServiceV2, err error)
  • func NewTaskSchedulerServiceV2() (svc2 *ServiceV2, err error)
  • func (svc *ServiceV2) Cancel(id primitive.ObjectID, by primitive.ObjectID) (err error)
  • func (svc *ServiceV2) Enqueue(t *models2.TaskV2, by primitive.ObjectID) (t2 *models2.TaskV2, err error)
  • func (svc *ServiceV2) SaveTask(t *models2.TaskV2, by primitive.ObjectID) (err error)
  • func (svc *ServiceV2) SetInterval(interval time.Duration)
  • func (svc *ServiceV2) Start()

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 ServiceV2

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

func GetTaskSchedulerServiceV2

func GetTaskSchedulerServiceV2() (svr *ServiceV2, err error)

func NewTaskSchedulerServiceV2

func NewTaskSchedulerServiceV2() (svc2 *ServiceV2, err error)

func (*ServiceV2) Cancel

func (svc *ServiceV2) Cancel(id primitive.ObjectID, by primitive.ObjectID) (err error)

func (*ServiceV2) Enqueue

func (svc *ServiceV2) Enqueue(t *models2.TaskV2, by primitive.ObjectID) (t2 *models2.TaskV2, err error)

func (*ServiceV2) SaveTask

func (svc *ServiceV2) SaveTask(t *models2.TaskV2, by primitive.ObjectID) (err error)

func (*ServiceV2) SetInterval

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

func (*ServiceV2) Start

func (svc *ServiceV2) Start()