publisher

Documentation

Index

• Constants
• type CommandPayload
  • func BuildCommandPayload(action string, optInterval plan.OptimisationInterval) CommandPayload
• type ErrorPayload
• type Service
  • func NewService(logger *slog.Logger, cfg config.Config, mqttClient mqtt.Client) *Service
  • func (s *Service) PublishCommand(optInterval plan.OptimisationInterval) error
  • func (s *Service) PublishError(message string, receivedError error)

Constants

const (
	MeterPowerUnitWatt     = 1
	MeterPowerUnitKilowatt = 2
	MeterPowerUnitMegawatt = 3
)

Types

type CommandPayload

type CommandPayload struct {
	Action string  `json:"action"`
	Value  float64 `json:"value"`
}

func BuildCommandPayload

func BuildCommandPayload(action string, optInterval plan.OptimisationInterval) CommandPayload

type ErrorPayload

type ErrorPayload struct {
	Category  string `json:"category"`
	Message   string `json:"message"`
	Timestamp int64  `json:"timestamp"`
}

type Service

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

func NewService

func NewService(logger *slog.Logger, cfg config.Config, mqttClient mqtt.Client) *Service

func (*Service) PublishCommand

func (s *Service) PublishCommand(optInterval plan.OptimisationInterval) error

func (*Service) PublishError

func (s *Service) PublishError(message string, receivedError error)