job

Documentation

Index

• type FeedService
• type ItemService
• type ItemsJob
  • func NewItemsJob(feedService FeedService, itemService ItemService) *ItemsJob
  • func (j *ItemsJob) Execute()
• type Job
• type Scheduler
  • func NewScheduler(interval time.Duration) *Scheduler
  • func (s *Scheduler) ScheduleOnce(duration time.Duration, job Job)
  • func (s *Scheduler) Start()

Types

type FeedService

type FeedService interface {
	ListFeeds() ([]*feed.Feed, error)
	FetchItems(feedID int) ([]*item.Item, error)
}

type ItemService

type ItemService interface {
	UpsertItems(command *item.UpsertItemsCommand) error
}

type ItemsJob

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

func NewItemsJob

func NewItemsJob(feedService FeedService, itemService ItemService) *ItemsJob

func (*ItemsJob) Execute

func (j *ItemsJob) Execute()

type Job

type Job interface {
	Execute()
}

type Scheduler

type Scheduler struct {
	Queue    chan Job
	Interval time.Duration
}

func NewScheduler

func NewScheduler(interval time.Duration) *Scheduler

func (*Scheduler) ScheduleOnce

func (s *Scheduler) ScheduleOnce(duration time.Duration, job Job)

func (*Scheduler) Start

func (s *Scheduler) Start()