publisher

Documentation

Index

• type InverterUpdate
• type Publisher
  • func (p *Publisher[T]) Run(ctx context.Context) error
• type SiteUpdate
• type SolarEdgeClient
• type SolarEdgeUpdate
• type SolarEdgeUpdater
  • func (c SolarEdgeUpdater) GetUpdate(ctx context.Context) (SolarEdgeUpdate, error)
• type TadoUpdater
  • func (c TadoUpdater) GetUpdate(ctx context.Context) (*tado.Weather, error)
• type Updater
• type WeatherGetter

Types

type InverterUpdate

type InverterUpdate struct {
	Name         string
	SerialNumber string
	Telemetry    solaredge.InverterTelemetry
}

type Publisher

type Publisher[T any] struct {
	Updater[T]
	Interval time.Duration
	Logger   *slog.Logger
	pubsub.Publisher[T]
}

func (*Publisher[T]) Run

func (p *Publisher[T]) Run(ctx context.Context) error

type SiteUpdate

type SiteUpdate struct {
	ID              int
	Name            string
	PowerOverview   solaredge.PowerOverview
	InverterUpdates []InverterUpdate
}

type SolarEdgeClient

type SolarEdgeClient interface {
	GetSites(ctx context.Context) (solaredge.GetSitesResponse, error)
	GetPowerOverview(ctx context.Context, id int) (solaredge.GetPowerOverviewResponse, error)
	GetComponents(ctx context.Context, id int) (solaredge.GetComponentsResponse, error)
	GetInverterTechnicalData(ctx context.Context, id int, serialNr string, startTime time.Time, endTime time.Time) (solaredge.GetInverterTechnicalDataResponse, error)
}

type SolarEdgeUpdate

type SolarEdgeUpdate []SiteUpdate

type SolarEdgeUpdater

type SolarEdgeUpdater struct {
	SolarEdgeClient
}

func (SolarEdgeUpdater) GetUpdate

func (c SolarEdgeUpdater) GetUpdate(ctx context.Context) (SolarEdgeUpdate, error)

type TadoUpdater

type TadoUpdater struct {
	Client WeatherGetter
	HomeId tado.HomeId
}

func (TadoUpdater) GetUpdate

func (c TadoUpdater) GetUpdate(ctx context.Context) (*tado.Weather, error)

type Updater

type Updater[T any] interface {
	GetUpdate(context.Context) (T, error)
}

type WeatherGetter

type WeatherGetter interface {
	GetWeatherWithResponse(ctx context.Context, homeId tado.HomeId, reqEditors ...tado.RequestEditorFn) (*tado.GetWeatherResponse, error)
}