impl

Documentation

Index

• type DeviceServiceImpl
  • func NewDeviceServiceImpl(db *sql.DB) *DeviceServiceImpl
  • func (s *DeviceServiceImpl) Add(ctx context.Context, req *message.Device) (*message.Device, error)
  • func (s *DeviceServiceImpl) Count(ctx context.Context, req *message.DeviceCountRequest) (*message.DeviceCount, error)
  • func (s *DeviceServiceImpl) Delete(ctx context.Context, req *message.Device) (*message.Empty, error)
  • func (s *DeviceServiceImpl) Get(req *message.DevicesRequest, stream service.DeviceService_GetServer) error
  • func (s *DeviceServiceImpl) Update(ctx context.Context, req *message.Device) (*message.Empty, error)
• type HumidityServiceImpl
  • func NewHumidityServiceImpl(db *sql.DB) *HumidityServiceImpl
  • func (s *HumidityServiceImpl) Add(ctx context.Context, req *message.Humidity) (*message.Humidity, error)
  • func (s *HumidityServiceImpl) GetAvgHumidity(req *message.HumidityRequest, ...) error
  • func (s *HumidityServiceImpl) GetHumidity(req *message.HumidityRequest, stream service.HumidityService_GetHumidityServer) error
• type PowerServiceImpl
  • func NewPowerServiceImpl(db *sql.DB) *PowerServiceImpl
  • func (s *PowerServiceImpl) Add(ctx context.Context, req *message.Power) (*message.Power, error)
  • func (s *PowerServiceImpl) GetAvgConsumption(req *message.ConsumptionRequest, ...) error
  • func (s *PowerServiceImpl) GetPower(req *message.PowerRequest, stream service.PowerService_GetPowerServer) error
• type SensorServiceImpl
  • func NewSensorServiceImpl(db *sql.DB) *SensorServiceImpl
  • func (s *SensorServiceImpl) Add(ctx context.Context, req *message.Sensor) (*message.Sensor, error)
  • func (s *SensorServiceImpl) Count(ctx context.Context, req *message.SensorCountRequest) (*message.SensorCount, error)
  • func (s *SensorServiceImpl) Delete(ctx context.Context, req *message.Sensor) (*message.Empty, error)
  • func (s *SensorServiceImpl) Get(req *message.SensorsRequest, stream service.SensorService_GetServer) error
  • func (s *SensorServiceImpl) Update(ctx context.Context, req *message.Sensor) (*message.Empty, error)
• type TemperatureServiceImpl
  • func NewTemperatureServiceImpl(db *sql.DB) *TemperatureServiceImpl
  • func (s *TemperatureServiceImpl) Add(ctx context.Context, req *message.Temperature) (*message.Temperature, error)
  • func (s *TemperatureServiceImpl) GetAvgTemperature(req *message.TemperatureRequest, ...) error
  • func (s *TemperatureServiceImpl) GetTemperature(req *message.TemperatureRequest, ...) error

Types

type DeviceServiceImpl

type DeviceServiceImpl struct {
	DB *sql.DB
}

DeviceServiceImpl structure to access database.

func NewDeviceServiceImpl

func NewDeviceServiceImpl(db *sql.DB) *DeviceServiceImpl

NewDeviceServiceImpl initialize device service and access to database.

func (*DeviceServiceImpl) Add

func (s *DeviceServiceImpl) Add(ctx context.Context, req *message.Device) (*message.Device, error)

Add creates new device in database.

func (*DeviceServiceImpl) Count

func (s *DeviceServiceImpl) Count(ctx context.Context, req *message.DeviceCountRequest) (*message.DeviceCount, error)

Count counts the number of devices.

func (*DeviceServiceImpl) Delete

func (s *DeviceServiceImpl) Delete(ctx context.Context, req *message.Device) (*message.Empty, error)

Delete deletes the device.

func (*DeviceServiceImpl) Get

func (s *DeviceServiceImpl) Get(req *message.DevicesRequest, stream service.DeviceService_GetServer) error

Get retrieve devices from database.

func (*DeviceServiceImpl) Update

func (s *DeviceServiceImpl) Update(ctx context.Context, req *message.Device) (*message.Empty, error)

Update updates the device name.

type HumidityServiceImpl

type HumidityServiceImpl struct {
	DB *sql.DB
}

HumidityServiceImpl structure to access database.

func NewHumidityServiceImpl

func NewHumidityServiceImpl(db *sql.DB) *HumidityServiceImpl

NewHumidityServiceImpl initialize humidity service and access to database.

func (*HumidityServiceImpl) Add

func (s *HumidityServiceImpl) Add(ctx context.Context, req *message.Humidity) (*message.Humidity, error)

Add create a humidity metric.

func (*HumidityServiceImpl) GetAvgHumidity

func (s *HumidityServiceImpl) GetAvgHumidity(req *message.HumidityRequest, stream service.HumidityService_GetAvgHumidityServer) error

GetAvgHumidity get data points for average humidity metrics.

func (*HumidityServiceImpl) GetHumidity

func (s *HumidityServiceImpl) GetHumidity(req *message.HumidityRequest, stream service.HumidityService_GetHumidityServer) error

GetHumidity get data points for humidity metrics.

type PowerServiceImpl

type PowerServiceImpl struct {
	DB *sql.DB
}

PowerServiceImpl structure to access database.

func NewPowerServiceImpl

func NewPowerServiceImpl(db *sql.DB) *PowerServiceImpl

NewPowerServiceImpl initialize power service and access to database.

func (*PowerServiceImpl) Add

func (s *PowerServiceImpl) Add(ctx context.Context, req *message.Power) (*message.Power, error)

Add create a power metric.

func (*PowerServiceImpl) GetAvgConsumption

func (s *PowerServiceImpl) GetAvgConsumption(req *message.ConsumptionRequest, stream service.PowerService_GetAvgConsumptionServer) error

GetAvgConsumption get data points for average consumption metrics.

func (*PowerServiceImpl) GetPower

func (s *PowerServiceImpl) GetPower(req *message.PowerRequest, stream service.PowerService_GetPowerServer) error

GetPower get data points for power metrics.

type SensorServiceImpl

type SensorServiceImpl struct {
	DB *sql.DB
}

SensorServiceImpl structure to access database.

func NewSensorServiceImpl

func NewSensorServiceImpl(db *sql.DB) *SensorServiceImpl

NewSensorServiceImpl initialize sensor service and access to database.

func (*SensorServiceImpl) Add

func (s *SensorServiceImpl) Add(ctx context.Context, req *message.Sensor) (*message.Sensor, error)

Add creates sensor in database.

func (*SensorServiceImpl) Count

func (s *SensorServiceImpl) Count(ctx context.Context, req *message.SensorCountRequest) (*message.SensorCount, error)

Count counts the number of sensors.

func (*SensorServiceImpl) Delete

func (s *SensorServiceImpl) Delete(ctx context.Context, req *message.Sensor) (*message.Empty, error)

Delete deletes the sensor.

func (*SensorServiceImpl) Get

func (s *SensorServiceImpl) Get(req *message.SensorsRequest, stream service.SensorService_GetServer) error

Get retrieves sensors from database.

func (*SensorServiceImpl) Update

func (s *SensorServiceImpl) Update(ctx context.Context, req *message.Sensor) (*message.Empty, error)

Update updates the device ID and sensor name.

type TemperatureServiceImpl

type TemperatureServiceImpl struct {
	DB *sql.DB
}

TemperatureServiceImpl structure to access database.

func NewTemperatureServiceImpl

func NewTemperatureServiceImpl(db *sql.DB) *TemperatureServiceImpl

NewTemperatureServiceImpl initialize temperature service and access to database.

func (*TemperatureServiceImpl) Add

func (s *TemperatureServiceImpl) Add(ctx context.Context, req *message.Temperature) (*message.Temperature, error)

Add create a temperature metric.

func (*TemperatureServiceImpl) GetAvgTemperature

func (s *TemperatureServiceImpl) GetAvgTemperature(req *message.TemperatureRequest, stream service.TemperatureService_GetAvgTemperatureServer) error

GetAvgTemperature get data points for average temperature metrics.

func (*TemperatureServiceImpl) GetTemperature

func (s *TemperatureServiceImpl) GetTemperature(req *message.TemperatureRequest, stream service.TemperatureService_GetTemperatureServer) error

GetTemperature get data points for temperature metrics.