feedscheduler

Documentation

Index

• type FeedScheduler
  • func New(conf config.FeedScheduler, db *gorm.DB, fk *faktory.Client) *FeedScheduler
  • func (fs *FeedScheduler) Run(ctx context.Context) (err error)

Types

type FeedScheduler

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

FeedScheduler implements the mechanism for periodically fetching all enabled Feeds and scheduling a set of jobs for each Feed.

func New

func New(conf config.FeedScheduler, db *gorm.DB, fk *faktory.Client) *FeedScheduler

New creates a new FeedScheduler.

func (*FeedScheduler) Run

func (fs *FeedScheduler) Run(ctx context.Context) (err error)

Run starts the feed scheduling process.

This function should ideally run forever, unless an error is encountered or the context is done.