scraper

Documentation

Index

• type Exporter
  • func (e Exporter) Run(ctx context.Context) error
• type Metrics
  • func NewMetrics() *Metrics
  • func (m Metrics) Collect(ch chan<- prometheus.Metric)
  • func (m Metrics) Describe(ch chan<- *prometheus.Desc)
• type Poller
  • func (p *Poller) Run(ctx context.Context) error
• type Publisher
• type SolarEdgeGetter
• type Store
• type TadoGetter
• type Writer
  • func (w *Writer) Run(ctx context.Context) error

Types

type Exporter

type Exporter struct {
	Poller  Publisher[solaredge.Update]
	Metrics *Metrics
	Logger  *slog.Logger
}

func (Exporter) Run

func (e Exporter) Run(ctx context.Context) error

type Metrics

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

func NewMetrics

func NewMetrics() *Metrics

func (Metrics) Collect

func (m Metrics) Collect(ch chan<- prometheus.Metric)

func (Metrics) Describe

func (m Metrics) Describe(ch chan<- *prometheus.Desc)

type Poller

type Poller struct {
	Client   SolarEdgeGetter
	Interval time.Duration
	Logger   *slog.Logger
	pubsub.Publisher[solaredge.Update]
}

func (*Poller) Run

func (p *Poller) Run(ctx context.Context) error

type Publisher

type Publisher[T any] interface {
	Subscribe() chan T
	Unsubscribe(chan T)
}

type SolarEdgeGetter

type SolarEdgeGetter interface {
	GetUpdate(context.Context) (solaredge.Update, error)
}

type Store

type Store interface {
	Store(repository.Measurement) error
}

type TadoGetter

type TadoGetter interface {
	GetWeatherInfo(context.Context) (tado.WeatherInfo, error)
}

type Writer

type Writer struct {
	Store
	TadoGetter
	Poller   Publisher[solaredge.Update]
	Interval time.Duration
	Logger   *slog.Logger
	// contains filtered or unexported fields
}

func (*Writer) Run

func (w *Writer) Run(ctx context.Context) error