twitterscheduler

Documentation

Index

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

Types

type TwitterScheduler

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

TwitterScheduler implements the mechanism for periodically fetching all enabled TwitterSources and scheduling a set of jobs for each TwitterSource.

func New

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

New creates a new TwitterScheduler.

func (*TwitterScheduler) Run

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

Run starts the twitter-sources scheduling process.

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