repository

Documentation

Index

• type Measurement
  • func (m Measurement) Fold() Measurement
  • func (m Measurement) LogValue() slog.Value
• type Measurements
  • func (ms Measurements) Fold() Measurements
• type PostgresDB
  • func NewPostgresDB(host string, port int, database string, user string, password string) (*PostgresDB, error)
  • func (db *PostgresDB) Get(from, to time.Time) (measurements Measurements, err error)
  • func (db *PostgresDB) GetWeather(id int) (string, error)
  • func (db *PostgresDB) GetWeatherID(weather string) (int, error)
  • func (db *PostgresDB) Store(measurement Measurement) error

Types

type Measurement

type Measurement struct {
	Timestamp time.Time
	Power     float64
	Intensity float64
	Weather   string
}

func (Measurement) Fold

func (m Measurement) Fold() Measurement

func (Measurement) LogValue

func (m Measurement) LogValue() slog.Value

type Measurements

type Measurements []Measurement

func (Measurements) Fold

func (ms Measurements) Fold() Measurements

type PostgresDB

type PostgresDB struct {
	prometheus.Collector

	DBH *sqlx.DB
	// contains filtered or unexported fields
}

func NewPostgresDB

func NewPostgresDB(host string, port int, database string, user string, password string) (*PostgresDB, error)

func (*PostgresDB) Get

func (db *PostgresDB) Get(from, to time.Time) (measurements Measurements, err error)

func (*PostgresDB) GetWeather

func (db *PostgresDB) GetWeather(id int) (string, error)

func (*PostgresDB) GetWeatherID

func (db *PostgresDB) GetWeatherID(weather string) (int, error)

func (*PostgresDB) Store

func (db *PostgresDB) Store(measurement Measurement) error