monitor

Documentation

Index

• type ChiphellMonitor
  • func NewChiphellMonitor(forumName string, cookies string, userKeywords map[string][]string, ...) *ChiphellMonitor
  • func (c *ChiphellMonitor) FetchPageContent() (string, error)
  • func (c *ChiphellMonitor) FetchPostMainContent(postURL string) (string, string, string, string, string, error)
  • func (c *ChiphellMonitor) MonitorPage()
  • func (c *ChiphellMonitor) ParseContent(content string) ([]Post, error)
  • func (c *ChiphellMonitor) ProcessPosts(posts []Post) error
• type ForumMonitor
  • func NewMonitor(forumName string, cookies string, userKeywords map[string][]string, ...) ForumMonitor
• type NotificationMessage
• type Post

Types

type ChiphellMonitor

type ChiphellMonitor struct {
	ForumName     string
	Cookies       string
	UserKeywords  map[string][]string // 手机号及其关键词的映射
	Notifier      *notifier.DingTalkNotifier
	Database      *db.Database
	Logger        *mylog.Logger
	MessageQueue  chan NotificationMessage
	WaitTimeRange struct {
		Min int
		Max int
	}
	ProxyAPI string
}

func NewChiphellMonitor

func NewChiphellMonitor(forumName string, cookies string, userKeywords map[string][]string, notifier *notifier.DingTalkNotifier, database *db.Database, waitTimeRange struct{ Min, Max int }, proxyAPI string) *ChiphellMonitor

func (*ChiphellMonitor) FetchPageContent

func (c *ChiphellMonitor) FetchPageContent() (string, error)

获取页面内容 FetchPageContent 使用代理池并发请求访问论坛页面

func (*ChiphellMonitor) FetchPostMainContent

func (c *ChiphellMonitor) FetchPostMainContent(postURL string) (string, string, string, string, string, error)

func (*ChiphellMonitor) MonitorPage

func (c *ChiphellMonitor) MonitorPage()

func (*ChiphellMonitor) ParseContent

func (c *ChiphellMonitor) ParseContent(content string) ([]Post, error)

func (*ChiphellMonitor) ProcessPosts

func (c *ChiphellMonitor) ProcessPosts(posts []Post) error

type ForumMonitor

type ForumMonitor interface {
	FetchPageContent() (string, error)
	ParseContent(content string) ([]Post, error)
	ProcessPosts(posts []Post) error
	MonitorPage()
}

func NewMonitor

func NewMonitor(forumName string, cookies string, userKeywords map[string][]string, notifier *notifier.DingTalkNotifier, database *db.Database, waitTimeRange struct{ Min, Max int }, proxyapi string) ForumMonitor

type NotificationMessage

type NotificationMessage struct {
	Title         string
	Message       string
	AtPhoneNumber []string
}

type Post

type Post struct {
	Title    string
	Link     string
	Category string
}