scraper

package

v0.7.0 Latest Latest Go to latest Published: Jan 3, 2023 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	Scraper
	Interval time.Duration
	// contains filtered or unexported fields
}

Client collects measurements and returns a summary of those collected measurement

func (c *Client) Count() int

Count returns the number of measurements currently collected

func (c *Client) Run(ctx context.Context)

Run collects measurements at the specified interval and records them for latest summarizing

func (c *Client) Summarize() Sample

Summarize returns a summary of collected measurements. The summary is then reset, i.e. previously collected measurements are discarded.

type Sample struct {
	Timestamp time.Time
	Value     float64
}

type Scraper interface {
	Scrape(ctx context.Context) (Sample, error)
}

type SolarEdgeScraper struct {
	solaredge.API
	SiteID int
}

func (s *SolarEdgeScraper) Scrape(ctx context.Context) (sample Sample, err error)

type Summarizer interface {
	Summarize() Sample
	Count() int
	Run(ctx context.Context)
}

A Summarizer returns the summary of a list of samples

type Summary struct {
	Total float64
	Count int
	First time.Time
	Last  time.Time
}

func (summary *Summary) Add(m Sample)

func (summary *Summary) Summarize() (result Sample)

type TadoScraper struct {
	tado.API
}

func (t *TadoScraper) Scrape(ctx context.Context) (sample Sample, err error)