repository

Documentation

Index

• type Measurement
  • func (m Measurement) LogValue() slog.Value
• type Measurements
  • func (m Measurements) Fold() Measurements
  • func (m Measurements) Len() int
  • func (m Measurements) XY(i int) (float64, float64)
  • func (m Measurements) XYZ(i int) (float64, float64, float64)
• type PostgresDB
  • func NewPostgresDB(connectionString string) (*PostgresDB, error)
  • func (db *PostgresDB) Get(from, to time.Time) (measurements Measurements, err error)
  • func (db *PostgresDB) GetDataRange() (time.Time, time.Time, 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) LogValue

func (m Measurement) LogValue() slog.Value

type Measurements

type Measurements []Measurement

func (Measurements) Fold

func (m Measurements) Fold() Measurements

func (Measurements) Len

func (m Measurements) Len() int

func (Measurements) XY

func (m Measurements) XY(i int) (float64, float64)

func (Measurements) XYZ

func (m Measurements) XYZ(i int) (float64, float64, float64)

type PostgresDB

type PostgresDB struct {
	prometheus.Collector

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

func NewPostgresDB

func NewPostgresDB(connectionString string) (*PostgresDB, error)

func (*PostgresDB) Get

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

func (*PostgresDB) GetDataRange

func (db *PostgresDB) GetDataRange() (time.Time, time.Time, 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