repository

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Import added in v0.3.0 

func Import(sourceDSNURL *url.URL, destDNSURL *url.URL, flogger logger.Logger, optImport OptImport) error

Types

type OptImport added in v0.3.0 

type OptImport struct {
	Sensors      bool
	Humidities   bool
	Pressures    bool
	Temperatures bool
}

type Repository 

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

Repository represent a repository where all devices, sensors and measured values are stored.

func New 

func New(dsnURL *url.URL, flogger logger.Logger) (*Repository, error)

New returns a new repository based on the data source name (dsn)

func (*Repository) AddDevices 

func (repo *Repository) AddDevices(devices ...*types.Device) error

AddDevices to the repository

func (*Repository) AddMeasuredValues 

func (repo *Repository) AddMeasuredValues(measuredValues ...*types.MeasuredValue) error

AddMeasuredValues to the repository

func (*Repository) AddOrUpdateDevices added in v0.3.0 

func (repo *Repository) AddOrUpdateDevices(devices ...*types.Device) error

AddOrUpdateDevices to the repository

func (*Repository) AddOrUpdateMeasuredValues added in v0.3.0 

func (repo *Repository) AddOrUpdateMeasuredValues(measuredValues ...*types.MeasuredValue) error

AddOrUpdateMeasuredValues to the repository

func (*Repository) AddOrUpdateSensors added in v0.3.0 

func (repo *Repository) AddOrUpdateSensors(sensors ...*types.Sensor) error

AddOrUpdateSensors to the repository

func (*Repository) AddSensors 

func (repo *Repository) AddSensors(sensors ...*types.Sensor) error

AddSensors to the repository

func (*Repository) Close 

func (repo *Repository) Close() error

Close closes the repository and prevents new queries from starting. Close then waits for all queries that have started processing on the server to finish.

func (*Repository) DisableSensorsByNames 

func (repo *Repository) DisableSensorsByNames(sensorNames ...string) error

DisableSensorsByNames disable all sensors which match bei their name

func (*Repository) EnableSensorsByNames 

func (repo *Repository) EnableSensorsByNames(sensorNames ...string) error

EnableSensorsByNames enable all sensors which match bei their name

func (*Repository) GetDevice 

func (repo *Repository) GetDevice(deviceID string) (*types.Device, error)

GetDevice returns a device by his id. If no device has been found, the function returns nil.

func (*Repository) GetDevices 

func (repo *Repository) GetDevices() ([]*types.Device, error)

GetDevices returns all devices. If no devices has been found, the function returns nil.

func (*Repository) GetHumidity added in v0.3.0 

func (repo *Repository) GetHumidity(humidityID string) (*types.MeasuredValue, error)

GetHumidity returns a humidity value by id

func (*Repository) GetPressure added in v0.3.0 

func (repo *Repository) GetPressure(pressureID string) (*types.MeasuredValue, error)

GetPressure returns a pressure value by id

func (*Repository) GetSensor 

func (repo *Repository) GetSensor(sensorID string) (*types.Sensor, error)

GetSensor returns a sensor by his id. If no sensor has been found, the function returns nil.

func (*Repository) GetSensors 

func (repo *Repository) GetSensors(models ...string) ([]*types.Sensor, error)

GetSensors returns all sensors. If no sensors has been found, the function returns nil.

func (*Repository) GetSensorsByDeviceID 

func (repo *Repository) GetSensorsByDeviceID(deviceID string) ([]*types.Sensor, error)

GetSensorsByDeviceID returns all sensors by a device id. If no sensor has been found by the id, the function returns nil.

func (*Repository) GetTemperature added in v0.3.0 

func (repo *Repository) GetTemperature(pressureID string) (*types.MeasuredValue, error)

GetTemperature returns a temperature value by id

func (*Repository) RemoveDevices 

func (repo *Repository) RemoveDevices(deviceIDs ...string) error

RemoveDevices removes devices by their ids from the repository. Additional all sensors and measured values, which are in relation with the device respectively the sensors will also be deleted.

func (*Repository) RemoveSensors 

func (repo *Repository) RemoveSensors(sensorIDs ...string) error

RemoveSensors removes sensors by their ids from the repository. Additional all measured values, which are in relation with the sensor will also be deleted.

func (*Repository) RemoveSensorsByNames 

func (repo *Repository) RemoveSensorsByNames(sensorNames ...string) error

RemoveSensorsByNames removes all sensors which match bei their name

func (*Repository) RenameSensors 

func (repo *Repository) RenameSensors(oldName string, newName string) error

RenameSensors all sensors which match by their current name to the new name

func (*Repository) UpdateDevices 

func (repo *Repository) UpdateDevices(devices ...*types.Device) error

UpdateDevices update devices which are stored into the repository by their id. The id of the device can not be updated.

func (*Repository) UpdateSensors 

func (repo *Repository) UpdateSensors(sensors ...*types.Sensor) error

UpdateSensors update sensors which are stored into the repository by their id. The id of the sensor can not be updated.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.