scraper

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

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

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

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

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

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

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

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