job

Documentation

Index

• type CleanCacheJob
  • func NewCleanCacheJob(_db store.DB, cacheRetention time.Duration) *CleanCacheJob
  • func (ccj *CleanCacheJob) Stop()
• type Scheduler
  • func StartNewScheduler(_db store.DB, conf config.Config) *Scheduler
  • func (s *Scheduler) Shutdown()

Types

type CleanCacheJob

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

CleanCacheJob is a job to clean the cache

func NewCleanCacheJob

func NewCleanCacheJob(_db store.DB, cacheRetention time.Duration) *CleanCacheJob

NewCleanCacheJob create and start new job to clean the cache

func (*CleanCacheJob) Stop

func (ccj *CleanCacheJob) Stop()

Stop job

type Scheduler

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

Scheduler is a job scheduler

func StartNewScheduler

func StartNewScheduler(_db store.DB, conf config.Config) *Scheduler

StartNewScheduler create and start new job scheduler

func (*Scheduler) Shutdown

func (s *Scheduler) Shutdown()

Shutdown job scheduler