models

package
v0.0.0-...-7fde5a9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 16, 2019 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrInvalidName means that the name is invalid.
	ErrInvalidName = errors.New("models: invalid name")

	// ErrInvalidReq means that the ID is invalid.
	ErrInvalidReq = errors.New("models: invalid request")

	// ErrNotFound means that the record is not found.
	ErrNotFound = errors.New("models: not found")

	// ErrUnknownSensorType means that the type is set to 0.
	ErrUnknownSensorType = errors.New("models: unknown sensor type")
)

Functions

func AddDevice

func AddDevice(db *sql.DB, req *message.Device) error

AddDevice adds a new device to the database.

func AddHumidity

func AddHumidity(db *sql.DB, req *message.Humidity) error

AddHumidity saves humidity metric to database.

func AddPower

func AddPower(db *sql.DB, req *message.Power) error

AddPower saves power metric to database.

func AddSensor

func AddSensor(db *sql.DB, req *message.Sensor) error

AddSensor adds a new sensor to the database.

func AddTemperature

func AddTemperature(db *sql.DB, req *message.Temperature) error

AddTemperature saves temperature metric to database.

func CountDevice

func CountDevice(db *sql.DB, req *message.DeviceCountRequest) (*message.DeviceCount, error)

CountDevice counts number of devices.

func CountSensor

func CountSensor(db *sql.DB, req *message.SensorCountRequest) (*message.SensorCount, error)

CountSensor counts number of sensors.

func DeleteDevice

func DeleteDevice(db *sql.DB, req *message.Device) error

DeleteDevice deletes device for a given ID.

func DeleteSensor

func DeleteSensor(db *sql.DB, req *message.Sensor) error

DeleteSensor deletes sensor for a given ID.

func DeviceActive

func DeviceActive(db *sql.DB, id int64) (bool, error)

DeviceActive checks if the device is active.

func GetAvgConsumption

func GetAvgConsumption(db *sql.DB, req *message.ConsumptionRequest) (*sql.Rows, error)

GetAvgConsumption returns a bucket of average energy consumption.

func GetAvgHumidity

func GetAvgHumidity(db *sql.DB, req *message.HumidityRequest) (*sql.Rows, error)

GetAvgHumidity returns a bucket of average humidity.

func GetAvgTemperature

func GetAvgTemperature(db *sql.DB, req *message.TemperatureRequest) (*sql.Rows, error)

GetAvgTemperature returns a bucket of average temperature.

func GetDevice

func GetDevice(db *sql.DB, req *message.Device) (*message.Device, error)

GetDevice retrieves device.

func GetDevices

func GetDevices(db *sql.DB, req *message.DevicesRequest) (*sql.Rows, error)

GetDevices returns list of devices.

func GetHumidity

func GetHumidity(db *sql.DB, req *message.HumidityRequest) (*sql.Rows, error)

GetHumidity returns data point of humidity metrics.

func GetPower

func GetPower(db *sql.DB, req *message.PowerRequest) (*sql.Rows, error)

GetPower returns power metrics.

func GetSensor

func GetSensor(db *sql.DB, req *message.Sensor) (*message.Sensor, error)

GetSensor retrieves sensor.

func GetSensors

func GetSensors(db *sql.DB, req *message.SensorsRequest) (*sql.Rows, error)

GetSensors returns list of sensors.

func GetTemperature

func GetTemperature(db *sql.DB, req *message.TemperatureRequest) (*sql.Rows, error)

GetTemperature returns data point of temperature metrics.

func SensorActive

func SensorActive(db *sql.DB, sensorType message.SensorType, id int64) (bool, error)

SensorActive checks if the sensor is active.

func UpdateDevice

func UpdateDevice(db *sql.DB, req *message.Device) error

UpdateDevice updates device name for a given ID.

func UpdateSensor

func UpdateSensor(db *sql.DB, req *message.Sensor) error

UpdateSensor updates device ID and sensor name for a given ID.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL