modules

type DeviceModule ¶

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

Device Module encapsulates all the logic regarding the devices. The logic is the following: devices output values can be changed from mqtt and forwarded to digitalstrom on the opposite side, when an event is received from digitalstrom, the new value is pushed to mqtt.

func (c *DeviceModule) GetHomeAssistantEntities() ([]homeassistant.DiscoveryConfig, error)

func (c *DeviceModule) Start() error

func (c *DeviceModule) Stop() error

type MeteringsModule ¶

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

Meterings Module encapsulates all the logic regarding the meterings of the controllers. The logic is the following: every 10 seconds the meterings values are being checked and pushed to the corresponding topic in the MQTT server.

func (c *MeteringsModule) GetHomeAssistantEntities() ([]homeassistant.DiscoveryConfig, error)

func (c *MeteringsModule) Start() error

func (c *MeteringsModule) Stop() error

type Module ¶

type Module interface {
	Start() error
	Stop() error
}

Interface for the different modules being

func NewDeviceModule(mqttClient mqtt.Client, dsClient digitalstrom.Client, dsRegistry digitalstrom.Registry, config *config.Config) Module

func NewMeteringsModule(mqttClient mqtt.Client, dsClient digitalstrom.Client, dsRegistry digitalstrom.Registry, config *config.Config) Module

type ModuleBuilder ¶

type ModuleBuilder func(mqtt.Client, digitalstrom.Client, digitalstrom.Registry, *config.Config) Module