db

package

Go to main page

Versions in this module

v0

v0.0.35

Oct 4, 2021

v0.0.34

Sep 8, 2021

Changes in this version

type Influx

+ func (i *Influx) CheckConfig(config *InfluxConfig)

+ func (i *Influx) Close()

type Meta

+ ID int

type NatsHandler

+ func (nh *NatsHandler) StartMetrics(nodeID string) error

v0.0.33

Aug 12, 2021

v0.0.32

Aug 11, 2021

v0.0.31

Aug 10, 2021

v0.0.30

Jul 23, 2021

Changes in this version

+ const StoreTypeBadger

+ const StoreTypeBolt

+ const StoreTypeMemory

+ var DBVersion = 1

+ func ImportDb(gen *Db, in io.Reader) error

+ func NatsSendFileFromHTTP(nc *natsgo.Conn, deviceID string, url string, callback func(int)) error

type Db

+ func (gen *Db) Close() error

+ func (gen *Db) NodesForUser(userID string) ([]data.NodeEdge, error)

+ type Meta struct

+ RootID string

+ Version int

+ type NatsHandler struct

+ Nc *natsgo.Conn

+ func NewNatsHandler(db *Db, authToken, server string) *NatsHandler

+ func (nh *NatsHandler) Connect() (*natsgo.Conn, error)

+ func (nh *NatsHandler) StartUpdate(id, url string) error

+ type StoreType string

v0.0.29

Apr 26, 2021

v0.0.28

Apr 22, 2021

Changes in this version

type Influx

+ func (i *Influx) WritePoint(nodeID, nodeDesc string, point data.Point) error

+ type InfluxConfig struct

+ Bucket string

+ Org string

+ Token string

+ URL string

+ func NodeToInfluxConfig(node data.NodeEdge) (*InfluxConfig, error)

v0.0.27

Apr 16, 2021

v0.0.26

Apr 15, 2021

v0.0.25

Apr 13, 2021

v0.0.24

Apr 12, 2021

v0.0.23

Apr 10, 2021

Changes in this version

type Influx

+ func (i *Influx) WritePoints(points []InfluxPoint) error

v0.0.22

Mar 31, 2021

v0.0.21

Mar 22, 2021

v0.0.20

Mar 17, 2021

v0.0.19

Feb 27, 2021

v0.0.18

Feb 26, 2021

v0.0.17

Feb 12, 2021

v0.0.16

Feb 8, 2021

v0.0.15

Dec 9, 2020

v0.0.14

Nov 20, 2020

v0.0.13

Nov 3, 2020

v0.0.12

Nov 3, 2020

Changes in this version

+ type InfluxPoint struct

+ DeviceID string

+ Duration time.Duration

+ ID string

+ Max float64

+ Min float64

+ Time time.Time

+ Type string

+ Value float64

+ func PointToInfluxPoint(deviceID string, p data.Point) InfluxPoint

v0.0.11

Sep 9, 2020

Changes in this version

type Db

+ func (db *Db) DevicePoint(id string, point data.Point) error

type InfluxSample

+ func PointToInfluxSample(deviceID string, p data.Point) InfluxSample

v0.0.10

Aug 20, 2020

v0.0.9

Aug 15, 2020

Changes in this version

type Db

+ func (db *Db) DeviceDeleteCmd(id string) error

+ func (db *Db) DeviceSetSwUpdateState(id string, state data.SwUpdateState) error

v0.0.8

Aug 11, 2020

Changes in this version

type Db

+ func (db *Db) DeviceByID(id string) (data.Device, error)

+ func (db *Db) RuleByID(id uuid.UUID) (data.Rule, error)

+ func (db *Db) RuleDelete(id uuid.UUID) error

+ func (db *Db) RuleEach(callback func(rule *data.Rule) error) error

+ func (db *Db) RuleInsert(rule data.Rule) (uuid.UUID, error)

+ func (db *Db) RuleUpdateConfig(id uuid.UUID, config data.RuleConfig) error

+ func (db *Db) RuleUpdateState(id uuid.UUID, state data.RuleState) error

+ func (db *Db) Rules() ([]data.Rule, error)

+ func (db *Db) UsersForGroup(id uuid.UUID) ([]data.User, error)

+ type InfluxSample struct

+ DeviceID string

+ Duration time.Duration

+ ID string

+ Max float64

+ Min float64

+ Time time.Time

+ Type string

+ Value float64

+ func SampleToInfluxSample(deviceID string, s data.Sample) InfluxSample

v0.0.7

Jul 4, 2020

v0.0.6

Jun 26, 2020

Changes in this version

+ func DumpDb(db *Db, out io.Writer) error

type Db

+ func (db *Db) DeviceActivity(id string) error

+ func (db *Db) DeviceCmds() (ret []data.DeviceCmd, err error)

+ func (db *Db) DeviceEach(callback func(device *data.Device) error) error

+ func (db *Db) DeviceSetState(id string, state data.SysState) error

+ func (db *Db) DeviceUpdateGroups(id string, groups []uuid.UUID) error

+ func (db *Db) DevicesForGroup(tx *bolt.Tx, groupID uuid.UUID) ([]data.Device, error)

+ func (db *Db) DevicesForUser(userID uuid.UUID) ([]data.Device, error)

+ func (db *Db) Group(id uuid.UUID) (data.Group, error)

+ func (db *Db) GroupDelete(id uuid.UUID) error

+ func (db *Db) GroupInsert(group data.Group) (string, error)

+ func (db *Db) GroupUpdate(gUpdate data.Group) error

+ func (db *Db) Groups() ([]data.Group, error)

+ func (db *Db) UserByEmail(email string) (data.User, error)

+ func (db *Db) UserByID(id string) (data.User, error)

+ func (db *Db) UserCheck(email, password string) (*data.User, error)

+ func (db *Db) UserDelete(id uuid.UUID) error

+ func (db *Db) UserInsert(user data.User) (string, error)

+ func (db *Db) UserIsRoot(id uuid.UUID) (bool, error)

+ func (db *Db) UserUpdate(user data.User) error

+ func (db *Db) Users() ([]data.User, error)

v0.0.5

Jun 16, 2020

v0.0.4

May 8, 2020

v0.0.3

May 7, 2020

v0.0.2

Apr 28, 2020

v0.0.1

Apr 9, 2020

Changes in this version

+ type Db struct

+ func NewDb(dataDir string) (*Db, error)

+ func (db *Db) Device(id string) (ret data.Device, err error)

+ func (db *Db) DeviceDelete(id string) error

+ func (db *Db) DeviceGetCmd(id string) (data.DeviceCmd, error)

+ func (db *Db) DeviceSample(id string, sample data.Sample) error

+ func (db *Db) DeviceSetCmd(cmd data.DeviceCmd) error

+ func (db *Db) DeviceSetVersion(id string, ver data.DeviceVersion) error

+ func (db *Db) DeviceUpdate(device data.Device) error

+ func (db *Db) DeviceUpdateConfig(id string, config data.DeviceConfig) error

+ func (db *Db) Devices() (ret []data.Device, err error)

+ type Influx struct

+ func NewInflux(url, dbName, user, password string) (*Influx, error)

+ func (i *Influx) WriteSamples(samples []data.Sample) error

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