scheduler

Documentation

Index

• type FeedGroup
  • func NewFeedGroup(scheduledFeeds []feeds.ScheduledFeed, pub publisher.Publisher, ...) *FeedGroup
  • func (fg *FeedGroup) AddFeed(feed feeds.ScheduledFeed)
  • func (fg *FeedGroup) Run()
• type FeedGroupsHandler
  • func NewFeedGroupsHandler(feeds []*FeedGroup) *FeedGroupsHandler
  • func (srv *FeedGroupsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Scheduler
  • func New(feedsMap map[string]feeds.ScheduledFeed, pub publisher.Publisher, httpPort int) *Scheduler
  • func (s *Scheduler) Run(initialCutoff time.Duration, enableDefaultTimer bool) error

Types

type FeedGroup

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

func NewFeedGroup

func NewFeedGroup(scheduledFeeds []feeds.ScheduledFeed, pub publisher.Publisher, initialCutoff time.Duration) *FeedGroup

func (*FeedGroup) AddFeed

func (fg *FeedGroup) AddFeed(feed feeds.ScheduledFeed)

func (*FeedGroup) Run

func (fg *FeedGroup) Run()

type FeedGroupsHandler

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

func NewFeedGroupsHandler

func NewFeedGroupsHandler(feeds []*FeedGroup) *FeedGroupsHandler

func (*FeedGroupsHandler) ServeHTTP

func (srv *FeedGroupsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Scheduler

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

Scheduler is a registry of feeds that should be run on a schedule.

func New

func New(feedsMap map[string]feeds.ScheduledFeed, pub publisher.Publisher, httpPort int) *Scheduler

New returns a new Scheduler with a publisher and feeds configured for polling.

func (*Scheduler) Run

func (s *Scheduler) Run(initialCutoff time.Duration, enableDefaultTimer bool) error

Runs several services for the operation of scheduler, this call is blocking until application exit or failure in the HTTP server Services include: Cron polling via FeedGroups, HTTP serving of FeedGroupsHandler.