postgres

package

v0.0.0-...-34aea0c Latest Latest Go to latest Published: May 10, 2022 License: AGPL-3.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/everactive/iot-devicetwin

Links

Open Source Insights

Documentation ¶

Overview ¶

Package postgres is the Datastore implementation for Postgres

Index ¶

type DataStore
- func OpenDataStore(driver, dataSource string) *DataStore

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DataStore ¶

type DataStore struct {
	*sql.DB
	// contains filtered or unexported fields
}

DataStore is the postgreSQL implementation of a data store

func OpenDataStore ¶

func OpenDataStore(driver, dataSource string) *DataStore

OpenDataStore returns an open database connection

func (*DataStore) ActionCreate ¶

func (db *DataStore) ActionCreate(act datastore.Action) (int64, error)

ActionCreate log an new action

func (*DataStore) ActionListForDevice ¶

func (db *DataStore) ActionListForDevice(orgID, deviceID string) ([]datastore.Action, error)

ActionListForDevice lists the actions for a device

func (*DataStore) ActionUpdate ¶

func (db *DataStore) ActionUpdate(actionID, status, message string) error

ActionUpdate updates an action record

func (*DataStore) DeviceCreate ¶

func (db *DataStore) DeviceCreate(device datastore.Device) (int64, error)

DeviceCreate adds a new record to device database table, returning the record ID

func (*DataStore) DeviceDelete ¶

func (db *DataStore) DeviceDelete(deviceID string) error

DeviceDelete deletes the device

func (*DataStore) DeviceGet ¶

func (db *DataStore) DeviceGet(deviceID string) (datastore.Device, error)

DeviceGet fetches a device from the database

func (*DataStore) DeviceList ¶

func (db *DataStore) DeviceList(orgID string) ([]datastore.Device, error)

DeviceList fetches the devices for an organization from the database

func (*DataStore) DevicePing ¶

func (db *DataStore) DevicePing(deviceID string, refresh time.Time) error

DevicePing updates the last ping time from a device

func (*DataStore) DeviceSnapDelete ¶

func (db *DataStore) DeviceSnapDelete(id int64) error

DeviceSnapDelete removes a snap for a device

func (*DataStore) DeviceSnapList ¶

func (db *DataStore) DeviceSnapList(deviceID int64) ([]datastore.DeviceSnap, error)

DeviceSnapList lists the snaps for a device

func (*DataStore) DeviceSnapUpsert ¶

func (db *DataStore) DeviceSnapUpsert(ds datastore.DeviceSnap) error

DeviceSnapUpsert creates or updates a device snap record

func (*DataStore) DeviceVersionDelete ¶

func (db *DataStore) DeviceVersionDelete(id int64) error

DeviceVersionDelete removes a device version

func (*DataStore) DeviceVersionGet ¶

func (db *DataStore) DeviceVersionGet(deviceID int64) (datastore.DeviceVersion, error)

DeviceVersionGet fetches a device version details from the database

func (*DataStore) DeviceVersionUpsert ¶

func (db *DataStore) DeviceVersionUpsert(dv datastore.DeviceVersion) error

DeviceVersionUpsert creates or updates a device version record

func (*DataStore) GroupCreate ¶

func (db *DataStore) GroupCreate(orgID, name string) (int64, error)

GroupCreate creates a new group for an organization

func (*DataStore) GroupGet ¶

func (db *DataStore) GroupGet(orgID, name string) (datastore.Group, error)

GroupGet fetches a group

func (*DataStore) GroupGetDevices ¶

func (db *DataStore) GroupGetDevices(orgID, name string) ([]datastore.Device, error)

GroupGetDevices retrieves the devices for a group

func (*DataStore) GroupGetExcludedDevices ¶

func (db *DataStore) GroupGetExcludedDevices(orgID, name string) ([]datastore.Device, error)

GroupGetExcludedDevices retrieves the devices not in a group

func (*DataStore) GroupLinkDevice ¶

func (db *DataStore) GroupLinkDevice(orgID, name, deviceID string) error

GroupLinkDevice links a device to a group

func (*DataStore) GroupList ¶

func (db *DataStore) GroupList(orgID string) ([]datastore.Group, error)

GroupList lists the groups for an organization

func (*DataStore) GroupUnlinkDevice ¶

func (db *DataStore) GroupUnlinkDevice(orgID, name, deviceID string) error

GroupUnlinkDevice unlinks a device from a group

Source Files ¶

View all Source files

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