core

Documentation

Index

• func ScatterGather(ctx context.Context, configs []config.Feed, goodboy Fetcher) ([][]Entry, []error)
• type Entry
  • func HTTPFetcher(ctx context.Context, f config.Feed) ([]Entry, error)
  • func Parse(cfg config.Feed, raw io.Reader) ([]Entry, error)
• type Fetcher
• type SortedEntries
  • func (p SortedEntries) Len() int
  • func (p SortedEntries) Less(i, j int) bool
  • func (p SortedEntries) Swap(i, j int)

Functions

func ScatterGather

func ScatterGather(ctx context.Context, configs []config.Feed, goodboy Fetcher) ([][]Entry, []error)

ScatterGather uses a given Fetcher to fetch feeds concurrently.

Types

type Entry

type Entry struct {
	Feed      string
	Title     string
	Link      *url.URL
	Published time.Time
}

func HTTPFetcher

func HTTPFetcher(ctx context.Context, f config.Feed) ([]Entry, error)

HTTPFetcher fetches feeds over HTTP.

func Parse

func Parse(cfg config.Feed, raw io.Reader) ([]Entry, error)

type Fetcher

type Fetcher func(context.Context, config.Feed) ([]Entry, error)

Fetcher fetches a Feed based on a config.

type SortedEntries

type SortedEntries []Entry

func (SortedEntries) Len

func (p SortedEntries) Len() int

func (SortedEntries) Less

func (p SortedEntries) Less(i, j int) bool

func (SortedEntries) Swap

func (p SortedEntries) Swap(i, j int)