scraper

Documentation

Index

• type Publisher
• type Store
• type Writer
  • func (w *Writer) Run(ctx context.Context) error

Types

type Publisher

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

type Store

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

type Writer

type Writer struct {
	Store
	SolarEdge Publisher[publisher.SolarEdgeUpdate]
	Tado      Publisher[*tado.Weather]
	Interval  time.Duration
	Logger    *slog.Logger
	// contains filtered or unexported fields
}

func (*Writer) Run

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