piot

package module

Go to main page

Versions in this module

v1

v1.0.7

Mar 18, 2020

v1.0.6

Mar 18, 2020

v1.0.5

Mar 17, 2020

v1.0.4

Mar 17, 2020

Changes in this version

type Things

+ func (t *Things) SetLocationMqttTopic(id primitive.ObjectID, topic string) error

+ func (t *Things) SetLocationMqttValues(id primitive.ObjectID, lat, lng, date string) error

v1.0.3

Mar 17, 2020

Changes in this version

type Things

+ func (t *Things) SetLocationTopic(id primitive.ObjectID, topic string) error

v1.0.2

Mar 16, 2020

Changes in this version

+ func InfluxDbEscapeString(str string) string

+ func PrimitiveToString(value interface{}) (string, error)

type IInfluxDb

+ PostLocation func(thing *model.Thing, loc *model.LocationData)

type InfluxDb

+ func (db *InfluxDb) PostLocation(thing *model.Thing, loc *model.LocationData)

+ type RowMetric struct

+ func NewRowMetric(name string, tags map[string]string, fields map[string]interface{}, ...) *RowMetric

+ func (rm *RowMetric) Encode() (*bytes.Buffer, error)

+ func (rm *RowMetric) FieldList() []*proto.Field

+ func (rm *RowMetric) Name() string

+ func (rm *RowMetric) TagList() []*proto.Tag

+ func (rm *RowMetric) Time() time.Time

v1.0.1

Mar 15, 2020

v1.0.0

Mar 15, 2020

Changes in this version

+ const PIOT_MEASUREMENT_TOPIC

+ const TOPIC_AVAILABLE

+ const TOPIC_HUMIDITY

+ const TOPIC_IP

+ const TOPIC_NET

+ const TOPIC_PRESSURE

+ const TOPIC_ROOT

+ const TOPIC_TEMP

+ const TOPIC_UNIT

+ const TOPIC_WIFI_SSID

+ const TOPIC_WIFI_STRENGTH

+ const VALUE_NO

+ const VALUE_YES

+ func GetPasswordHash(pwd string) (string, error)

+ func NewLogger(log_format string, level string) (*logging.Logger, error)

+ type Auth struct

+ func (a *Auth) AuthUser(ctx context.Context, email, password string) error

+ type HttpClient struct

+ func (c *HttpClient) PostString(url, body string, username *string, password *string)

+ type HttpClientMock struct

+ Calls []httpClientMockCall

+ Log *logging.Logger

+ func (c *HttpClientMock) PostString(url, body string, username *string, password *string)

+ type IHttpClient interface

+ PostString func(url, body string, username *string, password *string)

+ func NewHttpClient(log *logging.Logger) IHttpClient

+ type IInfluxDb interface

+ PostMeasurement func(thing *model.Thing, value string)

+ PostSwitchState func(thing *model.Thing, value string)

+ func NewInfluxDb(log *logging.Logger, orgs *Orgs, httpClient IHttpClient, ...) IInfluxDb

+ type IMqtt interface

+ Connect func() error

+ Disconnect func() error

+ ProcessMessage func(topic, payload string)

+ PushThingData func(thing *model.Thing, topic, value string) error

+ SetClient func(id string)

+ SetPassword func(password string)

+ SetUsername func(username string)

+ func NewMqtt(uri string, log *logging.Logger, things *Things, orgs *Orgs, ...) IMqtt

+ type IMysqlDb interface

+ Close func()

+ Open func() error

+ StoreMeasurement func(thing *model.Thing, value string)

+ StoreSwitchState func(thing *model.Thing, value string)

+ func NewMysqlDb(log *logging.Logger, orgs *Orgs, host, username, password, name string) IMysqlDb

+ type InfluxDb struct

+ Password string

+ Uri string

+ Username string

+ func (db *InfluxDb) PostMeasurement(thing *model.Thing, value string)

+ func (db *InfluxDb) PostSwitchState(thing *model.Thing, value string)

+ type InfluxDbMock struct

+ Calls []influxDbMockCall

+ Log *logging.Logger

+ func (db *InfluxDbMock) PostMeasurement(thing *model.Thing, value string)

+ func (db *InfluxDbMock) PostSwitchState(thing *model.Thing, value string)

+ type Mqtt struct

+ Client *string

+ Password *string

+ Uri string

+ Username *string

+ func (t *Mqtt) Connect() error

+ func (t *Mqtt) Disconnect() error

+ func (t *Mqtt) GetThingTopic(thing *model.Thing, topic string) (string, error)

+ func (t *Mqtt) ProcessDevices(org *model.Org, topic, payload string)

+ func (t *Mqtt) ProcessMessage(topic, payload string)

+ func (t *Mqtt) ProcessSensors(org *model.Org, topic, payload string)

+ func (t *Mqtt) ProcessSwitches(org *model.Org, topic, payload string)

+ func (t *Mqtt) PushThingData(thing *model.Thing, topic, value string) error

+ func (t *Mqtt) SetClient(id string)

+ func (t *Mqtt) SetPassword(password string)

+ func (t *Mqtt) SetUsername(username string)

+ type MysqlDb struct

+ Db *sql.DB

+ Host string

+ Name string

+ Password string

+ Username string

+ func (db *MysqlDb) Close()

+ func (db *MysqlDb) Open() error

+ func (db *MysqlDb) StoreMeasurement(thing *model.Thing, value string)

+ func (db *MysqlDb) StoreSwitchState(thing *model.Thing, value string)

+ type MysqlDbMock struct

+ Calls []mysqlDbMockCall

+ Log *logging.Logger

+ func (db *MysqlDbMock) Close()

+ func (db *MysqlDbMock) Open() error

+ func (db *MysqlDbMock) StoreMeasurement(thing *model.Thing, value string)

+ func (db *MysqlDbMock) StoreSwitchState(thing *model.Thing, value string)

+ type Orgs struct

+ func NewOrgs(log *logging.Logger, db *mongo.Database) *Orgs

+ func (t *Orgs) Get(id primitive.ObjectID) (*model.Org, error)

+ func (t *Orgs) GetByName(name string) (*model.Org, error)

+ type PiotDevices struct

+ func NewPiotDevices(logger *logging.Logger, things *Things, mqtt IMqtt, params *config.Parameters) *PiotDevices

+ func (p *PiotDevices) ProcessPacket(packet model.PiotDevicePacket) error

+ type Things struct

+ Db *mongo.Database

+ Log *logging.Logger

+ func NewThings(db *mongo.Database, log *logging.Logger) *Things

+ func (t *Things) Find(name string) (*model.Thing, error)

+ func (t *Things) FindPiot(id string) (*model.Thing, error)

+ func (t *Things) Get(id primitive.ObjectID) (*model.Thing, error)

+ func (t *Things) GetFiltered(filter interface{}) ([]*model.Thing, error)

+ func (t *Things) RegisterPiot(id string, deviceType string) (*model.Thing, error)

+ func (t *Things) SetAvailabilityTopic(id primitive.ObjectID, topic string) error

+ func (t *Things) SetAvailabilityYesNo(id primitive.ObjectID, yes, no string) error

+ func (t *Things) SetLocation(id primitive.ObjectID, location model.LocationData) error

+ func (t *Things) SetParent(id primitive.ObjectID, id_parent primitive.ObjectID) error

+ func (t *Things) SetSensorClass(id primitive.ObjectID, class string) error

+ func (t *Things) SetSensorMeasurementTopic(id primitive.ObjectID, topic string) error

+ func (t *Things) SetSensorValue(id primitive.ObjectID, value string) error

+ func (t *Things) SetSwitchState(id primitive.ObjectID, value bool) error

+ func (t *Things) SetTelemetry(id primitive.ObjectID, telemetry string) error

+ func (t *Things) TouchThing(id primitive.ObjectID) error

+ type Users struct

+ func NewUsers(log *logging.Logger, db *mongo.Database) *Users

+ func (t *Users) FindByEmail(email string) (*model.User, error)

+ func (t *Users) FindUserOrgs(id primitive.ObjectID) ([]model.Org, error)

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