feedwatcher

Documentation

Index

• Variables
• func NewFeedJob(schedule string, config *Config) (rocketbot.CronJob, error)
• type Config
• type FeedJob
  • func (j *FeedJob) JobSchedule() string
  • func (j *FeedJob) Run(bot *rocketbot.Robot) error
• type Result
  • func (r *Result) Markdown() (string, error)
• type Watcher
  • func New(config *Config) *Watcher
  • func (fw *Watcher) ReloadFeeds() error
  • func (fw *Watcher) ReloadStates() error
  • func (fw *Watcher) SaveStates() error
  • func (fw *Watcher) Watch(f func(Result)) error

Variables

var ErrorMarkdownTemplate = `**[{{.Subscription.ID}}]({{.Subscription.URI}})**

` + "```" + `
{{.Err.Error}}
` + "```"

var NewItemsMarkdownTemplate = `**[{{.Feed.Title}}]({{.Feed.Link}})**

{{range .NewItems -}}
- [{{.Title}}]({{.Link}})
{{end}}`

Functions

func NewFeedJob

func NewFeedJob(schedule string, config *Config) (rocketbot.CronJob, error)

NewFeedJob creates feed watcher job.

Types

type Config

type Config struct {
	FeedsFile  string `toml:"feeds_file"`
	StatesFile string `toml:"states_file,omitempty"`
	NumWorkers int    `toml:"workers"`
	Channel    string `toml:"channel,omitempty"`
	Title      string `toml:"title,omitempty"`
}

type FeedJob

type FeedJob struct {
	Schedule string
	Config   *Config
	// contains filtered or unexported fields
}

func (*FeedJob) JobSchedule

func (j *FeedJob) JobSchedule() string

func (*FeedJob) Run

func (j *FeedJob) Run(bot *rocketbot.Robot) error

type Result

type Result struct {
	feedcrawler.Result
}

func (*Result) Markdown

func (r *Result) Markdown() (string, error)

type Watcher

type Watcher struct {
	feedcrawler.Crawler
	// contains filtered or unexported fields
}

func New

func New(config *Config) *Watcher

func (*Watcher) ReloadFeeds

func (fw *Watcher) ReloadFeeds() error

func (*Watcher) ReloadStates

func (fw *Watcher) ReloadStates() error

func (*Watcher) SaveStates

func (fw *Watcher) SaveStates() error

func (*Watcher) Watch

func (fw *Watcher) Watch(f func(Result)) error