scheduler

Documentation

Index

• type Scheduler
  • func New(id primitive.ObjectID, interval time.Duration, ...) (Scheduler, error)

Types

type Scheduler

type Scheduler interface {
	// Should return id
	GetID() string
	//Get ID bson
	GetIDBson() primitive.ObjectID
	// Should run Scheduler every tick
	Run() error
	// Should stop Scheduler
	Stop()
	// Return true/false depends from current state
	IsRun() bool
}

func New

func New(id primitive.ObjectID, interval time.Duration, jobExecutor job_executor.JobExecutor, cache cache.Cache) (Scheduler, error)