bot

Documentation

Index

• type Bot
  • func New(r *repo.MySQL, q queue.Queue) (*Bot, error)
  • func (b *Bot) HandleMessage(msg util.Object)
  • func (b *Bot) Start() error
  • func (b *Bot) Stop()
• type IPByDate
  • func (a IPByDate) Len() int
  • func (a IPByDate) Less(i, j int) bool
  • func (a IPByDate) Swap(i, j int)
• type Worker
  • func NewWorker(q queue.Queue) (*Worker, error)
  • func (w *Worker) Start()

Types

type Bot

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

Bot iterates on all subscriptions and listens / responds to messages

func New

func New(r *repo.MySQL, q queue.Queue) (*Bot, error)

New returns a new bot

func (*Bot) HandleMessage

func (b *Bot) HandleMessage(msg util.Object)

func (*Bot) Start

func (b *Bot) Start() error

Start the monitoring process - will start a separate Go routine

func (*Bot) Stop

func (b *Bot) Stop()

Stop the monitoring process

type IPByDate

type IPByDate []govt.DetectedUrl

IPByDate sorting

func (IPByDate) Len

func (a IPByDate) Len() int

func (IPByDate) Less

func (a IPByDate) Less(i, j int) bool

func (IPByDate) Swap

func (a IPByDate) Swap(i, j int)

type Worker

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

Worker reads messages from the queue and does the actual work

func NewWorker

func NewWorker(q queue.Queue) (*Worker, error)

NewWorker that loads work messages from the queue

func (*Worker) Start

func (w *Worker) Start()

Start the worker process. To stop, just close the queue.