worker

Documentation

Index

• type Client
• type NetworkUsage
• type RSS
• type RSSItem
• type Worker
  • func NewWorker(config *config.Config, db *storage.Storage) *Worker
  • func (w *Worker) ProcessQueue() NetworkUsage
  • func (w *Worker) RefreshFeeds()
  • func (w *Worker) StartArticleCleaner(maxAge time.Duration)
  • func (w *Worker) StartFeeds(interval time.Duration)
  • func (w *Worker) StartQueue(delay time.Duration)
  • func (w *Worker) Submit(url string, pubDate time.Time)

Types

type Client

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

type NetworkUsage

type NetworkUsage int

const (
	NetworkUsed NetworkUsage = iota
	NetworkSkipped
)

type RSS

type RSS struct {
	XMLName xml.Name `xml:"rss"`
	Version string   `xml:"version,attr"`
	Channel struct {
		Title       string `xml:"title"`
		Description string `xml:"description"`
		Link        string `xml:"link"`
		Image       struct {
			Url   string `xml:"url"`
			Title string `xml:"title"`
			Link  string `xml:"link"`
		} `xml:"image"`
		Items []RSSItem `xml:"item"`
	} `xml:"channel"`
}

type RSSItem

type RSSItem struct {
	Title       string `xml:"title"`
	Description struct {
		XMLName xml.Name `xml:"description"`
		Text    string   `xml:",cdata"`
	} `xml:"description"`
	Link string `xml:"link"`
	Guid struct {
		IsPermaLink string `xml:"isPermaLink,attr"`
		Value       string `xml:",chardata"`
	} `xml:"guid"`
	PubDate string `xml:"pubDate"`
}

type Worker

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

func NewWorker

func NewWorker(config *config.Config, db *storage.Storage) *Worker

func (*Worker) ProcessQueue

func (w *Worker) ProcessQueue() NetworkUsage

func (*Worker) RefreshFeeds

func (w *Worker) RefreshFeeds()

func (*Worker) StartArticleCleaner

func (w *Worker) StartArticleCleaner(maxAge time.Duration)

func (*Worker) StartFeeds

func (w *Worker) StartFeeds(interval time.Duration)

func (*Worker) StartQueue

func (w *Worker) StartQueue(delay time.Duration)

func (*Worker) Submit

func (w *Worker) Submit(url string, pubDate time.Time)