adaptors

Mar 8, 2024

Changes in this version

type Adaptors

+ Tag ITag

type DashboardTab

+ func (n *DashboardTab) Import(ctx context.Context, tab *m.DashboardTab) (tabId int64, err error)

type Entity

+ func (n *Entity) Statistic(ctx context.Context) (statistic *m.EntitiesStatistic, err error)

type IDashboardTab

+ Import func(ctx context.Context, ver *m.DashboardTab) (tabId int64, err error)

type IEntity

+ Statistic func(ctx context.Context) (statistic *m.EntitiesStatistic, err error)

+ type ITag interface

+ Add func(ctx context.Context, tag *m.Tag) (id int64, err error)

+ Delete func(ctx context.Context, name string) (err error)

+ GetById func(ctx context.Context, id int64) (tag *m.Tag, err error)

+ GetByName func(ctx context.Context, name string) (tag *m.Tag, err error)

+ List func(ctx context.Context, limit, offset int64, orderBy, sort string, query *string, ...) (list []*m.Tag, total int64, err error)

+ Search func(ctx context.Context, query string, limit, offset int64) (list []*m.Tag, total int64, err error)

+ Update func(ctx context.Context, tag *m.Tag) (err error)

+ func GetTagAdaptor(d *gorm.DB) ITag

type IUserDevice

+ List func(ctx context.Context, limit, offset int64, orderBy, sort string) (list []*m.UserDevice, total int64, err error)

+ type Tag struct

+ func (n *Tag) Add(ctx context.Context, tag *m.Tag) (id int64, err error)

+ func (n *Tag) Delete(ctx context.Context, name string) (err error)

+ func (n *Tag) GetById(ctx context.Context, id int64) (tag *m.Tag, err error)

+ func (n *Tag) GetByName(ctx context.Context, name string) (tag *m.Tag, err error)

+ func (n *Tag) List(ctx context.Context, limit, offset int64, orderBy, sort string, query *string, ...) (list []*m.Tag, total int64, err error)

+ func (n *Tag) Search(ctx context.Context, query string, limit, offset int64) (list []*m.Tag, total int64, err error)

+ func (n *Tag) Update(ctx context.Context, tag *m.Tag) (err error)

type UserDevice

+ func (n *UserDevice) List(ctx context.Context, limit, offset int64, orderBy, sort string) (list []*m.UserDevice, total int64, err error)

Jan 8, 2024

Changes in this version

type Entity

+ func (n *Entity) ListPlain(ctx context.Context, limit, offset int64, orderBy, sort string, autoLoad bool, ...) (list []*m.Entity, total int64, err error)

type IEntity

+ ListPlain func(ctx context.Context, limit, offset int64, orderBy, sort string, autoLoad bool, ...) (list []*m.Entity, total int64, err error)

type ITrigger

+ ListPlain func(ctx context.Context, limit, offset int64, orderBy, sort string, ...) (list []*m.Trigger, total int64, err error)

type Trigger

+ func (n *Trigger) ListPlain(ctx context.Context, limit, offset int64, orderBy, sort string, ...) (list []*m.Trigger, total int64, err error)

Nov 2, 2023

Changes in this version

type Action

+ func (n *Action) Add(ctx context.Context, ver *m.Action) (id int64, err error)

+ func (n *Action) Delete(ctx context.Context, deviceId int64) (err error)

+ func (n *Action) GetById(ctx context.Context, id int64) (metric *m.Action, err error)

+ func (n *Action) GetByIdWithData(ctx context.Context, id int64, from, to *time.Time, metricRange *string) (metric *m.Action, err error)

+ func (n *Action) List(ctx context.Context, limit, offset int64, orderBy, sort string) (list []*m.Action, total int64, err error)

+ func (n *Action) Search(ctx context.Context, query string, limit, offset int) (list []*m.Action, total int64, err error)

+ func (n *Action) Update(ctx context.Context, ver *m.Action) error

type Adaptors

+ ScriptVersion IScriptVersion

type Condition

+ func (n *Condition) Add(ctx context.Context, ver *m.Condition) (id int64, err error)

+ func (n *Condition) Delete(ctx context.Context, deviceId int64) (err error)

+ func (n *Condition) GetById(ctx context.Context, id int64) (metric *m.Condition, err error)

+ func (n *Condition) GetByIdWithData(ctx context.Context, id int64, from, to *time.Time, metricRange *string) (metric *m.Condition, err error)

+ func (n *Condition) List(ctx context.Context, limit, offset int64, orderBy, sort string) (list []*m.Condition, total int64, err error)

+ func (n *Condition) Search(ctx context.Context, query string, limit, offset int) (list []*m.Condition, total int64, err error)

+ func (n *Condition) Update(ctx context.Context, ver *m.Condition) error

type Entity

+ func (n *Entity) GetByIdsSimple(ctx context.Context, ids []common.EntityId) (list []*m.Entity, err error)

+ func (n *Entity) UpdateAutoload(ctx context.Context, entityId common.EntityId, autoLoad bool) (err error)

type IAction

+ Add func(ctx context.Context, ver *m.Action) (id int64, err error)

+ Delete func(ctx context.Context, deviceId int64) (err error)

+ GetById func(ctx context.Context, id int64) (metric *m.Action, err error)

+ List func(ctx context.Context, limit, offset int64, orderBy, sort string) (list []*m.Action, total int64, err error)

+ Search func(ctx context.Context, query string, limit, offset int) (list []*m.Action, total int64, err error)

+ Update func(ctx context.Context, ver *m.Action) error

type ICondition

+ Add func(ctx context.Context, ver *m.Condition) (id int64, err error)

+ Delete func(ctx context.Context, deviceId int64) (err error)

+ GetById func(ctx context.Context, id int64) (metric *m.Condition, err error)

+ List func(ctx context.Context, limit, offset int64, orderBy, sort string) (list []*m.Condition, total int64, err error)

+ Search func(ctx context.Context, query string, limit, offset int) (list []*m.Condition, total int64, err error)

+ Update func(ctx context.Context, ver *m.Condition) error

type IEntity

+ GetByIdsSimple func(ctx context.Context, ids []common.EntityId) (list []*m.Entity, err error)

+ UpdateAutoload func(ctx context.Context, entityId common.EntityId, autoLoad bool) (err error)

type IMetricBucket

+ List func(ctx context.Context, from, to *time.Time, metricId int64, optionItems []string, ...) (list []*m.MetricDataItem, err error)

type IRunHistory

+ DeleteOldest func(ctx context.Context, days int) (err error)

type IScript

+ Statistic func(ctx context.Context) (statistic *m.ScriptsStatistic, err error)

+ type IScriptVersion interface

+ Delete func(ctx context.Context, id int64) (err error)

+ DeleteOldest func(ctx context.Context, days int) (err error)

+ func GetScriptVersionAdaptor(d *gorm.DB) IScriptVersion

type ITrigger

+ Add func(ctx context.Context, ver *m.Trigger) (id int64, err error)

+ Delete func(ctx context.Context, deviceId int64) (err error)

+ Disable func(ctx context.Context, id int64) (err error)

+ Enable func(ctx context.Context, id int64) (err error)

+ GetById func(ctx context.Context, id int64) (metric *m.Trigger, err error)

+ List func(ctx context.Context, limit, offset int64, orderBy, sort string, ...) (list []*m.Trigger, total int64, err error)

+ Search func(ctx context.Context, query string, limit, offset int) (list []*m.Trigger, total int64, err error)

+ Update func(ctx context.Context, ver *m.Trigger) error

type MetricBucket

+ func (n *MetricBucket) List(ctx context.Context, from, to *time.Time, metricId int64, optionItems []string, ...) (list []*m.MetricDataItem, err error)

type RunHistory

+ func (n *RunHistory) DeleteOldest(ctx context.Context, days int) (err error)

type Script

+ func (n *Script) Statistic(ctx context.Context) (statistic *m.ScriptsStatistic, err error)

+ type ScriptVersion struct

+ func (n *ScriptVersion) Delete(ctx context.Context, id int64) (err error)

type Trigger

+ func (n *Trigger) Add(ctx context.Context, ver *m.Trigger) (id int64, err error)

+ func (n *Trigger) Delete(ctx context.Context, deviceId int64) (err error)

+ func (n *Trigger) Disable(ctx context.Context, id int64) (err error)

+ func (n *Trigger) Enable(ctx context.Context, id int64) (err error)

+ func (n *Trigger) GetById(ctx context.Context, id int64) (metric *m.Trigger, err error)

+ func (n *Trigger) GetByIdWithData(ctx context.Context, id int64, from, to *time.Time, metricRange *string) (metric *m.Trigger, err error)

+ func (n *Trigger) List(ctx context.Context, limit, offset int64, orderBy, sort string, ...) (list []*m.Trigger, total int64, err error)

+ func (n *Trigger) Search(ctx context.Context, query string, limit, offset int) (list []*m.Trigger, total int64, err error)

+ func (n *Trigger) Update(ctx context.Context, ver *m.Trigger) error

Jun 23, 2023

Changes in this version

type ITask

+ Import func(ver *m.Task) (err error)

type Task

+ func (n *Task) Import(ver *m.Task) (err error)

Jun 8, 2023

Changes in this version

type Adaptors

+ UserDevice IUserDevice

+ type IUserDevice interface

+ Add func(ver *m.UserDevice) (id int64, err error)

+ Delete func(id int64) (err error)

+ GetByUserId func(userId int64) (list []*m.UserDevice, err error)

+ func GetUserDeviceAdaptor(d *gorm.DB) IUserDevice

+ type UserDevice struct

+ func (n *UserDevice) Add(ver *m.UserDevice) (id int64, err error)

+ func (n *UserDevice) Delete(id int64) (err error)

+ func (n *UserDevice) GetByUserId(userId int64) (list []*m.UserDevice, err error)

Oct 8, 2022

Changes in this version

type EntityStorage

+ func (n *EntityStorage) DeleteOldest(days int) (err error)

type IEntityStorage

+ DeleteOldest func(days int) (err error)

type IVariable

+ Search func(query string, limit, offset int) (list []m.Variable, total int64, err error)

type Variable

+ func (s *Variable) Search(query string, limit, offset int) (list []m.Variable, total int64, err error)

Sep 29, 2022

Changes in this version

type ILog

+ DeleteOldest func(days int) (err error)

type Log

+ func (n *Log) DeleteOldest(days int) (err error)

Aug 18, 2022

Changes in this version

type Entity

+ func (n *Entity) Import(ver *m.Entity) (err error)

type IEntity

+ Import func(entity *m.Entity) (err error)

Aug 14, 2022

Changes in this version

type Dashboard

+ func (n *Dashboard) Search(query string, limit, offset int64) (list []*m.Dashboard, total int64, err error)

type IDashboard

+ Search func(query string, limit, offset int64) (list []*m.Dashboard, total int64, err error)

Aug 3, 2022

Changes in this version

type Adaptors

+ Dashboard IDashboard

+ DashboardCard IDashboardCard

+ DashboardCardItem IDashboardCardItem

+ DashboardTab IDashboardTab

+ type Dashboard struct

+ func (n *Dashboard) Add(ver *m.Dashboard) (id int64, err error)

+ func (n *Dashboard) Delete(id int64) (err error)

+ func (n *Dashboard) GetById(mapId int64) (ver *m.Dashboard, err error)

+ func (n *Dashboard) Import(ver *m.Dashboard) (boardId int64, err error)

+ func (n *Dashboard) List(limit, offset int64, orderBy, sort string) (list []*m.Dashboard, total int64, err error)

+ func (n *Dashboard) Update(ver *m.Dashboard) (err error)

+ type DashboardCard struct

+ func (n *DashboardCard) Add(ver *m.DashboardCard) (id int64, err error)

+ func (n *DashboardCard) Delete(id int64) (err error)

+ func (n *DashboardCard) GetById(mapId int64) (ver *m.DashboardCard, err error)

+ func (n *DashboardCard) Import(card *m.DashboardCard) (cardId int64, err error)

+ func (n *DashboardCard) List(limit, offset int64, orderBy, sort string) (list []*m.DashboardCard, total int64, err error)

+ func (n *DashboardCard) Update(ver *m.DashboardCard) (err error)

+ type DashboardCardItem struct

+ func (n *DashboardCardItem) Add(ver *m.DashboardCardItem) (id int64, err error)

+ func (n *DashboardCardItem) Delete(id int64) (err error)

+ func (n *DashboardCardItem) GetById(mapId int64) (ver *m.DashboardCardItem, err error)

+ func (n *DashboardCardItem) List(limit, offset int64, orderBy, sort string) (list []*m.DashboardCardItem, total int64, err error)

+ func (n *DashboardCardItem) Update(ver *m.DashboardCardItem) (err error)

+ type DashboardTab struct

+ func (n *DashboardTab) Add(ver *m.DashboardTab) (id int64, err error)

+ func (n *DashboardTab) Delete(id int64) (err error)

+ func (n *DashboardTab) GetById(mapId int64) (ver *m.DashboardTab, err error)

+ func (n *DashboardTab) List(limit, offset int64, orderBy, sort string) (list []*m.DashboardTab, total int64, err error)

+ func (n *DashboardTab) Update(ver *m.DashboardTab) (err error)

type Entity

+ func (n *Entity) GetByIds(ids []common.EntityId) (list []*m.Entity, err error)

type EntityStorage

+ func (n *EntityStorage) ListByEntityId(limit, offset int64, orderBy, sort string, entityId common.EntityId, ...) (list []*m.EntityStorage, total int64, err error)

+ type IDashboard interface

+ Add func(ver *m.Dashboard) (id int64, err error)

+ Delete func(id int64) (err error)

+ GetById func(mapId int64) (ver *m.Dashboard, err error)

+ Import func(*m.Dashboard) (int64, error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.Dashboard, total int64, err error)

+ Update func(ver *m.Dashboard) (err error)

+ func GetDashboardAdaptor(d *gorm.DB) IDashboard

+ type IDashboardCard interface

+ Add func(ver *m.DashboardCard) (id int64, err error)

+ Delete func(id int64) (err error)

+ GetById func(mapId int64) (ver *m.DashboardCard, err error)

+ Import func(card *m.DashboardCard) (cardId int64, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.DashboardCard, total int64, err error)

+ Update func(ver *m.DashboardCard) (err error)

+ func GetDashboardCardAdaptor(d *gorm.DB) IDashboardCard

+ type IDashboardCardItem interface

+ Add func(ver *m.DashboardCardItem) (id int64, err error)

+ Delete func(id int64) (err error)

+ GetById func(mapId int64) (ver *m.DashboardCardItem, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.DashboardCardItem, total int64, err error)

+ Update func(ver *m.DashboardCardItem) (err error)

+ func GetDashboardCardItemAdaptor(d *gorm.DB) IDashboardCardItem

+ type IDashboardTab interface

+ Add func(ver *m.DashboardTab) (id int64, err error)

+ Delete func(id int64) (err error)

+ GetById func(mapId int64) (ver *m.DashboardTab, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.DashboardTab, total int64, err error)

+ Update func(ver *m.DashboardTab) (err error)

+ func GetDashboardTabAdaptor(d *gorm.DB) IDashboardTab

type IEntity

+ GetByIds func(ids []common.EntityId) (ver []*m.Entity, err error)

type IEntityStorage

+ ListByEntityId func(limit, offset int64, orderBy, sort string, entityId common.EntityId, ...) (list []*m.EntityStorage, total int64, err error)

Feb 5, 2022

Changes in this version

type ITask

+ Disable func(id int64) (err error)

+ Enable func(id int64) (err error)

type Task

+ func (n *Task) Disable(id int64) (err error)

+ func (n *Task) Enable(id int64) (err error)

Jan 27, 2022

Changes in this version

type ITask

+ GetById func(id int64) (task *m.Task, err error)

type IZigbee2mqttDevice

+ ListByBridgeId func(bridgeId, limit, offset int64) (list []*m.Zigbee2mqttDevice, total int64, err error)

type Task

+ func (n *Task) GetById(id int64) (task *m.Task, err error)

type Zigbee2mqttDevice

+ func (n *Zigbee2mqttDevice) ListByBridgeId(bridgeId, limit, offset int64) (list []*m.Zigbee2mqttDevice, total int64, err error)

Dec 8, 2021

Changes in this version

type ITask

+ Update func(ver *m.Task) (err error)

type Task

+ func (n *Task) Update(ver *m.Task) (err error)

Nov 28, 2021

Changes in this version

+ type Action struct

+ func (n *Action) AddMultiple(items []*m.Action) (err error)

+ func (n *Action) DeleteByTaskId(id int64) (err error)

type Adaptors

+ Action IAction

+ Area IArea

+ Condition ICondition

+ Entity IEntity

+ EntityAction IEntityAction

+ EntityState IEntityState

+ EntityStorage IEntityStorage

+ Metric IMetric

+ MetricBucket IMetricBucket

+ Plugin IPlugin

+ RunHistory IRunHistory

+ Task ITask

+ TelegramChat ITelegramChat

+ Trigger ITrigger

+ type Area struct

+ func (a *Area) GetByName(name string) (ver *m.Area, err error)

+ func (n *Area) Add(ver *m.Area) (id int64, err error)

+ func (n *Area) DeleteByName(name string) (err error)

+ func (n *Area) GetById(verId int64) (ver *m.Area, err error)

+ func (n *Area) List(limit, offset int64, orderBy, sort string) (list []*m.Area, total int64, err error)

+ func (n *Area) Search(query string, limit, offset int) (list []*m.Area, total int64, err error)

+ func (n *Area) Update(ver *m.Area) (err error)

+ type Condition struct

+ func (n *Condition) AddMultiple(items []*m.Condition) (err error)

+ func (n *Condition) DeleteByTaskId(id int64) (err error)

+ type Entity struct

+ func (n *Entity) Add(ver *m.Entity) (err error)

+ func (n *Entity) AppendMetric(entityId common.EntityId, metric m.Metric) (err error)

+ func (n *Entity) Delete(id common.EntityId) (err error)

+ func (n *Entity) DeleteMetric(entityId common.EntityId, metric m.Metric) (err error)

+ func (n *Entity) GetById(id common.EntityId) (ver *m.Entity, err error)

+ func (n *Entity) GetByType(t string, limit, offset int64) (list []*m.Entity, err error)

+ func (n *Entity) List(limit, offset int64, orderBy, sort string, autoLoad bool) (list []*m.Entity, total int64, err error)

+ func (n *Entity) Search(query string, limit, offset int) (list []*m.Entity, total int64, err error)

+ func (n *Entity) Update(ver *m.Entity) (err error)

+ func (n *Entity) UpdateSettings(entity common.EntityId, settings m.Attributes) (err error)

+ type EntityAction struct

+ func (n *EntityAction) Add(ver *m.EntityAction) (id int64, err error)

+ func (n *EntityAction) AddMultiple(items []*m.EntityAction) (err error)

+ func (n *EntityAction) DeleteByEntityId(id common.EntityId) (err error)

+ type EntityState struct

+ func (n *EntityState) Add(ver *m.EntityState) (id int64, err error)

+ func (n *EntityState) AddMultiple(items []*m.EntityState) (err error)

+ func (n *EntityState) DeleteByEntityId(entityId common.EntityId) (err error)

+ type EntityStorage struct

+ func (n *EntityStorage) Add(ver m.EntityStorage) (id int64, err error)

+ func (n *EntityStorage) GetLastByEntityId(entityId common.EntityId) (ver m.EntityStorage, err error)

+ func (n *EntityStorage) List(limit, offset int64, orderBy, sort string) (list []m.EntityStorage, total int64, err error)

+ type IAction interface

+ AddMultiple func(items []*m.Action) (err error)

+ DeleteByTaskId func(id int64) (err error)

+ func GetActionAdaptor(d *gorm.DB) IAction

+ type IAlexaIntent interface

+ Add func(ver *m.AlexaIntent) (err error)

+ Delete func(ver *m.AlexaIntent) (err error)

+ GetByName func(name string) (ver *m.AlexaIntent, err error)

+ Update func(ver *m.AlexaIntent) (err error)

+ type IAlexaSkill interface

+ Add func(app *m.AlexaSkill) (id int64, err error)

+ Delete func(appId int64) (err error)

+ GetById func(appId int64) (app *m.AlexaSkill, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.AlexaSkill, total int64, err error)

+ ListEnabled func(limit, offset int64) (list []*m.AlexaSkill, err error)

+ Update func(params *m.AlexaSkill) (err error)

+ type IArea interface

+ Add func(ver *m.Area) (id int64, err error)

+ DeleteByName func(name string) (err error)

+ GetById func(verId int64) (ver *m.Area, err error)

+ GetByName func(name string) (ver *m.Area, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.Area, total int64, err error)

+ Search func(query string, limit, offset int) (list []*m.Area, total int64, err error)

+ Update func(ver *m.Area) (err error)

+ func GetAreaAdaptor(d *gorm.DB) IArea

+ type ICondition interface

+ AddMultiple func(items []*m.Condition) (err error)

+ DeleteByTaskId func(id int64) (err error)

+ func GetConditionAdaptor(d *gorm.DB) ICondition

+ type IEntity interface

+ Add func(ver *m.Entity) (err error)

+ AppendMetric func(entityId common.EntityId, metric m.Metric) (err error)

+ Delete func(id common.EntityId) (err error)

+ DeleteMetric func(entityId common.EntityId, metric m.Metric) (err error)

+ GetById func(id common.EntityId) (ver *m.Entity, err error)

+ GetByType func(t string, limit, offset int64) (list []*m.Entity, err error)

+ List func(limit, offset int64, orderBy, sort string, autoLoad bool) (list []*m.Entity, total int64, err error)

+ Search func(query string, limit, offset int) (list []*m.Entity, total int64, err error)

+ Update func(ver *m.Entity) (err error)

+ UpdateSettings func(entityId common.EntityId, settings m.Attributes) (err error)

+ func GetEntityAdaptor(d *gorm.DB) IEntity

+ type IEntityAction interface

+ Add func(ver *m.EntityAction) (id int64, err error)

+ AddMultiple func(items []*m.EntityAction) (err error)

+ DeleteByEntityId func(id common.EntityId) (err error)

+ func GetEntityActionAdaptor(d *gorm.DB) IEntityAction

+ type IEntityState interface

+ Add func(ver *m.EntityState) (id int64, err error)

+ AddMultiple func(items []*m.EntityState) (err error)

+ DeleteByEntityId func(entityId common.EntityId) (err error)

+ func GetEntityStateAdaptor(d *gorm.DB) IEntityState

+ type IEntityStorage interface

+ Add func(ver m.EntityStorage) (id int64, err error)

+ GetLastByEntityId func(entityId common.EntityId) (ver m.EntityStorage, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []m.EntityStorage, total int64, err error)

+ func GetEntityStorageAdaptor(d *gorm.DB) IEntityStorage

+ type IImage interface

+ Add func(ver *m.Image) (id int64, err error)

+ AddMultiple func(items []*m.Image) (err error)

+ Delete func(mapId int64) (err error)

+ GetAllByDate func(filter string) (images []*m.Image, err error)

+ GetById func(mapId int64) (ver *m.Image, err error)

+ GetByImageName func(imageName string) (ver *m.Image, err error)

+ GetFilterList func() (filterList []*m.ImageFilterList, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.Image, total int64, err error)

+ Update func(ver *m.Image) (err error)

+ UploadImage func(reader *bufio.Reader, fileName string) (file *m.Image, err error)

+ type ILog interface

+ Add func(ver *m.Log) (id int64, err error)

+ AddMultiple func(items []*m.Log) (err error)

+ Delete func(verId int64) (err error)

+ GetById func(verId int64) (ver *m.Log, err error)

+ List func(limit, offset int64, orderBy, sort string, queryObj *m.LogQuery) (list []*m.Log, total int64, err error)

+ Search func(query string, limit, offset int) (list []*m.Log, total int64, err error)

+ type IMap interface

+ Add func(ver *m.Map) (id int64, err error)

+ Delete func(mapId int64) (err error)

+ GetById func(mapId int64) (ver *m.Map, err error)

+ GetFullById func(mapId int64) (ver *m.Map, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.Map, total int64, err error)

+ Search func(query string, limit, offset int) (list []*m.Map, total int64, err error)

+ Update func(ver *m.Map) (err error)

+ type IMapElement interface

+ Add func(ver *m.MapElement) (id int64, err error)

+ Delete func(mapId int64) (err error)

+ GetActiveElements func(sortBy, order string, limit, offset int) (result []*m.MapElement, total int64, err error)

+ GetById func(mapId int64) (ver *m.MapElement, err error)

+ GetByName func(name string) (ver *m.MapElement, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.MapElement, total int64, err error)

+ Sort func(ver *m.MapElement) (err error)

+ Update func(ver *m.MapElement) (err error)

+ type IMapImage interface

+ Add func(ver *m.MapImage) (id int64, err error)

+ Delete func(mapId int64) (err error)

+ GetById func(mapId int64) (ver *m.MapImage, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.MapImage, total int64, err error)

+ Sort func(ver *m.MapImage) (err error)

+ Update func(ver *m.MapImage) (err error)

+ type IMapLayer interface

+ Add func(ver *m.MapLayer) (id int64, err error)

+ Delete func(mapId int64) (err error)

+ GetById func(mapId int64) (ver *m.MapLayer, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.MapLayer, total int64, err error)

+ Sort func(ver *m.MapLayer) (err error)

+ Update func(ver *m.MapLayer) (err error)

+ type IMapText interface

+ Add func(ver *m.MapText) (id int64, err error)

+ Delete func(mapId int64) (err error)

+ GetById func(mapId int64) (ver *m.MapText, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.MapText, total int64, err error)

+ Sort func(ver *m.MapText) (err error)

+ Update func(ver *m.MapText) (err error)

+ type IMessage interface

+ Add func(msg m.Message) (id int64, err error)

+ type IMessageDelivery interface

+ Add func(msg m.MessageDelivery) (id int64, err error)

+ Delete func(id int64) (err error)

+ GetAllUncompleted func(limit, offset int64) (list []m.MessageDelivery, total int64, err error)

+ GetById func(id int64) (ver m.MessageDelivery, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []m.MessageDelivery, total int64, err error)

+ SetStatus func(msg m.MessageDelivery) (err error)

+ type IMetric interface

+ Add func(ver m.Metric) (id int64, err error)

+ AddMultiple func(items []m.Metric) (err error)

+ Delete func(deviceId int64) (err error)

+ GetById func(id int64) (metric m.Metric, err error)

+ GetByIdWithData func(id int64, from, to *time.Time, metricRange *string) (metric m.Metric, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []m.Metric, total int64, err error)

+ Search func(query string, limit, offset int) (list []m.Metric, total int64, err error)

+ Update func(ver m.Metric) error

+ func GetMetricAdaptor(d *gorm.DB, orm *orm.Orm) IMetric

+ type IMetricBucket interface

+ Add func(ver m.MetricDataItem) error

+ AddMultiple func(items []m.MetricDataItem) (err error)

+ CreateHypertable func() (err error)

+ DeleteById func(id int64) (err error)

+ DeleteByMetricId func(metricId int64) (err error)

+ DeleteOldest func(days int) (err error)

+ Simple24HPreview func(metricId int64, optionItems []string) (list []m.MetricDataItem, err error)

+ SimpleListWithSoftRange func(_from, _to *time.Time, metricId int64, _metricRange *string, ...) (list []m.MetricDataItem, err error)

+ func GetMetricBucketAdaptor(d *gorm.DB, orm *orm.Orm) IMetricBucket

+ type IPermission interface

+ Add func(permission *m.Permission) (id int64, err error)

+ Delete func(roleName, packageName string, levelName []string) (err error)

+ GetAllPermissions func(roleName string) (permissions []*m.Permission, err error)

+ type IPlugin interface

+ Add func(plugin m.Plugin) error

+ CreateOrUpdate func(ver m.Plugin) error

+ Delete func(pluginId string) error

+ GetByName func(name string) (ver m.Plugin, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []m.Plugin, total int64, err error)

+ Search func(query string, limit, offset int) (list []m.Plugin, total int64, err error)

+ Update func(plugin m.Plugin) error

+ func GetPluginAdaptor(d *gorm.DB) IPlugin

+ type IRole interface

+ Add func(role *m.Role) (err error)

+ Delete func(name string) (err error)

+ GetAccessList func(role *m.Role) (err error)

+ GetByName func(name string) (role *m.Role, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.Role, total int64, err error)

+ Search func(query string, limit, offset int) (list []*m.Role, total int64, err error)

+ Update func(role *m.Role) (err error)

+ type IRunHistory interface

+ Add func(story *m.RunStory) (id int64, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.RunStory, total int64, err error)

+ Update func(story *m.RunStory) (err error)

+ func GetRunHistoryAdaptor(d *gorm.DB) IRunHistory

+ type IScript interface

+ Add func(script *m.Script) (id int64, err error)

+ Delete func(scriptId int64) (err error)

+ GetById func(scriptId int64) (script *m.Script, err error)

+ GetByName func(name string) (script *m.Script, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.Script, total int64, err error)

+ Search func(query string, limit, offset int) (list []*m.Script, total int64, err error)

+ Update func(script *m.Script) (err error)

+ type IStorage interface

+ CreateOrUpdate func(ver m.Storage) (err error)

+ Delete func(name string) (err error)

+ GetByName func(name string) (ver m.Storage, err error)

+ Search func(query string, limit, offset int) (list []m.Storage, total int64, err error)

+ type ITask interface

+ Add func(ver *m.Task) (err error)

+ Delete func(id int64) (err error)

+ List func(limit, offset int64, orderBy, sort string, onlyEnabled bool) (list []*m.Task, total int64, err error)

+ func GetTaskAdaptor(d *gorm.DB) ITask

+ type ITelegramChat interface

+ Add func(plugin m.TelegramChat) (err error)

+ Delete func(entityId common.EntityId, channelId int64) (err error)

+ List func(limit, offset int64, orderBy, sort string, entityId common.EntityId) (list []m.TelegramChat, total int64, err error)

+ func GetTelegramChannelAdaptor(d *gorm.DB) ITelegramChat

+ type ITemplate interface

+ Create func(ver *m.Template) (err error)

+ Delete func(name string) (err error)

+ GetByName func(name string) (ver *m.Template, err error)

+ GetItemByName func(name string) (ver *m.Template, err error)

+ GetItemsSortedList func() (count int64, items []string, err error)

+ GetItemsTree func() (tree []*m.TemplateTree, err error)

+ GetList func(templateType m.TemplateType) (items []*m.Template, err error)

+ GetMarkers func(template *m.Template) (err error)

+ Render func(name string, params map[string]interface{}) (render *m.TemplateRender, err error)

+ Search func(query string, limit, offset int) (list []*m.Template, total int64, err error)

+ UpdateItemsTree func(tree []*m.TemplateTree) (err error)

+ UpdateOrCreate func(ver *m.Template) (err error)

+ UpdateStatus func(ver *m.Template) (err error)

+ type ITrigger interface

+ AddMultiple func(items []*m.Trigger) (err error)

+ DeleteByTaskId func(id int64) (err error)

+ func GetTriggerAdaptor(d *gorm.DB) ITrigger

+ type IUser interface

+ Add func(user *m.User) (id int64, err error)

+ ClearResetPassToken func(u *m.User) (err error)

+ ClearToken func(u *m.User) (err error)

+ Delete func(userId int64) (err error)

+ GenResetPassToken func(u *m.User) (token string, err error)

+ GetByAuthenticationToken func(token string) (user *m.User, err error)

+ GetByEmail func(email string) (user *m.User, err error)

+ GetById func(userId int64) (user *m.User, err error)

+ GetByNickname func(nick string) (user *m.User, err error)

+ GetByResetPassToken func(token string) (user *m.User, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []*m.User, total int64, err error)

+ SignIn func(u *m.User, ipv4 string) (err error)

+ Update func(user *m.User) (err error)

+ type IUserMeta interface

+ UpdateOrCreate func(meta *m.UserMeta) (id int64, err error)

+ type IVariable interface

+ Add func(ver m.Variable) (err error)

+ CreateOrUpdate func(ver m.Variable) (err error)

+ Delete func(name string) (err error)

+ GetAllEnabled func() (list []m.Variable, err error)

+ GetByName func(name string) (ver m.Variable, err error)

+ List func(limit, offset int64, orderBy, sort string) (list []m.Variable, total int64, err error)

+ Update func(variable m.Variable) (err error)

+ type IZigbee2mqtt interface

+ Add func(ver *m.Zigbee2mqtt) (id int64, err error)

+ Delete func(id int64) (err error)

+ GetById func(id int64) (ver *m.Zigbee2mqtt, err error)

+ GetByLogin func(login string) (ver *m.Zigbee2mqtt, err error)

+ List func(limit, offset int64) (list []*m.Zigbee2mqtt, total int64, err error)

+ Update func(ver *m.Zigbee2mqtt) (err error)

+ type IZigbee2mqttDevice interface

+ Add func(ver *m.Zigbee2mqttDevice) (err error)

+ Delete func(id string) (err error)

+ GetById func(id string) (ver *m.Zigbee2mqttDevice, err error)

+ List func(limit, offset int64) (list []*m.Zigbee2mqttDevice, total int64, err error)

+ Search func(query string, limit, offset int) (list []*m.Zigbee2mqttDevice, total int64, err error)

+ Update func(ver *m.Zigbee2mqttDevice) (err error)

+ type Metric struct

+ func (n *Metric) Add(ver m.Metric) (id int64, err error)

+ func (n *Metric) AddMultiple(items []m.Metric) (err error)

+ func (n *Metric) Delete(deviceId int64) (err error)

+ func (n *Metric) GetById(id int64) (metric m.Metric, err error)

+ func (n *Metric) GetByIdWithData(id int64, from, to *time.Time, metricRange *string) (metric m.Metric, err error)

+ func (n *Metric) List(limit, offset int64, orderBy, sort string) (list []m.Metric, total int64, err error)

+ func (n *Metric) Search(query string, limit, offset int) (list []m.Metric, total int64, err error)

+ func (n *Metric) Update(ver m.Metric) error

+ type MetricBucket struct

+ func (n *MetricBucket) Add(ver m.MetricDataItem) error

+ func (n *MetricBucket) AddMultiple(items []m.MetricDataItem) (err error)

+ func (n *MetricBucket) CreateHypertable() (err error)

+ func (n *MetricBucket) DeleteById(id int64) (err error)

+ func (n *MetricBucket) DeleteByMetricId(metricId int64) (err error)

+ func (n *MetricBucket) DeleteOldest(days int) (err error)

+ func (n *MetricBucket) Simple24HPreview(metricId int64, optionItems []string) (list []m.MetricDataItem, err error)

+ func (n *MetricBucket) SimpleListWithSoftRange(_from, _to *time.Time, metricId int64, _metricRange *string, ...) (list []m.MetricDataItem, err error)

+ type Plugin struct

+ func (p *Plugin) Add(plugin m.Plugin) (err error)

+ func (p *Plugin) CreateOrUpdate(ver m.Plugin) (err error)

+ func (p *Plugin) Delete(name string) (err error)

+ func (p *Plugin) GetByName(name string) (ver m.Plugin, err error)

+ func (p *Plugin) List(limit, offset int64, orderBy, sort string) (list []m.Plugin, total int64, err error)

+ func (p *Plugin) Search(query string, limit, offset int) (list []m.Plugin, total int64, err error)

+ func (p *Plugin) Update(plugin m.Plugin) (err error)

+ type RunHistory struct

+ func (n *RunHistory) Add(story *m.RunStory) (id int64, err error)

+ func (n *RunHistory) List(limit, offset int64, orderBy, sort string) (list []*m.RunStory, total int64, err error)

+ func (n *RunHistory) Update(story *m.RunStory) (err error)

type Script

+ func (n *Script) GetByName(name string) (script *m.Script, err error)

+ type Task struct

+ func (n *Task) Add(ver *m.Task) (err error)

+ func (n *Task) Delete(id int64) (err error)

+ func (n *Task) List(limit, offset int64, orderBy, sort string, onlyEnabled bool) (list []*m.Task, total int64, err error)

+ type TelegramChat struct

+ func (p *TelegramChat) Add(plugin m.TelegramChat) (err error)

+ func (p *TelegramChat) Delete(entityId common.EntityId, channelId int64) (err error)

+ func (p *TelegramChat) List(limit, offset int64, orderBy, sort string, entityId common.EntityId) (list []m.TelegramChat, total int64, err error)

+ type Trigger struct

+ func (n *Trigger) AddMultiple(items []*m.Trigger) (err error)

+ func (n *Trigger) DeleteByTaskId(id int64) (err error)

type Variable

+ func (n *Variable) CreateOrUpdate(ver m.Variable) (err error)

Apr 11, 2020

Changes in this version

type Adaptors

+ Storage *Storage

+ type Storage struct

+ func GetStorageAdaptor(d *gorm.DB) *Storage

+ func (s *Storage) CreateOrUpdate(ver m.Storage) (err error)

+ func (s *Storage) Delete(name string) (err error)

+ func (s *Storage) GetByName(name string) (ver m.Storage, err error)

+ func (s *Storage) Search(query string, limit, offset int) (list []m.Storage, total int64, err error)

Apr 8, 2020

Changes in this version

type Adaptors

+ AlexaIntent *AlexaIntent

+ AlexaSkill *AlexaSkill

+ type AlexaIntent struct

+ func GetAlexaIntentAdaptor(d *gorm.DB) *AlexaIntent

+ func (n *AlexaIntent) Add(ver *m.AlexaIntent) (id int64, err error)

+ func (n *AlexaIntent) Delete(ver *m.AlexaIntent) (err error)

+ func (n *AlexaIntent) GetByName(name string) (ver *m.AlexaIntent, err error)

+ func (n *AlexaIntent) Update(ver *m.AlexaIntent) (err error)

+ type AlexaSkill struct

+ func GetAlexaSkillAdaptor(d *gorm.DB) *AlexaSkill

+ func (n *AlexaSkill) Add(app *m.AlexaSkill) (id int64, err error)

+ func (n *AlexaSkill) Delete(appId int64) (err error)

+ func (n *AlexaSkill) GetById(appId int64) (app *m.AlexaSkill, err error)

+ func (n *AlexaSkill) List(limit, offset int64, orderBy, sort string) (list []*m.AlexaSkill, total int64, err error)

+ func (n *AlexaSkill) ListEnabled(limit, offset int64) (list []*m.AlexaSkill, err error)

+ func (n *AlexaSkill) Update(params *m.AlexaSkill) (err error)

type Device

+ func (n *Device) GetByDeviceActionId(deviceActionId int64) (device *m.Device, err error)

Mar 31, 2020

Changes in this version

type Adaptors

+ MapDeviceHistory *MapDeviceHistory

type Image

+ func (n *Image) GetByImageName(imageName string) (ver *m.Image, err error)

+ type MapDeviceHistory struct

+ func GetMapDeviceHistoryAdaptor(d *gorm.DB) *MapDeviceHistory

+ func (n *MapDeviceHistory) Add(ver m.MapDeviceHistory) (id int64, err error)

+ func (n *MapDeviceHistory) List(limit, offset int) (list []*m.MapDeviceHistory, err error)

+ func (n *MapDeviceHistory) ListByDeviceId(mapDeviceId int64, limit, offset int) (list []*m.MapDeviceHistory, total int64, err error)

+ func (n *MapDeviceHistory) ListByElementId(mapElementId int64, limit, offset int) (list []*m.MapDeviceHistory, total int64, err error)

+ func (n *MapDeviceHistory) ListByMapId(mapId int64, limit, offset int, orderBy, sort string) (list []*m.MapDeviceHistory, total int64, err error)

type MapElement

+ func (n *MapElement) GetByName(name string) (ver *m.MapElement, err error)

type Node

+ func (a *Node) GetByName(name string) (ver *m.Node, err error)

type User

+ func (n *User) GetByNickname(nick string) (user *m.User, err error)

Mar 2, 2020

Changes in this version

+ var ErrRecordNotFound = errors.New("record not found")

type Adaptors

+ FlowZigbee2mqttDevice *FlowZigbee2mqttDevice

+ Zigbee2mqtt *Zigbee2mqtt

+ Zigbee2mqttDevice *Zigbee2mqttDevice

+ func (a *Adaptors) Commit() error

+ func (a *Adaptors) Rollback() error

+ func (a Adaptors) Begin() (adaptors *Adaptors)

+ type FlowZigbee2mqttDevice struct

+ func GetFlowZigbee2mqttDeviceAdaptor(Db *gorm.DB) *FlowZigbee2mqttDevice

+ func (f *FlowZigbee2mqttDevice) Add(sub *m.FlowZigbee2mqttDevice) (err error)

+ func (f *FlowZigbee2mqttDevice) Remove(flowId int64, ids []string) (err error)

+ type Zigbee2mqtt struct

+ func GetZigbee2mqttAdaptor(d *gorm.DB) *Zigbee2mqtt

+ func (a *Zigbee2mqtt) GetByLogin(login string) (ver *m.Zigbee2mqtt, err error)

+ func (n *Zigbee2mqtt) Add(ver *m.Zigbee2mqtt) (id int64, err error)

+ func (n *Zigbee2mqtt) Delete(id int64) (err error)

+ func (n *Zigbee2mqtt) GetById(id int64) (ver *m.Zigbee2mqtt, err error)

+ func (n *Zigbee2mqtt) List(limit, offset int64) (list []*m.Zigbee2mqtt, total int64, err error)

+ func (n *Zigbee2mqtt) Update(ver *m.Zigbee2mqtt) (err error)

+ type Zigbee2mqttDevice struct

+ func GetZigbee2mqttDeviceAdaptor(d *gorm.DB) *Zigbee2mqttDevice

+ func (n *Zigbee2mqttDevice) Add(ver *m.Zigbee2mqttDevice) (err error)

+ func (n *Zigbee2mqttDevice) Delete(id string) (err error)

+ func (n *Zigbee2mqttDevice) GetById(id string) (ver *m.Zigbee2mqttDevice, err error)

+ func (n *Zigbee2mqttDevice) List(limit, offset int64) (list []*m.Zigbee2mqttDevice, total int64, err error)

+ func (n *Zigbee2mqttDevice) Search(query string, limit, offset int) (list []*m.Zigbee2mqttDevice, total int64, err error)

+ func (n *Zigbee2mqttDevice) Update(ver *m.Zigbee2mqttDevice) (err error)

Feb 13, 2020

Changes in this version

type Workflow

+ func (n *Workflow) GetByWorkflowScenarioId(workflowScenarioId int64) (workflow *m.Workflow, err error)

Dec 11, 2019

Changes in this version

type Adaptors

+ FlowSubscription *FlowSubscription

+ type FlowSubscription struct

+ func GetFlowSubscriptionAdaptor(Db *gorm.DB) *FlowSubscription

+ func (f *FlowSubscription) Add(sub *m.FlowSubscription) (err error)

+ func (f *FlowSubscription) Remove(ids []int64) (err error)

Nov 27, 2019

Changes in this version

type Log

+ func (n *Log) AddMultiple(items []*m.Log) (err error)

Nov 10, 2019

Changes in this version

type Adaptors

+ Message *Message

+ MessageDelivery *MessageDelivery

+ Template *Template

+ type Message struct

+ func GetMessageAdaptor(d *gorm.DB) *Message

+ func (n *Message) Add(msg *m.Message) (id int64, err error)

+ type MessageDelivery struct

+ func GetMessageDeliveryAdaptor(d *gorm.DB) *MessageDelivery

+ func (n *MessageDelivery) Add(msg *m.MessageDelivery) (id int64, err error)

+ func (n *MessageDelivery) Delete(id int64) (err error)

+ func (n *MessageDelivery) GetAllUncompleted(limit, offset int64) (list []*m.MessageDelivery, total int64, err error)

+ func (n *MessageDelivery) GetById(id int64) (ver *m.MessageDelivery, err error)

+ func (n *MessageDelivery) List(limit, offset int64, orderBy, sort string) (list []*m.MessageDelivery, total int64, err error)

+ func (n *MessageDelivery) SetStatus(msg *m.MessageDelivery) (err error)

+ type Template struct

+ func GetTemplateAdaptor(d *gorm.DB) *Template

+ func (n *Template) Create(ver *m.Template) (err error)

+ func (n *Template) Delete(name string) (err error)

+ func (n *Template) GetByName(name string) (ver *m.Template, err error)

+ func (n *Template) GetItemByName(name string) (ver *m.Template, err error)

+ func (n *Template) GetItemsSortedList() (count int64, items []string, err error)

+ func (n *Template) GetItemsTree() (tree []*m.TemplateTree, err error)

+ func (n *Template) GetList(templateType m.TemplateType) (items []*m.Template, err error)

+ func (n *Template) GetMarkers(template *m.Template) (err error)

+ func (n *Template) Render(name string, params map[string]interface{}) (render *m.TemplateRender, err error)

+ func (n *Template) Search(query string, limit, offset int) (list []*m.Template, total int64, err error)

+ func (n *Template) UpdateItemsTree(tree []*m.TemplateTree) (err error)

+ func (n *Template) UpdateOrCreate(ver *m.Template) (err error)

+ func (n *Template) UpdateStatus(ver *m.Template) (err error)

Sep 14, 2019

Changes in this version

type Adaptors

+ MapZone *MapZone

type MapElement

+ func (n *MapElement) GetActiveElements(sortBy, order string, limit, offset int) (result []*m.MapElement, total int64, err error)

+ type MapZone struct

+ func GetMapZoneAdaptor(d *gorm.DB) *MapZone

+ func (n *MapZone) Add(tag *m.MapZone) (id int64, err error)

+ func (n *MapZone) Clean() (err error)

+ func (n *MapZone) Delete(name string) (err error)

+ func (n *MapZone) GetByName(zoneName string) (ver *m.MapZone, err error)

+ func (n *MapZone) Search(query string, limit, offset int) (list []*m.MapZone, total int64, err error)

Jun 13, 2019

Changes in this version

+ type Adaptors struct

+ Connection *Connection

+ Device *Device

+ DeviceAction *DeviceAction

+ DeviceState *DeviceState

+ Flow *Flow

+ FlowElement *FlowElement

+ Image *Image

+ Log *Log

+ Map *Map

+ MapDevice *MapDevice

+ MapDeviceAction *MapDeviceAction

+ MapDeviceState *MapDeviceState

+ MapElement *MapElement

+ MapImage *MapImage

+ MapLayer *MapLayer

+ MapText *MapText

+ Node *Node

+ Permission *Permission

+ Role *Role

+ Script *Script

+ User *User

+ UserMeta *UserMeta

+ Variable *Variable

+ Worker *Worker

+ Workflow *Workflow

+ WorkflowScenario *WorkflowScenario

+ func NewAdaptors(db *gorm.DB, cfg *config.AppConfig, migrations *migrations.Migrations) (adaptors *Adaptors)

+ type Connection struct

+ func GetConnectionAdaptor(d *gorm.DB) *Connection

+ func (n *Connection) Add(con *m.Connection) (id uuid.UUID, err error)

+ func (n *Connection) AddOrUpdateConnection(connection *m.Connection) (err error)

+ func (n *Connection) Delete(conIds []uuid.UUID) (err error)

+ func (n *Connection) GetById(conId uuid.UUID) (con *m.Connection, err error)

+ func (n *Connection) List(limit, offset int64, orderBy, sort string) (list []*m.Connection, total int64, err error)

+ func (n *Connection) Update(con *m.Connection) (err error)

+ type Device struct

+ func GetDeviceAdaptor(d *gorm.DB) *Device

+ func (n *Device) Add(device *m.Device) (id int64, err error)

+ func (n *Device) Delete(deviceId int64) (err error)

+ func (n *Device) GetAllEnabled() (list []*m.Device, err error)

+ func (n *Device) GetById(deviceId int64) (device *m.Device, err error)

+ func (n *Device) List(limit, offset int64, orderBy, sort string) (list []*m.Device, total int64, err error)

+ func (n *Device) Search(query string, limit, offset int) (list []*m.Device, total int64, err error)

+ func (n *Device) Update(device *m.Device) (err error)

+ type DeviceAction struct

+ func GetDeviceActionAdaptor(d *gorm.DB) *DeviceAction

+ func (n *DeviceAction) Add(device *m.DeviceAction) (id int64, err error)

+ func (n *DeviceAction) Delete(deviceId int64) (err error)

+ func (n *DeviceAction) GetByDeviceId(deviceId int64) (actions []*m.DeviceAction, err error)

+ func (n *DeviceAction) GetById(actionId int64) (device *m.DeviceAction, err error)

+ func (n *DeviceAction) List(limit, offset int64, orderBy, sort string) (list []*m.DeviceAction, total int64, err error)

+ func (n *DeviceAction) Search(query string, limit, offset int) (list []*m.DeviceAction, total int64, err error)

+ func (n *DeviceAction) Update(device *m.DeviceAction) (err error)

+ type DeviceDefault struct

+ Address *int

+ type DeviceSmartBus struct

+ Address *int

+ Baud int

+ Sleep int64

+ StopBite int64

+ Timeout time.Duration

+ Tty string

+ type DeviceState struct

+ func GetDeviceStateAdaptor(d *gorm.DB) *DeviceState

+ func (n *DeviceState) Add(device *m.DeviceState) (id int64, err error)

+ func (n *DeviceState) Delete(deviceId int64) (err error)

+ func (n *DeviceState) GetByDeviceId(deviceId int64) (states []*m.DeviceState, err error)

+ func (n *DeviceState) GetById(deviceId int64) (device *m.DeviceState, err error)

+ func (n *DeviceState) List(limit, offset int64, orderBy, sort string) (list []*m.DeviceState, total int64, err error)

+ func (n *DeviceState) Update(device *m.DeviceState) (err error)

+ type DeviceZigBee struct

+ Address string

+ type Flow struct

+ func GetFlowAdaptor(d *gorm.DB) *Flow

+ func (n *Flow) Add(flow *m.Flow) (id int64, err error)

+ func (n *Flow) Delete(flowId int64) (err error)

+ func (n *Flow) GetAllEnabled() (list []*m.Flow, err error)

+ func (n *Flow) GetAllEnabledByWorkflow(workflowId int64) (list []*m.Flow, err error)

+ func (n *Flow) GetById(flowId int64) (flow *m.Flow, err error)

+ func (n *Flow) List(limit, offset int64, orderBy, sort string) (list []*m.Flow, total int64, err error)

+ func (n *Flow) Search(query string, limit, offset int) (list []*m.Flow, total int64, err error)

+ func (n *Flow) Update(flow *m.Flow) (err error)

+ type FlowElement struct

+ func GetFlowElementAdaptor(d *gorm.DB) *FlowElement

+ func (n *FlowElement) Add(element *m.FlowElement) (id uuid.UUID, err error)

+ func (n *FlowElement) AddOrUpdateFlowElement(element *m.FlowElement) (err error)

+ func (n *FlowElement) Delete(ids []uuid.UUID) (err error)

+ func (n *FlowElement) GetAllEnabled() (list []*m.FlowElement, err error)

+ func (n *FlowElement) GetById(elementId uuid.UUID) (element *m.FlowElement, err error)

+ func (n *FlowElement) List(limit, offset int64, orderBy, sort string) (list []*m.FlowElement, total int64, err error)

+ func (n *FlowElement) Update(element *m.FlowElement) (err error)

+ type Image struct

+ func GetImageAdaptor(d *gorm.DB) *Image

+ func (n *Image) Add(ver *m.Image) (id int64, err error)

+ func (n *Image) AddMultiple(items []*m.Image) (err error)

+ func (n *Image) Delete(mapId int64) (err error)

+ func (n *Image) GetAllByDate(filter string) (images []*m.Image, err error)

+ func (n *Image) GetById(mapId int64) (ver *m.Image, err error)

+ func (n *Image) GetFilterList() (filterList []*m.ImageFilterList, err error)

+ func (n *Image) List(limit, offset int64, orderBy, sort string) (list []*m.Image, total int64, err error)

+ func (n *Image) Update(ver *m.Image) (err error)

+ func (n *Image) UploadImage(reader *bufio.Reader, fileName string) (err error)

+ type Log struct

+ func GetLogAdaptor(d *gorm.DB) *Log

+ func (n *Log) Add(ver *m.Log) (id int64, err error)

+ func (n *Log) Delete(verId int64) (err error)

+ func (n *Log) GetById(verId int64) (ver *m.Log, err error)

+ func (n *Log) List(limit, offset int64, orderBy, sort string, queryObj *m.LogQuery) (list []*m.Log, total int64, err error)

+ func (n *Log) Search(query string, limit, offset int) (list []*m.Log, total int64, err error)

+ type Map struct

+ func GetMapAdaptor(d *gorm.DB) *Map

+ func (n *Map) Add(ver *m.Map) (id int64, err error)

+ func (n *Map) Delete(mapId int64) (err error)

+ func (n *Map) GetById(mapId int64) (ver *m.Map, err error)

+ func (n *Map) GetFullById(mapId int64) (ver *m.Map, err error)

+ func (n *Map) List(limit, offset int64, orderBy, sort string) (list []*m.Map, total int64, err error)

+ func (n *Map) Search(query string, limit, offset int) (list []*m.Map, total int64, err error)

+ func (n *Map) Update(ver *m.Map) (err error)

+ type MapDevice struct

+ func GetMapDeviceAdaptor(d *gorm.DB) *MapDevice

+ func (n *MapDevice) Add(ver *m.MapDevice) (id int64, err error)

+ func (n *MapDevice) Delete(mapId int64) (err error)

+ func (n *MapDevice) GetById(mapId int64) (ver *m.MapDevice, err error)

+ type MapDeviceAction struct

+ func GetMapDeviceActionAdaptor(d *gorm.DB) *MapDeviceAction

+ func (n *MapDeviceAction) Add(ver *m.MapDeviceAction) (id int64, err error)

+ func (n *MapDeviceAction) AddMultiple(items []*m.MapDeviceAction) (err error)

+ type MapDeviceState struct

+ func GetMapDeviceStateAdaptor(d *gorm.DB) *MapDeviceState

+ func (n *MapDeviceState) Add(ver *m.MapDeviceState) (id int64, err error)

+ func (n *MapDeviceState) AddMultiple(items []*m.MapDeviceState) (err error)

+ type MapElement struct

+ func GetMapElementAdaptor(d *gorm.DB) *MapElement

+ func (n *MapElement) Add(ver *m.MapElement) (id int64, err error)

+ func (n *MapElement) Delete(mapId int64) (err error)

+ func (n *MapElement) GetById(mapId int64) (ver *m.MapElement, err error)

+ func (n *MapElement) List(limit, offset int64, orderBy, sort string) (list []*m.MapElement, total int64, err error)

+ func (n *MapElement) Sort(ver *m.MapElement) (err error)

+ func (n *MapElement) Update(ver *m.MapElement) (err error)

+ type MapImage struct

+ func GetMapImageAdaptor(d *gorm.DB) *MapImage

+ func (n *MapImage) Add(ver *m.MapImage) (id int64, err error)

+ func (n *MapImage) Delete(mapId int64) (err error)

+ func (n *MapImage) GetById(mapId int64) (ver *m.MapImage, err error)

+ func (n *MapImage) List(limit, offset int64, orderBy, sort string) (list []*m.MapImage, total int64, err error)

+ func (n *MapImage) Sort(ver *m.MapImage) (err error)

+ func (n *MapImage) Update(ver *m.MapImage) (err error)

+ type MapLayer struct

+ func GetMapLayerAdaptor(d *gorm.DB) *MapLayer

+ func (n *MapLayer) Add(ver *m.MapLayer) (id int64, err error)

+ func (n *MapLayer) Delete(mapId int64) (err error)

+ func (n *MapLayer) GetById(mapId int64) (ver *m.MapLayer, err error)

+ func (n *MapLayer) List(limit, offset int64, orderBy, sort string) (list []*m.MapLayer, total int64, err error)

+ func (n *MapLayer) Sort(ver *m.MapLayer) (err error)

+ func (n *MapLayer) Update(ver *m.MapLayer) (err error)

+ type MapText struct

+ func GetMapTextAdaptor(d *gorm.DB) *MapText

+ func (n *MapText) Add(ver *m.MapText) (id int64, err error)

+ func (n *MapText) Delete(mapId int64) (err error)

+ func (n *MapText) GetById(mapId int64) (ver *m.MapText, err error)

+ func (n *MapText) List(limit, offset int64, orderBy, sort string) (list []*m.MapText, total int64, err error)

+ func (n *MapText) Sort(ver *m.MapText) (err error)

+ func (n *MapText) Update(ver *m.MapText) (err error)

+ type Node struct

+ func GetNodeAdaptor(d *gorm.DB) *Node

+ func (a *Node) GetByLogin(login string) (ver *m.Node, err error)

+ func (n *Node) Add(node *m.Node) (id int64, err error)

+ func (n *Node) Delete(nodeId int64) (err error)

+ func (n *Node) GetAllEnabled() (list []*m.Node, err error)

+ func (n *Node) GetById(nodeId int64) (node *m.Node, err error)

+ func (n *Node) List(limit, offset int64, orderBy, sort string) (list []*m.Node, total int64, err error)

+ func (n *Node) Search(query string, limit, offset int) (list []*m.Node, total int64, err error)

+ func (n *Node) Update(node *m.Node) (err error)

+ type Permission struct

+ func GetPermissionAdaptor(d *gorm.DB) *Permission

+ func (n *Permission) Add(permission *m.Permission) (id int64, err error)

+ func (n *Permission) Delete(packageName string, levelName []string) (err error)

+ func (n *Permission) GetAllPermissions(roleName string) (permissions []*m.Permission, err error)

+ type Role struct

+ func GetRoleAdaptor(d *gorm.DB) *Role

+ func (n *Role) Add(role *m.Role) (err error)

+ func (n *Role) Delete(name string) (err error)

+ func (n *Role) GetAccessList(role *m.Role) (err error)

+ func (n *Role) GetByName(name string) (role *m.Role, err error)

+ func (n *Role) List(limit, offset int64, orderBy, sort string) (list []*m.Role, total int64, err error)

+ func (n *Role) Search(query string, limit, offset int) (list []*m.Role, total int64, err error)

+ func (n *Role) Update(role *m.Role) (err error)

+ type Script struct

+ func GetScriptAdaptor(d *gorm.DB) *Script

+ func (n *Script) Add(script *m.Script) (id int64, err error)

+ func (n *Script) Delete(scriptId int64) (err error)

+ func (n *Script) GetById(scriptId int64) (script *m.Script, err error)

+ func (n *Script) List(limit, offset int64, orderBy, sort string) (list []*m.Script, total int64, err error)

+ func (n *Script) Search(query string, limit, offset int) (list []*m.Script, total int64, err error)

+ func (n *Script) Update(script *m.Script) (err error)

+ type User struct

+ func GetUserAdaptor(d *gorm.DB) *User

+ func (n *User) Add(user *m.User) (id int64, err error)

+ func (n *User) ClearResetPassToken(u *m.User) (err error)

+ func (n *User) ClearToken(u *m.User) (err error)

+ func (n *User) Delete(userId int64) (err error)

+ func (n *User) GenResetPassToken(u *m.User) (token string, err error)

+ func (n *User) GetByAuthenticationToken(token string) (user *m.User, err error)

+ func (n *User) GetByEmail(email string) (user *m.User, err error)

+ func (n *User) GetById(userId int64) (user *m.User, err error)

+ func (n *User) GetByResetPassToken(token string) (user *m.User, err error)

+ func (n *User) List(limit, offset int64, orderBy, sort string) (list []*m.User, total int64, err error)

+ func (n *User) NewToken(u *m.User) (token string, err error)

+ func (n *User) SignIn(u *m.User, ipv4 string) (err error)

+ func (n *User) Update(user *m.User) (err error)

+ type UserMeta struct

+ func GetUserMetaAdaptor(d *gorm.DB) *UserMeta

+ func (n *UserMeta) UpdateOrCreate(meta *m.UserMeta) (id int64, err error)

+ type Variable struct

+ func GetVariableAdaptor(d *gorm.DB) *Variable

+ func (n *Variable) Add(variables *m.Variable) (err error)

+ func (n *Variable) Delete(name string) (err error)

+ func (n *Variable) GetAllEnabled() (list []*m.Variable, err error)

+ func (n *Variable) GetByName(name string) (variables *m.Variable, err error)

+ func (n *Variable) List(limit, offset int64, orderBy, sort string) (list []*m.Variable, total int64, err error)

+ func (n *Variable) Update(variables *m.Variable) (err error)

+ type Worker struct

+ func GetWorkerAdaptor(d *gorm.DB) *Worker

+ func (n *Worker) Add(worker *m.Worker) (id int64, err error)

+ func (n *Worker) Delete(ids []int64) (err error)

+ func (n *Worker) GetAllEnabled() (list []*m.Worker, err error)

+ func (n *Worker) GetById(workerId int64) (worker *m.Worker, err error)

+ func (n *Worker) List(limit, offset int64, orderBy, sort string) (list []*m.Worker, total int64, err error)

+ func (n *Worker) Update(worker *m.Worker) (err error)

+ type Workflow struct

+ func GetWorkflowAdaptor(d *gorm.DB) *Workflow

+ func (n *Workflow) Add(workflow *m.Workflow) (id int64, err error)

+ func (n *Workflow) AddScript(workflow *m.Workflow, script *m.Script) (err error)

+ func (n *Workflow) Delete(workflowId int64) (err error)

+ func (n *Workflow) DependencyLoading(workflow *m.Workflow) (err error)

+ func (n *Workflow) GetAllEnabled() (list []*m.Workflow, err error)

+ func (n *Workflow) GetById(workflowId int64) (workflow *m.Workflow, err error)

+ func (n *Workflow) List(limit, offset int64, orderBy, sort string) (list []*m.Workflow, total int64, err error)

+ func (n *Workflow) RemoveScript(workflow *m.Workflow, script *m.Script) (err error)

+ func (n *Workflow) Search(query string, limit, offset int) (list []*m.Workflow, total int64, err error)

+ func (n *Workflow) SetScenario(workflow *m.Workflow, s interface{}) (err error)

+ func (n *Workflow) Update(workflow *m.Workflow) (err error)

+ func (n *Workflow) UpdateScripts(wf *m.Workflow) (err error)

+ type WorkflowScenario struct

+ func GetWorkflowScenarioAdaptor(d *gorm.DB) *WorkflowScenario

+ func (n *WorkflowScenario) Add(workflow *m.WorkflowScenario) (id int64, err error)

+ func (n *WorkflowScenario) AddScript(workflowScenario *m.WorkflowScenario, script *m.Script) (err error)

+ func (n *WorkflowScenario) Delete(workflowId int64) (err error)

+ func (n *WorkflowScenario) GetById(scenarioId int64) (workflow *m.WorkflowScenario, err error)

+ func (n *WorkflowScenario) List(limit, offset int64, orderBy, sort string) (list []*m.WorkflowScenario, total int64, err error)

+ func (n *WorkflowScenario) ListByWorkflow(workflowId int64) (list []*m.WorkflowScenario, total int64, err error)

+ func (n *WorkflowScenario) RemoveScript(workflowScenario *m.WorkflowScenario, script *m.Script) (err error)

+ func (n *WorkflowScenario) Search(query string, limit, offset int) (list []*m.WorkflowScenario, total int64, err error)

+ func (n *WorkflowScenario) Update(workflow *m.WorkflowScenario) (err error)

+ func (n *WorkflowScenario) UpdateScripts(wf *m.WorkflowScenario) (err error)