ingest

Documentation

Index

• Variables
• type PostIngester
  • func (p *PostIngester) FilterDistinctAuthors() *collection.Collection[*models.Author]
  • func (p *PostIngester) Get(slug, hostname string, wg *sync.WaitGroup)
  • func (p *PostIngester) GroupPostsByTag() *collection.Collection[models.Tag]
  • func (p *PostIngester) Results() *collection.Collection[*models.Post]

Variables

var Posts = &PostIngester{
	client:  client.New(),
	results: collection.New[*models.Post](),
}

Types

type PostIngester

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

PostIngester

func (*PostIngester) FilterDistinctAuthors

func (p *PostIngester) FilterDistinctAuthors() *collection.Collection[*models.Author]

FilterDistinctAuthors

func (*PostIngester) Get

func (p *PostIngester) Get(slug, hostname string, wg *sync.WaitGroup)

Get

func (*PostIngester) GroupPostsByTag

func (p *PostIngester) GroupPostsByTag() *collection.Collection[models.Tag]

GroupPostsByTag

func (*PostIngester) Results

func (p *PostIngester) Results() *collection.Collection[*models.Post]

Results