service

Documentation

Index

• type Messanger
• type Notifier
• type ProductCollector
  • func NewCollector() ProductCollector
  • func (p *ProductCollector) Collect(ch chan<- prometheus.Metric)
  • func (p *ProductCollector) Describe(descs chan<- *prometheus.Desc)
  • func (pc *ProductCollector) TrackProduct(name string, price float64)
• type Service
  • func New(collector ProductCollector, messanger Messanger, logger *zap.Logger) Service
  • func (s Service) Check() []string
  • func (s Service) Notify(products domain.Products)
• type ShopClient
• type ShopScraper
  • func NewScraper(client ShopClient, publisher Notifier, logger *zap.Logger) ShopScraper
  • func (scraper *ShopScraper) Run(ctx context.Context, interval time.Duration, query string)

Types

type Messanger

type Messanger interface {
	Message(text string) error
}

type Notifier

type Notifier interface {
	Notify(products domain.Products)
}

type ProductCollector

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

func NewCollector

func NewCollector() ProductCollector

func (*ProductCollector) Collect

func (p *ProductCollector) Collect(ch chan<- prometheus.Metric)

func (*ProductCollector) Describe

func (p *ProductCollector) Describe(descs chan<- *prometheus.Desc)

func (*ProductCollector) TrackProduct

func (pc *ProductCollector) TrackProduct(name string, price float64)

type Service

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

func New

func New(collector ProductCollector, messanger Messanger, logger *zap.Logger) Service

func (Service) Check

func (s Service) Check() []string

func (Service) Notify

func (s Service) Notify(products domain.Products)

type ShopClient

type ShopClient interface {
	Search(query string) (domain.Products, error)
}

type ShopScraper

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

func NewScraper

func NewScraper(client ShopClient, publisher Notifier, logger *zap.Logger) ShopScraper

func (*ShopScraper) Run

func (scraper *ShopScraper) Run(ctx context.Context, interval time.Duration, query string)