adaptors

package
Version: v0.5.5 Latest Latest
Warning

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

Go to latest
Published: Feb 7, 2022 License: GPL-3.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Action added in v0.5.0

type Action struct {
	IAction
	// contains filtered or unexported fields
}

Action ...

func (*Action) AddMultiple added in v0.5.0

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

AddMultiple ...

func (*Action) DeleteByTaskId added in v0.5.0

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

DeleteByTaskId ...

type Adaptors

type Adaptors struct {
	Script            IScript
	Role              IRole
	Permission        IPermission
	User              IUser
	UserMeta          IUserMeta
	Image             IImage
	Variable          IVariable
	Map               IMap
	MapLayer          IMapLayer
	MapText           IMapText
	MapImage          IMapImage
	MapElement        IMapElement
	Entity            IEntity
	EntityState       IEntityState
	EntityAction      IEntityAction
	EntityStorage     IEntityStorage
	Log               ILog
	Template          ITemplate
	Message           IMessage
	MessageDelivery   IMessageDelivery
	Zigbee2mqtt       IZigbee2mqtt
	Zigbee2mqttDevice IZigbee2mqttDevice
	AlexaSkill        IAlexaSkill
	AlexaIntent       IAlexaIntent
	Storage           IStorage
	Metric            IMetric
	MetricBucket      IMetricBucket
	Area              IArea
	Action            IAction
	Condition         ICondition
	Trigger           ITrigger
	Task              ITask
	RunHistory        IRunHistory
	Plugin            IPlugin
	TelegramChat      ITelegramChat
	// contains filtered or unexported fields
}

Adaptors ...

func NewAdaptors

func NewAdaptors(lc fx.Lifecycle,
	db *gorm.DB,
	cfg *models.AppConfig,
	migrations *migrations.Migrations,
	orm *orm.Orm) (adaptors *Adaptors)

NewAdaptors ...

func (Adaptors) Begin added in v0.1.0

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

Begin ...

func (*Adaptors) Commit added in v0.1.0

func (a *Adaptors) Commit() error

Commit ...

func (*Adaptors) Rollback added in v0.1.0

func (a *Adaptors) Rollback() error

Rollback ...

type AlexaIntent added in v0.3.0

type AlexaIntent struct {
	IAlexaIntent
	// contains filtered or unexported fields
}

AlexaIntent ...

func (*AlexaIntent) Add added in v0.3.0

func (n *AlexaIntent) Add(ver *m.AlexaIntent) error

Add ...

func (*AlexaIntent) Delete added in v0.3.0

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

Delete ...

func (*AlexaIntent) GetByName added in v0.3.0

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

GetByName ...

func (*AlexaIntent) Update added in v0.3.0

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

Update ...

type AlexaSkill added in v0.3.0

type AlexaSkill struct {
	IAlexaSkill
	// contains filtered or unexported fields
}

AlexaSkill ...

func (*AlexaSkill) Add added in v0.3.0

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

Add ...

func (*AlexaSkill) Delete added in v0.3.0

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

Delete ...

func (*AlexaSkill) GetById added in v0.3.0

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

GetById ...

func (*AlexaSkill) List added in v0.3.0

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

List ...

func (*AlexaSkill) ListEnabled added in v0.3.0

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

ListEnabled ...

func (*AlexaSkill) Update added in v0.3.0

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

Update ...

type Area added in v0.5.0

type Area struct {
	IArea
	// contains filtered or unexported fields
}

Area ...

func (*Area) Add added in v0.5.0

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

Add ...

func (*Area) DeleteByName added in v0.5.0

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

DeleteByName ...

func (*Area) GetById added in v0.5.0

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

GetById ...

func (*Area) GetByName added in v0.5.0

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

GetByName ...

func (*Area) List added in v0.5.0

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

List ...

func (*Area) Search added in v0.5.0

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

Search ...

func (*Area) Update added in v0.5.0

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

Update ...

type Condition added in v0.5.0

type Condition struct {
	ICondition
	// contains filtered or unexported fields
}

Condition ...

func (*Condition) AddMultiple added in v0.5.0

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

AddMultiple ...

func (*Condition) DeleteByTaskId added in v0.5.0

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

DeleteByTaskId ...

type Entity added in v0.5.0

type Entity struct {
	IEntity
	// contains filtered or unexported fields
}

Entity ...

func (*Entity) Add added in v0.5.0

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

Add ...

func (*Entity) AppendMetric added in v0.5.0

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

AppendMetric ...

func (*Entity) Delete added in v0.5.0

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

Delete ...

func (*Entity) DeleteMetric added in v0.5.0

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

DeleteMetric ...

func (*Entity) GetById added in v0.5.0

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

GetById ...

func (*Entity) GetByType added in v0.5.0

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

GetByType ...

func (*Entity) List added in v0.5.0

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

List ...

func (*Entity) Search added in v0.5.0

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

Search ...

func (*Entity) Update added in v0.5.0

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

Update ...

func (*Entity) UpdateSettings added in v0.5.0

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

UpdateSettings ...

type EntityAction added in v0.5.0

type EntityAction struct {
	IEntityAction
	// contains filtered or unexported fields
}

EntityAction ...

func (*EntityAction) Add added in v0.5.0

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

Add ...

func (*EntityAction) AddMultiple added in v0.5.0

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

AddMultiple ...

func (*EntityAction) DeleteByEntityId added in v0.5.0

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

DeleteByEntityId ...

type EntityState added in v0.5.0

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

EntityState ...

func (*EntityState) Add added in v0.5.0

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

Add ...

func (*EntityState) AddMultiple added in v0.5.0

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

AddMultiple ...

func (*EntityState) DeleteByEntityId added in v0.5.0

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

DeleteByEntityId ...

type EntityStorage added in v0.5.0

type EntityStorage struct {
	IEntityStorage
	// contains filtered or unexported fields
}

EntityStorage ...

func (*EntityStorage) Add added in v0.5.0

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

Add ...

func (*EntityStorage) GetLastByEntityId added in v0.5.0

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

GetLastByEntityId ...

func (*EntityStorage) List added in v0.5.0

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

List ...

type IAction added in v0.5.0

type IAction interface {
	DeleteByTaskId(id int64) (err error)
	AddMultiple(items []*m.Action) (err error)
	// contains filtered or unexported methods
}

IAction ...

func GetActionAdaptor added in v0.5.0

func GetActionAdaptor(d *gorm.DB) IAction

GetActionAdaptor ...

type IAlexaIntent added in v0.5.0

type IAlexaIntent interface {
	Add(ver *m.AlexaIntent) (err error)
	GetByName(name string) (ver *m.AlexaIntent, err error)
	Update(ver *m.AlexaIntent) (err error)
	Delete(ver *m.AlexaIntent) (err error)
	// contains filtered or unexported methods
}

IAlexaIntent ...

func GetAlexaIntentAdaptor added in v0.3.0

func GetAlexaIntentAdaptor(d *gorm.DB) IAlexaIntent

GetAlexaIntentAdaptor ...

type IAlexaSkill added in v0.5.0

type IAlexaSkill interface {
	Add(app *m.AlexaSkill) (id int64, err error)
	GetById(appId int64) (app *m.AlexaSkill, err error)
	Update(params *m.AlexaSkill) (err error)
	Delete(appId int64) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.AlexaSkill, total int64, err error)
	ListEnabled(limit, offset int64) (list []*m.AlexaSkill, err error)
	// contains filtered or unexported methods
}

IAlexaSkill ...

func GetAlexaSkillAdaptor added in v0.3.0

func GetAlexaSkillAdaptor(d *gorm.DB) IAlexaSkill

GetAlexaSkillAdaptor ...

type IArea added in v0.5.0

type IArea interface {
	Add(ver *m.Area) (id int64, err error)
	GetById(verId int64) (ver *m.Area, err error)
	GetByName(name string) (ver *m.Area, err error)
	Update(ver *m.Area) (err error)
	DeleteByName(name string) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.Area, total int64, err error)
	Search(query string, limit, offset int64) (list []*m.Area, total int64, err error)
	// contains filtered or unexported methods
}

IArea ...

func GetAreaAdaptor added in v0.5.0

func GetAreaAdaptor(d *gorm.DB) IArea

GetAreaAdaptor ...

type ICondition added in v0.5.0

type ICondition interface {
	DeleteByTaskId(id int64) (err error)
	AddMultiple(items []*m.Condition) (err error)
	// contains filtered or unexported methods
}

ICondition ...

func GetConditionAdaptor added in v0.5.0

func GetConditionAdaptor(d *gorm.DB) ICondition

GetConditionAdaptor ...

type IEntity added in v0.5.0

type IEntity interface {
	Add(ver *m.Entity) (err error)
	GetById(id common.EntityId) (ver *m.Entity, err error)
	Delete(id common.EntityId) (err error)
	List(limit, offset int64, orderBy, sort string, autoLoad bool) (list []*m.Entity, total int64, err error)
	GetByType(t string, limit, offset int64) (list []*m.Entity, err error)
	Update(ver *m.Entity) (err error)
	UpdateSettings(entityId common.EntityId, settings m.Attributes) (err error)
	Search(query string, limit, offset int64) (list []*m.Entity, total int64, err error)
	AppendMetric(entityId common.EntityId, metric m.Metric) (err error)
	DeleteMetric(entityId common.EntityId, metric m.Metric) (err error)
	// contains filtered or unexported methods
}

IEntity ...

func GetEntityAdaptor added in v0.5.0

func GetEntityAdaptor(d *gorm.DB) IEntity

GetEntityAdaptor ...

type IEntityAction added in v0.5.0

type IEntityAction interface {
	Add(ver *m.EntityAction) (id int64, err error)
	DeleteByEntityId(id common.EntityId) (err error)
	AddMultiple(items []*m.EntityAction) (err error)
	// contains filtered or unexported methods
}

IEntityAction ...

func GetEntityActionAdaptor added in v0.5.0

func GetEntityActionAdaptor(d *gorm.DB) IEntityAction

GetEntityActionAdaptor ...

type IEntityState added in v0.5.0

type IEntityState interface {
	Add(ver *m.EntityState) (id int64, err error)
	DeleteByEntityId(entityId common.EntityId) (err error)
	AddMultiple(items []*m.EntityState) (err error)
	// contains filtered or unexported methods
}

IEntityState ...

func GetEntityStateAdaptor added in v0.5.0

func GetEntityStateAdaptor(d *gorm.DB) IEntityState

GetEntityStateAdaptor ...

type IEntityStorage added in v0.5.0

type IEntityStorage interface {
	Add(ver m.EntityStorage) (id int64, err error)
	GetLastByEntityId(entityId common.EntityId) (ver m.EntityStorage, err error)
	List(limit, offset int64, orderBy, sort string) (list []m.EntityStorage, total int64, err error)
	// contains filtered or unexported methods
}

IEntityStorage ...

func GetEntityStorageAdaptor added in v0.5.0

func GetEntityStorageAdaptor(d *gorm.DB) IEntityStorage

GetEntityStorageAdaptor ...

type IImage added in v0.5.0

type IImage interface {
	Add(ver *m.Image) (id int64, err error)
	GetByImageName(imageName string) (ver *m.Image, err error)
	GetById(mapId int64) (ver *m.Image, err error)
	Update(ver *m.Image) (err error)
	Delete(mapId int64) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.Image, total int64, err error)
	UploadImage(reader *bufio.Reader, fileName string) (file *m.Image, err error)
	AddMultiple(items []*m.Image) (err error)
	GetAllByDate(filter string) (images []*m.Image, err error)
	GetFilterList() (filterList []*m.ImageFilterList, err error)
	// contains filtered or unexported methods
}

IImage ...

func GetImageAdaptor

func GetImageAdaptor(d *gorm.DB) IImage

GetImageAdaptor ...

type ILog added in v0.5.0

type ILog interface {
	Add(ver *m.Log) (id int64, err error)
	AddMultiple(items []*m.Log) (err error)
	GetById(verId int64) (ver *m.Log, err error)
	Delete(verId int64) (err error)
	List(limit, offset int64, orderBy, sort string, queryObj *m.LogQuery) (list []*m.Log, total int64, err error)
	Search(query string, limit, offset int) (list []*m.Log, total int64, err error)
	// contains filtered or unexported methods
}

ILog ...

func GetLogAdaptor

func GetLogAdaptor(d *gorm.DB) ILog

GetLogAdaptor ...

type IMap added in v0.5.0

type IMap interface {
	Add(ver *m.Map) (id int64, err error)
	GetById(mapId int64) (ver *m.Map, err error)
	GetFullById(mapId int64) (ver *m.Map, err error)
	Update(ver *m.Map) (err error)
	Delete(mapId int64) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.Map, total int64, err error)
	Search(query string, limit, offset int) (list []*m.Map, total int64, err error)
	// contains filtered or unexported methods
}

IMap ...

func GetMapAdaptor

func GetMapAdaptor(d *gorm.DB) IMap

GetMapAdaptor ...

type IMapElement added in v0.5.0

type IMapElement interface {
	Add(ver *m.MapElement) (id int64, err error)
	GetById(mapId int64) (ver *m.MapElement, err error)
	GetByName(name string) (ver *m.MapElement, err error)
	Update(ver *m.MapElement) (err error)
	Delete(mapId int64) (err error)
	Sort(ver *m.MapElement) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.MapElement, total int64, err error)
	GetActiveElements(sortBy, order string, limit, offset int) (result []*m.MapElement, total int64, err error)
	// contains filtered or unexported methods
}

IMapElement ...

func GetMapElementAdaptor

func GetMapElementAdaptor(d *gorm.DB) IMapElement

GetMapElementAdaptor ...

type IMapImage added in v0.5.0

type IMapImage interface {
	Add(ver *m.MapImage) (id int64, err error)
	GetById(mapId int64) (ver *m.MapImage, err error)
	Update(ver *m.MapImage) (err error)
	Sort(ver *m.MapImage) (err error)
	Delete(mapId int64) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.MapImage, total int64, err error)
	// contains filtered or unexported methods
}

IMapImage ...

func GetMapImageAdaptor

func GetMapImageAdaptor(d *gorm.DB) IMapImage

GetMapImageAdaptor ...

type IMapLayer added in v0.5.0

type IMapLayer interface {
	Add(ver *m.MapLayer) (id int64, err error)
	GetById(mapId int64) (ver *m.MapLayer, err error)
	Update(ver *m.MapLayer) (err error)
	Sort(ver *m.MapLayer) (err error)
	Delete(mapId int64) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.MapLayer, total int64, err error)
	// contains filtered or unexported methods
}

IMapLayer ...

func GetMapLayerAdaptor

func GetMapLayerAdaptor(d *gorm.DB) IMapLayer

GetMapLayerAdaptor ...

type IMapText added in v0.5.0

type IMapText interface {
	Add(ver *m.MapText) (id int64, err error)
	GetById(mapId int64) (ver *m.MapText, err error)
	Update(ver *m.MapText) (err error)
	Sort(ver *m.MapText) (err error)
	Delete(mapId int64) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.MapText, total int64, err error)
	// contains filtered or unexported methods
}

IMapText ...

func GetMapTextAdaptor

func GetMapTextAdaptor(d *gorm.DB) IMapText

GetMapTextAdaptor ...

type IMessage added in v0.5.0

type IMessage interface {
	Add(msg m.Message) (id int64, err error)
	// contains filtered or unexported methods
}

IMessage ...

func GetMessageAdaptor added in v0.0.17

func GetMessageAdaptor(d *gorm.DB) IMessage

GetMessageAdaptor ...

type IMessageDelivery added in v0.5.0

type IMessageDelivery interface {
	Add(msg m.MessageDelivery) (id int64, err error)
	SetStatus(msg m.MessageDelivery) (err error)
	List(limit, offset int64, orderBy, sort string) (list []m.MessageDelivery, total int64, err error)
	GetAllUncompleted(limit, offset int64) (list []m.MessageDelivery, total int64, err error)
	Delete(id int64) (err error)
	GetById(id int64) (ver m.MessageDelivery, err error)
	// contains filtered or unexported methods
}

IMessageDelivery ...

func GetMessageDeliveryAdaptor added in v0.0.17

func GetMessageDeliveryAdaptor(d *gorm.DB) IMessageDelivery

GetMessageDeliveryAdaptor ...

type IMetric added in v0.5.0

type IMetric interface {
	Add(ver m.Metric) (id int64, err error)
	GetById(id int64) (metric m.Metric, err error)
	GetByIdWithData(id int64, from, to *time.Time, metricRange *string) (metric m.Metric, err error)
	Update(ver m.Metric) error
	Delete(deviceId int64) (err error)
	AddMultiple(items []m.Metric) (err error)
	List(limit, offset int64, orderBy, sort string) (list []m.Metric, total int64, err error)
	Search(query string, limit, offset int) (list []m.Metric, total int64, err error)
	// contains filtered or unexported methods
}

IMetric ...

func GetMetricAdaptor added in v0.5.0

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

GetMetricAdaptor ...

type IMetricBucket added in v0.5.0

type IMetricBucket interface {
	Add(ver m.MetricDataItem) error
	AddMultiple(items []m.MetricDataItem) (err error)
	SimpleListWithSoftRange(_from, _to *time.Time, metricId int64, _metricRange *string, optionItems []string) (list []m.MetricDataItem, err error)
	Simple24HPreview(metricId int64, optionItems []string) (list []m.MetricDataItem, err error)
	DeleteOldest(days int) (err error)
	DeleteById(id int64) (err error)
	DeleteByMetricId(metricId int64) (err error)
	CreateHypertable() (err error)
	// contains filtered or unexported methods
}

IMetricBucket ...

func GetMetricBucketAdaptor added in v0.5.0

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

GetMetricBucketAdaptor ...

type IPermission added in v0.5.0

type IPermission interface {
	Add(permission *m.Permission) (id int64, err error)
	Delete(roleName, packageName string, levelName []string) (err error)
	GetAllPermissions(roleName string) (permissions []*m.Permission, err error)
	// contains filtered or unexported methods
}

IPermission ...

func GetPermissionAdaptor

func GetPermissionAdaptor(d *gorm.DB) IPermission

GetPermissionAdaptor ...

type IPlugin added in v0.5.0

type IPlugin interface {
	Add(plugin m.Plugin) error
	CreateOrUpdate(ver m.Plugin) error
	Update(plugin m.Plugin) error
	Delete(pluginId string) error
	List(limit, offset int64, orderBy, sort string) (list []m.Plugin, total int64, err error)
	Search(query string, limit, offset int64) (list []m.Plugin, total int64, err error)
	GetByName(name string) (ver m.Plugin, err error)
	// contains filtered or unexported methods
}

IPlugin ...

func GetPluginAdaptor added in v0.5.0

func GetPluginAdaptor(d *gorm.DB) IPlugin

GetPluginAdaptor ...

type IRole added in v0.5.0

type IRole interface {
	Add(role *m.Role) (err error)
	GetByName(name string) (role *m.Role, err error)
	Update(role *m.Role) (err error)
	Delete(name string) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.Role, total int64, err error)
	Search(query string, limit, offset int64) (list []*m.Role, total int64, err error)
	GetAccessList(role *m.Role) (err error)
	// contains filtered or unexported methods
}

IRole ...

func GetRoleAdaptor

func GetRoleAdaptor(d *gorm.DB) IRole

GetRoleAdaptor ...

type IRunHistory added in v0.5.0

type IRunHistory interface {
	Add(story *m.RunStory) (id int64, err error)
	Update(story *m.RunStory) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.RunStory, total int64, err error)
	// contains filtered or unexported methods
}

IRunHistory ...

func GetRunHistoryAdaptor added in v0.5.0

func GetRunHistoryAdaptor(d *gorm.DB) IRunHistory

GetRunHistoryAdaptor ...

type IScript added in v0.5.0

type IScript interface {
	Add(script *m.Script) (id int64, err error)
	GetById(scriptId int64) (script *m.Script, err error)
	GetByName(name string) (script *m.Script, err error)
	Update(script *m.Script) (err error)
	Delete(scriptId int64) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.Script, total int64, err error)
	Search(query string, limit, offset int64) (list []*m.Script, total int64, err error)
	// contains filtered or unexported methods
}

IScript ...

func GetScriptAdaptor

func GetScriptAdaptor(d *gorm.DB) IScript

GetScriptAdaptor ...

type IStorage added in v0.5.0

type IStorage interface {
	CreateOrUpdate(ver m.Storage) (err error)
	Delete(name string) (err error)
	Search(query string, limit, offset int) (list []m.Storage, total int64, err error)
	GetByName(name string) (ver m.Storage, err error)
	// contains filtered or unexported methods
}

IStorage ...

func GetStorageAdaptor added in v0.4.0

func GetStorageAdaptor(d *gorm.DB) IStorage

GetStorageAdaptor ...

type ITask added in v0.5.0

type ITask interface {
	Add(ver *m.Task) (err error)
	Update(ver *m.Task) (err error)
	Delete(id int64) (err error)
	GetById(id int64) (task *m.Task, err error)
	List(limit, offset int64, orderBy, sort string, onlyEnabled bool) (list []*m.Task, total int64, err error)
	Enable(id int64) (err error)
	Disable(id int64) (err error)
	// contains filtered or unexported methods
}

ITask ...

func GetTaskAdaptor added in v0.5.0

func GetTaskAdaptor(d *gorm.DB) ITask

GetTaskAdaptor ...

type ITelegramChat added in v0.5.0

type ITelegramChat interface {
	Add(plugin m.TelegramChat) (err error)
	Delete(entityId common.EntityId, channelId int64) (err error)
	List(limit, offset int64, orderBy, sort string, entityId common.EntityId) (list []m.TelegramChat, total int64, err error)
	// contains filtered or unexported methods
}

ITelegramChat ...

func GetTelegramChannelAdaptor added in v0.5.0

func GetTelegramChannelAdaptor(d *gorm.DB) ITelegramChat

GetTelegramChannelAdaptor ...

type ITemplate added in v0.5.0

type ITemplate interface {
	UpdateOrCreate(ver *m.Template) (err error)
	Create(ver *m.Template) (err error)
	UpdateStatus(ver *m.Template) (err error)
	GetList(templateType m.TemplateType) (items []*m.Template, err error)
	GetByName(name string) (ver *m.Template, err error)
	GetItemByName(name string) (ver *m.Template, err error)
	GetItemsSortedList() (count int64, items []string, err error)
	Delete(name string) (err error)
	GetItemsTree() (tree []*m.TemplateTree, err error)
	UpdateItemsTree(tree []*m.TemplateTree) (err error)
	Search(query string, limit, offset int) (list []*m.Template, total int64, err error)
	GetMarkers(template *m.Template) (err error)
	Render(name string, params map[string]interface{}) (render *m.TemplateRender, err error)
	// contains filtered or unexported methods
}

ITemplate ...

func GetTemplateAdaptor added in v0.0.17

func GetTemplateAdaptor(d *gorm.DB) ITemplate

GetTemplateAdaptor ...

type ITrigger added in v0.5.0

type ITrigger interface {
	DeleteByTaskId(id int64) (err error)
	AddMultiple(items []*m.Trigger) (err error)
	// contains filtered or unexported methods
}

ITrigger ...

func GetTriggerAdaptor added in v0.5.0

func GetTriggerAdaptor(d *gorm.DB) ITrigger

GetTriggerAdaptor ...

type IUser added in v0.5.0

type IUser interface {
	Add(user *m.User) (id int64, err error)
	GetById(userId int64) (user *m.User, err error)
	GetByNickname(nick string) (user *m.User, err error)
	GetByEmail(email string) (user *m.User, err error)
	GetByAuthenticationToken(token string) (user *m.User, err error)
	GetByResetPassToken(token string) (user *m.User, err error)
	Update(user *m.User) (err error)
	Delete(userId int64) (err error)
	List(limit, offset int64, orderBy, sort string) (list []*m.User, total int64, err error)
	SignIn(u *m.User, ipv4 string) (err error)
	GenResetPassToken(u *m.User) (token string, err error)
	ClearResetPassToken(u *m.User) (err error)
	ClearToken(u *m.User) (err error)
	// contains filtered or unexported methods
}

IUser ...

func GetUserAdaptor

func GetUserAdaptor(d *gorm.DB) IUser

GetUserAdaptor ...

type IUserMeta added in v0.5.0

type IUserMeta interface {
	UpdateOrCreate(meta *m.UserMeta) (id int64, err error)
	// contains filtered or unexported methods
}

IUserMeta ...

type IVariable added in v0.5.0

type IVariable interface {
	Add(ver m.Variable) (err error)
	CreateOrUpdate(ver m.Variable) (err error)
	GetAllEnabled() (list []m.Variable, err error)
	GetByName(name string) (ver m.Variable, err error)
	Update(variable m.Variable) (err error)
	Delete(name string) (err error)
	List(limit, offset int64, orderBy, sort string) (list []m.Variable, total int64, err error)
	// contains filtered or unexported methods
}

IVariable ...

func GetVariableAdaptor

func GetVariableAdaptor(d *gorm.DB) IVariable

GetVariableAdaptor ...

type IZigbee2mqtt added in v0.5.0

type IZigbee2mqtt interface {
	Add(ver *m.Zigbee2mqtt) (id int64, err error)
	GetById(id int64) (ver *m.Zigbee2mqtt, err error)
	Update(ver *m.Zigbee2mqtt) (err error)
	Delete(id int64) (err error)
	List(limit, offset int64) (list []*m.Zigbee2mqtt, total int64, err error)
	GetByLogin(login string) (ver *m.Zigbee2mqtt, err error)
	// contains filtered or unexported methods
}

IZigbee2mqtt ...

func GetZigbee2mqttAdaptor added in v0.1.0

func GetZigbee2mqttAdaptor(d *gorm.DB) IZigbee2mqtt

GetZigbee2mqttAdaptor ...

type IZigbee2mqttDevice added in v0.5.0

type IZigbee2mqttDevice interface {
	Add(ver *m.Zigbee2mqttDevice) (err error)
	GetById(id string) (ver *m.Zigbee2mqttDevice, err error)
	Update(ver *m.Zigbee2mqttDevice) (err error)
	Delete(id string) (err error)
	List(limit, offset int64) (list []*m.Zigbee2mqttDevice, total int64, err error)
	ListByBridgeId(bridgeId, limit, offset int64) (list []*m.Zigbee2mqttDevice, total int64, err error)
	Search(query string, limit, offset int64) (list []*m.Zigbee2mqttDevice, total int64, err error)
	// contains filtered or unexported methods
}

IZigbee2mqttDevice ...

func GetZigbee2mqttDeviceAdaptor added in v0.1.0

func GetZigbee2mqttDeviceAdaptor(d *gorm.DB) IZigbee2mqttDevice

GetZigbee2mqttDeviceAdaptor ...

type Image

type Image struct {
	IImage
	// contains filtered or unexported fields
}

Image ...

func (*Image) Add

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

Add ...

func (*Image) AddMultiple

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

AddMultiple ...

func (*Image) Delete

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

Delete ...

func (*Image) GetAllByDate

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

GetAllByDate ...

func (*Image) GetById

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

GetById ...

func (*Image) GetByImageName added in v0.2.0

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

GetByImageName ...

func (*Image) GetFilterList

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

GetFilterList ...

func (*Image) List

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

List ...

func (*Image) Update

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

Update ...

func (*Image) UploadImage

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

UploadImage ...

type Log

type Log struct {
	ILog
	// contains filtered or unexported fields
}

Log ...

func (*Log) Add

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

Add ...

func (*Log) AddMultiple added in v0.0.19

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

AddMultiple ...

func (*Log) Delete

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

Delete ...

func (*Log) GetById

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

GetById ...

func (*Log) List

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

List ...

func (*Log) Search

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

Search ...

type Map

type Map struct {
	IMap
	// contains filtered or unexported fields
}

Map ...

func (*Map) Add

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

Add ...

func (*Map) Delete

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

Delete ...

func (*Map) GetById

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

GetById ...

func (*Map) GetFullById

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

GetFullById ...

func (*Map) List

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

List ...

func (*Map) Search

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

Search ...

func (*Map) Update

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

Update ...

type MapElement

type MapElement struct {
	IMapElement
	// contains filtered or unexported fields
}

Entity ...

func (*MapElement) Add

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

Add ...

func (*MapElement) Delete

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

Delete ...

func (*MapElement) GetActiveElements added in v0.0.14

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

GetActiveElements ...

func (*MapElement) GetById

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

GetById ...

func (*MapElement) GetByName added in v0.2.0

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

GetByName ...

func (*MapElement) List

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

List ...

func (*MapElement) Sort

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

Sort ...

func (*MapElement) Update

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

Update ...

type MapImage

type MapImage struct {
	IMapImage
	// contains filtered or unexported fields
}

MapImage ...

func (*MapImage) Add

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

Add ...

func (*MapImage) Delete

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

Delete ...

func (*MapImage) GetById

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

GetById ...

func (*MapImage) List

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

List ...

func (*MapImage) Sort

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

Sort ...

func (*MapImage) Update

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

Update ...

type MapLayer

type MapLayer struct {
	IMapLayer
	// contains filtered or unexported fields
}

MapLayer ...

func (*MapLayer) Add

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

Add ...

func (*MapLayer) Delete

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

Delete ...

func (*MapLayer) GetById

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

GetById ...

func (*MapLayer) List

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

List ...

func (*MapLayer) Sort

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

Sort ...

func (*MapLayer) Update

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

Update ...

type MapText

type MapText struct {
	IMapText
	// contains filtered or unexported fields
}

MapText ...

func (*MapText) Add

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

Add ...

func (*MapText) Delete

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

Delete ...

func (*MapText) GetById

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

GetById ...

func (*MapText) List

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

List ...

func (*MapText) Sort

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

Sort ...

func (*MapText) Update

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

Update ...

type Message added in v0.0.17

type Message struct {
	IMessage
	// contains filtered or unexported fields
}

Message ...

func (*Message) Add added in v0.0.17

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

Add ...

type MessageDelivery added in v0.0.17

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

MessageDelivery ...

func (*MessageDelivery) Add added in v0.0.17

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

Add ...

func (*MessageDelivery) Delete added in v0.0.17

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

Delete ...

func (*MessageDelivery) GetAllUncompleted added in v0.0.17

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

GetAllUncompleted ...

func (*MessageDelivery) GetById added in v0.0.17

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

GetById ...

func (*MessageDelivery) List added in v0.0.17

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

List ...

func (*MessageDelivery) SetStatus added in v0.0.17

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

SetStatus ...

type Metric added in v0.5.0

type Metric struct {
	IMetric
	// contains filtered or unexported fields
}

Metric ...

func (*Metric) Add added in v0.5.0

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

Add ...

func (*Metric) AddMultiple added in v0.5.0

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

AddMultiple ...

func (*Metric) Delete added in v0.5.0

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

Delete ...

func (*Metric) GetById added in v0.5.0

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

GetById ...

func (*Metric) GetByIdWithData added in v0.5.0

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

GetByIdWithData ...

func (*Metric) List added in v0.5.0

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

List ...

func (*Metric) Search added in v0.5.0

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

Search ...

func (*Metric) Update added in v0.5.0

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

Update ...

type MetricBucket added in v0.5.0

type MetricBucket struct {
	IMetricBucket
	// contains filtered or unexported fields
}

MetricDataItem ...

func (*MetricBucket) Add added in v0.5.0

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

Add ...

func (*MetricBucket) AddMultiple added in v0.5.0

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

AddMultiple ...

func (*MetricBucket) CreateHypertable added in v0.5.0

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

CreateHypertable ...

func (*MetricBucket) DeleteById added in v0.5.0

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

DeleteById ...

func (*MetricBucket) DeleteByMetricId added in v0.5.0

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

DeleteByMetricId ...

func (*MetricBucket) DeleteOldest added in v0.5.0

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

DeleteOldest ...

func (*MetricBucket) Simple24HPreview added in v0.5.0

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

Simple24HPreview ...

func (*MetricBucket) SimpleListWithSoftRange added in v0.5.0

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

SimpleListWithSoftRange ...

type Permission

type Permission struct {
	IPermission
	// contains filtered or unexported fields
}

Permission ...

func (*Permission) Add

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

Add ...

func (*Permission) Delete

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

Delete ...

func (*Permission) GetAllPermissions

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

GetAllPermissions ...

type Plugin added in v0.5.0

type Plugin struct {
	IPlugin
	// contains filtered or unexported fields
}

Plugin ...

func (*Plugin) Add added in v0.5.0

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

Add ...

func (*Plugin) CreateOrUpdate added in v0.5.0

func (p *Plugin) CreateOrUpdate(plugin m.Plugin) (err error)

CreateOrUpdate ...

func (*Plugin) Delete added in v0.5.0

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

Delete ...

func (*Plugin) GetByName added in v0.5.0

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

GetByName ...

func (*Plugin) List added in v0.5.0

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

List ...

func (*Plugin) Search added in v0.5.0

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

Search ...

func (*Plugin) Update added in v0.5.0

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

Update ...

type Role

type Role struct {
	IRole
	// contains filtered or unexported fields
}

RoleName ...

func (*Role) Add

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

Add ...

func (*Role) Delete

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

Delete ...

func (*Role) GetAccessList

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

GetAccessList ...

func (*Role) GetByName

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

GetByName ...

func (*Role) List

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

List ...

func (*Role) Search

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

Search ...

func (*Role) Update

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

Update ...

type RunHistory added in v0.5.0

type RunHistory struct {
	IRunHistory
	// contains filtered or unexported fields
}

RunStory ...

func (*RunHistory) Add added in v0.5.0

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

Add ...

func (*RunHistory) List added in v0.5.0

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

List ...

func (*RunHistory) Update added in v0.5.0

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

Update ...

type Script

type Script struct {
	IScript
	// contains filtered or unexported fields
}

Script ...

func (*Script) Add

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

Add ...

func (*Script) Delete

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

Delete ...

func (*Script) GetById

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

GetById ...

func (*Script) GetByName added in v0.5.0

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

GetByName ...

func (*Script) List

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

List ...

func (*Script) Search

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

Search ...

func (*Script) Update

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

Update ...

type Storage added in v0.4.0

type Storage struct {
	IStorage
	// contains filtered or unexported fields
}

Storage ...

func (*Storage) CreateOrUpdate added in v0.4.0

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

CreateOrUpdate ...

func (*Storage) Delete added in v0.4.0

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

Delete ...

func (*Storage) GetByName added in v0.4.0

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

GetByName ...

func (*Storage) Search added in v0.4.0

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

Search ...

type Task added in v0.5.0

type Task struct {
	ITask
	// contains filtered or unexported fields
}

Task ...

func (*Task) Add added in v0.5.0

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

Add ...

func (*Task) Delete added in v0.5.0

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

Delete ...

func (*Task) Disable added in v0.5.3

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

Disable ...

func (*Task) Enable added in v0.5.3

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

Enable ...

func (*Task) GetById added in v0.5.2

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

GetById ...

func (*Task) List added in v0.5.0

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

List ...

func (*Task) Update added in v0.5.1

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

Update ...

type TelegramChat added in v0.5.0

type TelegramChat struct {
	ITelegramChat
	// contains filtered or unexported fields
}

TelegramChat ...

func (*TelegramChat) Add added in v0.5.0

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

Add ...

func (*TelegramChat) Delete added in v0.5.0

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

Delete ...

func (*TelegramChat) List added in v0.5.0

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

List ...

type Template added in v0.0.17

type Template struct {
	ITemplate
	// contains filtered or unexported fields
}

Template ...

func (*Template) Create added in v0.0.17

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

Create ...

func (*Template) Delete added in v0.0.17

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

Delete ...

func (*Template) GetByName added in v0.0.17

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

GetByName ...

func (*Template) GetItemByName added in v0.0.17

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

GetItemByName ...

func (*Template) GetItemsSortedList added in v0.0.17

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

GetItemsSortedList ...

func (*Template) GetItemsTree added in v0.0.17

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

GetItemsTree ...

func (*Template) GetList added in v0.0.17

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

GetList ...

func (*Template) GetMarkers added in v0.0.17

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

GetMarkers ...

func (*Template) Render added in v0.0.17

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

Render ...

func (*Template) Search added in v0.0.17

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

Search ...

func (*Template) UpdateItemsTree added in v0.0.17

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

UpdateItemsTree ...

func (*Template) UpdateOrCreate added in v0.0.17

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

UpdateOrCreate ...

func (*Template) UpdateStatus added in v0.0.17

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

UpdateStatus ...

type Trigger added in v0.5.0

type Trigger struct {
	ITrigger
	// contains filtered or unexported fields
}

Trigger ...

func (*Trigger) AddMultiple added in v0.5.0

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

AddMultiple ...

func (*Trigger) DeleteByTaskId added in v0.5.0

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

DeleteByTaskId ...

type User

type User struct {
	IUser
	// contains filtered or unexported fields
}

User ...

func (*User) Add

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

Add ...

func (*User) ClearResetPassToken

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

ClearResetPassToken ...

func (*User) ClearToken

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

ClearToken ...

func (*User) Delete

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

Delete ...

func (*User) GenResetPassToken

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

GenResetPassToken ...

func (*User) GetByAuthenticationToken

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

GetByAuthenticationToken ...

func (*User) GetByEmail

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

GetByEmail ...

func (*User) GetById

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

GetById ...

func (*User) GetByNickname added in v0.2.0

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

GetByNickname ...

func (*User) GetByResetPassToken

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

GetByResetPassToken ...

func (*User) List

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

List ...

func (*User) SignIn

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

SignIn ...

func (*User) Update

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

Update ...

type UserMeta

type UserMeta struct {
	IUserMeta
	// contains filtered or unexported fields
}

UserMeta ...

func GetUserMetaAdaptor

func GetUserMetaAdaptor(d *gorm.DB) *UserMeta

GetUserMetaAdaptor ...

func (*UserMeta) UpdateOrCreate

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

UpdateOrCreate ...

type Variable

type Variable struct {
	IVariable
	// contains filtered or unexported fields
}

Variable ...

func (*Variable) Add

func (n *Variable) Add(ver m.Variable) (err error)

Add ...

func (*Variable) CreateOrUpdate added in v0.5.0

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

CreateOrUpdate ...

func (*Variable) Delete

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

Delete ...

func (*Variable) GetAllEnabled

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

GetAllEnabled ...

func (*Variable) GetByName

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

GetByName ...

func (*Variable) List

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

List ...

func (*Variable) Update

func (n *Variable) Update(variable m.Variable) (err error)

Update ...

type Zigbee2mqtt added in v0.1.0

type Zigbee2mqtt struct {
	IZigbee2mqtt
	// contains filtered or unexported fields
}

Zigbee2mqtt ...

func (*Zigbee2mqtt) Add added in v0.1.0

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

Add ...

func (*Zigbee2mqtt) Delete added in v0.1.0

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

Delete ...

func (*Zigbee2mqtt) GetById added in v0.1.0

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

GetById ...

func (*Zigbee2mqtt) GetByLogin added in v0.1.0

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

GetByLogin ...

func (*Zigbee2mqtt) List added in v0.1.0

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

List ...

func (*Zigbee2mqtt) Update added in v0.1.0

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

Update ...

type Zigbee2mqttDevice added in v0.1.0

type Zigbee2mqttDevice struct {
	IZigbee2mqttDevice
	// contains filtered or unexported fields
}

Zigbee2mqttDevice ...

func (*Zigbee2mqttDevice) Add added in v0.1.0

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

Add ...

func (*Zigbee2mqttDevice) Delete added in v0.1.0

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

Delete ...

func (*Zigbee2mqttDevice) GetById added in v0.1.0

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

GetById ...

func (*Zigbee2mqttDevice) List added in v0.1.0

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

List ...

func (*Zigbee2mqttDevice) ListByBridgeId added in v0.5.2

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

ListByBridgeId ...

func (*Zigbee2mqttDevice) Search added in v0.1.0

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

Search ...

func (*Zigbee2mqttDevice) Update added in v0.1.0

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

Update ...

Jump to

Keyboard shortcuts

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