feeder

Documentation

Index

• func GetFeedsToRefresh(ctx context.Context, exec boil.ContextExecutor) ([]*core.RSSFeed, error)
• func LockFeed(ctx context.Context, exec boil.ContextExecutor, feedID string) (*core.RSSFeed, error)
• func SaveFeed(ctx context.Context, exec boil.ContextExecutor, feed *core.RSSFeed, ...) error
• func SaveFeedItem(ctx context.Context, exec boil.ContextExecutor, feedID string, ...) (bool, error)
• func SaveFetchFailure(ctx context.Context, exec boil.ContextExecutor, feed *core.RSSFeed, ...) error
• type Feeder
  • func NewFeeder(db *sqlx.DB, fetcher fetcher, cleaner cleaner) *Feeder
  • func (f *Feeder) RunPoller(ctx context.Context)

Functions

func GetFeedsToRefresh

func GetFeedsToRefresh(ctx context.Context, exec boil.ContextExecutor) ([]*core.RSSFeed, error)

func LockFeed

func LockFeed(ctx context.Context, exec boil.ContextExecutor, feedID string) (*core.RSSFeed, error)

func SaveFeed

func SaveFeed(ctx context.Context, exec boil.ContextExecutor, feed *core.RSSFeed, rssFeed *reader.Feed, cleaner cleaner) error

func SaveFeedItem

func SaveFeedItem(ctx context.Context, exec boil.ContextExecutor, feedID string, rssFeedItem *reader.Item, cleaner cleaner) (bool, error)

func SaveFetchFailure

func SaveFetchFailure(ctx context.Context, exec boil.ContextExecutor, feed *core.RSSFeed, fetchErr error) error

Types

type Feeder

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

func NewFeeder

func NewFeeder(db *sqlx.DB, fetcher fetcher, cleaner cleaner) *Feeder

func (*Feeder) RunPoller

func (f *Feeder) RunPoller(ctx context.Context)