adaptors

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2020 License: GPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type Adaptors 

type Adaptors struct {
	Node                  *Node
	Script                *Script
	Workflow              *Workflow
	WorkflowScenario      *WorkflowScenario
	Device                *Device
	DeviceAction          *DeviceAction
	DeviceState           *DeviceState
	Flow                  *Flow
	FlowElement           *FlowElement
	FlowSubscription      *FlowSubscription
	FlowZigbee2mqttDevice *FlowZigbee2mqttDevice
	Connection            *Connection
	Worker                *Worker
	Role                  *Role
	Permission            *Permission
	User                  *User
	UserMeta              *UserMeta
	Image                 *Image
	Variable              *Variable
	Map                   *Map
	MapLayer              *MapLayer
	MapText               *MapText
	MapImage              *MapImage
	MapDevice             *MapDevice
	MapElement            *MapElement
	MapDeviceState        *MapDeviceState
	MapDeviceAction       *MapDeviceAction
	Log                   *Log
	MapZone               *MapZone
	Template              *Template
	Message               *Message
	MessageDelivery       *MessageDelivery
	Zigbee2mqtt           *Zigbee2mqtt
	Zigbee2mqttDevice     *Zigbee2mqttDevice
	// contains filtered or unexported fields
}

func NewAdaptors 

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

func (Adaptors) Begin added in v0.1.0 

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

func (*Adaptors) Commit added in v0.1.0 

func (a *Adaptors) Commit() error

func (*Adaptors) Rollback added in v0.1.0 

func (a *Adaptors) Rollback() error

type Connection 

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

func GetConnectionAdaptor 

func GetConnectionAdaptor(d *gorm.DB) *Connection

func (*Connection) Add 

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

func (*Connection) AddOrUpdateConnection 

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

func (*Connection) Delete 

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

func (*Connection) GetById 

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

func (*Connection) List 

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

func (*Connection) Update 

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

type Device 

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

func GetDeviceAdaptor 

func GetDeviceAdaptor(d *gorm.DB) *Device

func (*Device) Add 

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

func (*Device) Delete 

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

func (*Device) GetAllEnabled 

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

func (*Device) GetById 

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

func (*Device) List 

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

func (*Device) Search 

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

func (*Device) Update 

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

type DeviceAction 

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

func GetDeviceActionAdaptor 

func GetDeviceActionAdaptor(d *gorm.DB) *DeviceAction

func (*DeviceAction) Add 

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

func (*DeviceAction) Delete 

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

func (*DeviceAction) GetByDeviceId 

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

func (*DeviceAction) GetById 

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

func (*DeviceAction) List 

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

func (*DeviceAction) Search 

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

func (*DeviceAction) Update 

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

type DeviceDefault 

type DeviceDefault struct {
	Address *int `json:"address"`
}

type DeviceSmartBus 

type DeviceSmartBus struct {
	Address  *int          `json:"address"`
	Baud     int           `json:"baud"`
	Sleep    int64         `json:"sleep"`
	StopBite int64         `json:"stop_bite"`
	Timeout  time.Duration `json:"timeout"`
	Tty      string        `json:"tty"`
}

type DeviceState 

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

func GetDeviceStateAdaptor 

func GetDeviceStateAdaptor(d *gorm.DB) *DeviceState

func (*DeviceState) Add 

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

func (*DeviceState) Delete 

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

func (*DeviceState) GetByDeviceId 

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

func (*DeviceState) GetById 

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

func (*DeviceState) List 

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

func (*DeviceState) Update 

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

type DeviceZigBee 

type DeviceZigBee struct {
	Address string `json:"address"`
}

type Flow 

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

func GetFlowAdaptor 

func GetFlowAdaptor(d *gorm.DB) *Flow

func (*Flow) Add 

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

func (*Flow) Delete 

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

func (*Flow) GetAllEnabled 

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

func (*Flow) GetAllEnabledByWorkflow 

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

func (*Flow) GetById 

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

func (*Flow) List 

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

func (*Flow) Search 

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

func (*Flow) Update 

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

type FlowElement 

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

func GetFlowElementAdaptor 

func GetFlowElementAdaptor(d *gorm.DB) *FlowElement

func (*FlowElement) Add 

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

func (*FlowElement) AddOrUpdateFlowElement 

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

func (*FlowElement) Delete 

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

func (*FlowElement) GetAllEnabled 

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

func (*FlowElement) GetById 

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

func (*FlowElement) List 

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

func (*FlowElement) Update 

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

type FlowSubscription added in v0.0.21 

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

func GetFlowSubscriptionAdaptor added in v0.0.21 

func GetFlowSubscriptionAdaptor(Db *gorm.DB) *FlowSubscription

func (*FlowSubscription) Add added in v0.0.21 

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

func (*FlowSubscription) Remove added in v0.0.21 

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

type FlowZigbee2mqttDevice added in v0.1.0 

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

func GetFlowZigbee2mqttDeviceAdaptor added in v0.1.0 

func GetFlowZigbee2mqttDeviceAdaptor(Db *gorm.DB) *FlowZigbee2mqttDevice

func (*FlowZigbee2mqttDevice) Add added in v0.1.0 

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

func (*FlowZigbee2mqttDevice) Remove added in v0.1.0 

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

type Image 

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

func GetImageAdaptor 

func GetImageAdaptor(d *gorm.DB) *Image

func (*Image) Add 

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

func (*Image) AddMultiple 

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

func (*Image) Delete 

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

func (*Image) GetAllByDate 

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

func (*Image) GetById 

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

func (*Image) GetFilterList 

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

func (*Image) List 

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

func (*Image) Update 

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

func (*Image) UploadImage 

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

type Log 

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

func GetLogAdaptor 

func GetLogAdaptor(d *gorm.DB) *Log

func (*Log) Add 

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

func (*Log) AddMultiple added in v0.0.19 

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

func (*Log) Delete 

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

func (*Log) GetById 

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

func (*Log) List 

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

func (*Log) Search 

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

type Map 

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

func GetMapAdaptor 

func GetMapAdaptor(d *gorm.DB) *Map

func (*Map) Add 

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

func (*Map) Delete 

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

func (*Map) GetById 

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

func (*Map) GetFullById 

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

func (*Map) List 

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

func (*Map) Search 

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

func (*Map) Update 

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

type MapDevice 

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

func GetMapDeviceAdaptor 

func GetMapDeviceAdaptor(d *gorm.DB) *MapDevice

func (*MapDevice) Add 

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

func (*MapDevice) Delete 

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

func (*MapDevice) GetById 

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

type MapDeviceAction 

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

func GetMapDeviceActionAdaptor 

func GetMapDeviceActionAdaptor(d *gorm.DB) *MapDeviceAction

func (*MapDeviceAction) Add 

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

func (*MapDeviceAction) AddMultiple 

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

type MapDeviceState 

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

func GetMapDeviceStateAdaptor 

func GetMapDeviceStateAdaptor(d *gorm.DB) *MapDeviceState

func (*MapDeviceState) Add 

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

func (*MapDeviceState) AddMultiple 

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

type MapElement 

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

func GetMapElementAdaptor 

func GetMapElementAdaptor(d *gorm.DB) *MapElement

func (*MapElement) Add 

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

func (*MapElement) Delete 

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

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)

func (*MapElement) GetById 

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

func (*MapElement) List 

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

func (*MapElement) Sort 

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

func (*MapElement) Update 

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

type MapImage 

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

func GetMapImageAdaptor 

func GetMapImageAdaptor(d *gorm.DB) *MapImage

func (*MapImage) Add 

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

func (*MapImage) Delete 

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

func (*MapImage) GetById 

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

func (*MapImage) List 

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

func (*MapImage) Sort 

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

func (*MapImage) Update 

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

type MapLayer 

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

func GetMapLayerAdaptor 

func GetMapLayerAdaptor(d *gorm.DB) *MapLayer

func (*MapLayer) Add 

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

func (*MapLayer) Delete 

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

func (*MapLayer) GetById 

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

func (*MapLayer) List 

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

func (*MapLayer) Sort 

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

func (*MapLayer) Update 

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

type MapText 

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

func GetMapTextAdaptor 

func GetMapTextAdaptor(d *gorm.DB) *MapText

func (*MapText) Add 

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

func (*MapText) Delete 

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

func (*MapText) GetById 

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

func (*MapText) List 

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

func (*MapText) Sort 

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

func (*MapText) Update 

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

type MapZone added in v0.0.14 

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

func GetMapZoneAdaptor added in v0.0.14 

func GetMapZoneAdaptor(d *gorm.DB) *MapZone

func (*MapZone) Add added in v0.0.14 

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

func (*MapZone) Clean added in v0.0.14 

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

func (*MapZone) Delete added in v0.0.14 

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

func (*MapZone) GetByName added in v0.0.14 

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

func (*MapZone) Search added in v0.0.14 

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

type Message added in v0.0.17 

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

func GetMessageAdaptor added in v0.0.17 

func GetMessageAdaptor(d *gorm.DB) *Message

func (*Message) Add added in v0.0.17 

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

type MessageDelivery added in v0.0.17 

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

func GetMessageDeliveryAdaptor added in v0.0.17 

func GetMessageDeliveryAdaptor(d *gorm.DB) *MessageDelivery

func (*MessageDelivery) Add added in v0.0.17 

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

func (*MessageDelivery) Delete added in v0.0.17 

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

func (*MessageDelivery) GetAllUncompleted added in v0.0.17 

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

func (*MessageDelivery) GetById added in v0.0.17 

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

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)

func (*MessageDelivery) SetStatus added in v0.0.17 

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

type Node 

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

func GetNodeAdaptor 

func GetNodeAdaptor(d *gorm.DB) *Node

func (*Node) Add 

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

func (*Node) Delete 

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

func (*Node) GetAllEnabled 

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

func (*Node) GetById 

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

func (*Node) GetByLogin 

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

func (*Node) List 

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

func (*Node) Search 

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

func (*Node) Update 

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

type Permission 

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

func GetPermissionAdaptor 

func GetPermissionAdaptor(d *gorm.DB) *Permission

func (*Permission) Add 

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

func (*Permission) Delete 

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

func (*Permission) GetAllPermissions 

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

type Role 

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

func GetRoleAdaptor 

func GetRoleAdaptor(d *gorm.DB) *Role

func (*Role) Add 

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

func (*Role) Delete 

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

func (*Role) GetAccessList 

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

func (*Role) GetByName 

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

func (*Role) List 

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

func (*Role) Search 

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

func (*Role) Update 

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

type Script 

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

func GetScriptAdaptor 

func GetScriptAdaptor(d *gorm.DB) *Script

func (*Script) Add 

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

func (*Script) Delete 

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

func (*Script) GetById 

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

func (*Script) List 

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

func (*Script) Search 

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

func (*Script) Update 

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

type Template added in v0.0.17 

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

func GetTemplateAdaptor added in v0.0.17 

func GetTemplateAdaptor(d *gorm.DB) *Template

func (*Template) Create added in v0.0.17 

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

func (*Template) Delete added in v0.0.17 

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

func (*Template) GetByName added in v0.0.17 

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

func (*Template) GetItemByName added in v0.0.17 

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

func (*Template) GetItemsSortedList added in v0.0.17 

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

func (*Template) GetItemsTree added in v0.0.17 

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

func (*Template) GetList added in v0.0.17 

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

func (*Template) GetMarkers added in v0.0.17 

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

func (*Template) Render added in v0.0.17 

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

func (*Template) Search added in v0.0.17 

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

func (*Template) UpdateItemsTree added in v0.0.17 

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

func (*Template) UpdateOrCreate added in v0.0.17 

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

func (*Template) UpdateStatus added in v0.0.17 

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

type User 

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

func GetUserAdaptor 

func GetUserAdaptor(d *gorm.DB) *User

func (*User) Add 

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

func (*User) ClearResetPassToken 

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

func (*User) ClearToken 

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

func (*User) Delete 

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

func (*User) GenResetPassToken 

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

func (*User) GetByAuthenticationToken 

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

func (*User) GetByEmail 

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

func (*User) GetById 

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

func (*User) GetByResetPassToken 

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

func (*User) List 

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

func (*User) NewToken 

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

func (*User) SignIn 

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

func (*User) Update 

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

type UserMeta 

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

func GetUserMetaAdaptor 

func GetUserMetaAdaptor(d *gorm.DB) *UserMeta

func (*UserMeta) UpdateOrCreate 

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

type Variable 

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

func GetVariableAdaptor 

func GetVariableAdaptor(d *gorm.DB) *Variable

func (*Variable) Add 

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

func (*Variable) Delete 

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

func (*Variable) GetAllEnabled 

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

func (*Variable) GetByName 

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

func (*Variable) List 

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

func (*Variable) Update 

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

type Worker 

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

func GetWorkerAdaptor 

func GetWorkerAdaptor(d *gorm.DB) *Worker

func (*Worker) Add 

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

func (*Worker) Delete 

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

func (*Worker) GetAllEnabled 

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

func (*Worker) GetById 

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

func (*Worker) List 

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

func (*Worker) Update 

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

type Workflow 

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

func GetWorkflowAdaptor 

func GetWorkflowAdaptor(d *gorm.DB) *Workflow

func (*Workflow) Add 

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

func (*Workflow) AddScript 

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

func (*Workflow) Delete 

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

func (*Workflow) DependencyLoading 

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

func (*Workflow) GetAllEnabled 

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

func (*Workflow) GetById 

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

func (*Workflow) GetByWorkflowScenarioId added in v0.0.25 

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

func (*Workflow) List 

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

func (*Workflow) RemoveScript 

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

func (*Workflow) Search 

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

func (*Workflow) SetScenario 

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

func (*Workflow) Update 

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

func (*Workflow) UpdateScripts 

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

type WorkflowScenario 

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

func GetWorkflowScenarioAdaptor 

func GetWorkflowScenarioAdaptor(d *gorm.DB) *WorkflowScenario

func (*WorkflowScenario) Add 

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

func (*WorkflowScenario) AddScript 

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

func (*WorkflowScenario) Delete 

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

func (*WorkflowScenario) GetById 

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

func (*WorkflowScenario) List 

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

func (*WorkflowScenario) ListByWorkflow 

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

func (*WorkflowScenario) RemoveScript 

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

func (*WorkflowScenario) Search 

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

func (*WorkflowScenario) Update 

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

func (*WorkflowScenario) UpdateScripts 

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

type Zigbee2mqtt added in v0.1.0 

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

func GetZigbee2mqttAdaptor added in v0.1.0 

func GetZigbee2mqttAdaptor(d *gorm.DB) *Zigbee2mqtt

func (*Zigbee2mqtt) Add added in v0.1.0 

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

func (*Zigbee2mqtt) Delete added in v0.1.0 

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

func (*Zigbee2mqtt) GetById added in v0.1.0 

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

func (*Zigbee2mqtt) GetByLogin added in v0.1.0 

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

func (*Zigbee2mqtt) List added in v0.1.0 

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

func (*Zigbee2mqtt) Update added in v0.1.0 

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

type Zigbee2mqttDevice added in v0.1.0 

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

func GetZigbee2mqttDeviceAdaptor added in v0.1.0 

func GetZigbee2mqttDeviceAdaptor(d *gorm.DB) *Zigbee2mqttDevice

func (*Zigbee2mqttDevice) Add added in v0.1.0 

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

func (*Zigbee2mqttDevice) Delete added in v0.1.0 

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

func (*Zigbee2mqttDevice) GetById added in v0.1.0 

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

func (*Zigbee2mqttDevice) List added in v0.1.0 

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

func (*Zigbee2mqttDevice) Search added in v0.1.0 

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

func (*Zigbee2mqttDevice) Update added in v0.1.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.