pull

package

v0.2.2 Latest Latest Go to latest Published: Mar 6, 2024 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func Fetch(ctx context.Context, link string) (*gofeed.Feed, error)

type FeedRepo interface {
	All() ([]*model.Feed, error)
	Get(id uint) (*model.Feed, error)
	Update(id uint, feed *model.Feed) error
}

type ItemRepo interface {
	Creates(items []*model.Item) error
	IdentityExist(feedID uint, guid, link, title string) (bool, error)
}

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

func NewPuller(feedRepo FeedRepo, itemRepo ItemRepo) *Puller

func (p *Puller) PullAll(ctx context.Context) error

func (p *Puller) PullOne(id uint) error

func (p *Puller) Run()