core

Apr 8, 2020

Changes in this version

type Core

+ func (c *Core) DoAction(deviceActionId int64) (result string, err error)

Mar 31, 2020

Changes in this version

type ActionBind

+ Description string

+ Id int64

+ Name string

+ func NewActionBind(id int64, name, desc string, action *Action) *ActionBind

type Device

+ func NewDevice(dev *m.Device, node *Node, mqtt *mqtt.Mqtt, adaptors *adaptors.Adaptors, ...) *Device

+ func (d Device) Mqtt(path string, payload []byte) (result DevMqttResponse)

+ func (d Device) Zigbee2mqtt(path string, payload []byte) (result DevZigbee2mqttResponse)

type DeviceBind

+ func NewDeviceBind(model *m.Device, node *Node, mqtt *mqtt.Mqtt, adaptors *adaptors.Adaptors, ...) *DeviceBind

+ func (d *DeviceBind) Mqtt(path string, payload []byte) (result DevMqttResponse)

+ func (d *DeviceBind) Send(payload interface{}) (result interface{})

+ func (d *DeviceBind) Zigbee2mqtt(path string, payload []byte) (result DevZigbee2mqttResponse)

type MapElement

+ func NewMapElement(elementName string, systemName *string, _map *Map, adaptors *adaptors.Adaptors) (*MapElement, error)

+ func (e *MapElement) CustomHistory(logLevel, t, desc string)

type MapElementBind

+ func (e *MapElementBind) Story(logLevel, t, desc string)

type Node

+ func (n *Node) Model() *m.Node

Mar 10, 2020

Changes in this version

type Map

+ func NewMap(metric *metrics.MetricManager) *Map

Feb 13, 2020

Changes in this version

+ const Done

+ const Ended

+ const Error

+ const InProcess

+ const Started

type Core

+ func (b *Core) GetStatusAllWorkflow() (statusList []m.DashboardWorkflowStatus)

+ func (c *Core) GetStatusWorkflow(workflowId int64) (status m.DashboardWorkflowStatus, err error)

type Flow

+ func (f *Flow) GetMessage() *Message

+ func (f *Flow) SetMessage(msg *Message)

type Message

+ func (m *Message) Update(newMsg *Message)

type Node

+ func (n *Node) GetConnStatus() string

+ func (n *Node) GetStat() NodeStat

+ func (n *Node) Remove()

+ func (n *Node) UpdateClientParams(params *m.Node)

+ type NodeStat struct

+ ConnStatus string

+ IsConnected bool

+ LastPing time.Time

+ Max int64

+ Min int64

+ Rps int64

+ StartedAt time.Time

+ Status NodeStatus

+ Thread int

type Workflow

+ func (wf *Workflow) DoWorker(model *m.Worker) (err error)

+ func (wf *Workflow) RemoveWorker(_worker *m.Worker) (err error)

+ func (wf *Workflow) UpdateWorker(_worker *m.Worker) (err error)

Dec 11, 2019

Changes in this version

type Message

+ Mqtt bool

+ func (m *Message) GetVar(key string) (value interface{})

+ func (m *Message) SetVar(key string, value interface{})

type Node

+ func (n *Node) MqttPublish(msg interface{})

Nov 27, 2019

Changes in this version

type Device

+ func (d *Device) ModBus(f string, address, count uint16, command []uint16) (result *DevModBusResponse)

Nov 10, 2019

Changes in this version

type Storage

+ func NewStorage() Storage

type Worker

+ func (w *Worker) Start()

+ func (w *Worker) Stop()

Jul 28, 2019

Changes in this version

type Node

+ ConnStatus string

Jun 13, 2019

Changes in this version

+ const DONE

+ const ENDED

+ const ERROR

+ const IN_PROCESS

+ const STARTED

+ func NewCron() (cron *cr.Cron)

+ type Action struct

+ Device *m.Device

+ Message *Message

+ Node *Node

+ ScriptEngine *scripts.Engine

+ func NewAction(device *m.Device, script *m.Script, node *Node, flow *Flow, ...) (action *Action, err error)

+ func (a *Action) Do() (res string, err error)

+ func (a *Action) GetDevice() *m.Device

+ func (a *Action) GetNode() *Node

+ func (a *Action) NewScript() (err error)

+ type ActionBind struct

+ func (a *ActionBind) Device() *DeviceBind

+ func (a *ActionBind) Node() *NodeBind

+ type ActionPrototypes interface

+ After func(*Message, *Flow) error

+ Before func(*Message, *Flow) error

+ Run func(*Message, *Flow) error

+ Type func() string

+ type Core struct

+ Map *Map

+ func NewCore(adaptors *adaptors.Adaptors, scripts *scripts.ScriptService, ...) (core *Core, err error)

+ func (b *Core) AddFlow(flow *m.Flow) (err error)

+ func (b *Core) AddNode(node *m.Node) (n *Node, err error)

+ func (b *Core) AddWorkflow(workflow *m.Workflow) (err error)

+ func (b *Core) ConnectNode(node *m.Node) (err error)

+ func (b *Core) DeleteWorkflow(workflow *m.Workflow) (err error)

+ func (b *Core) DisconnectNode(node *m.Node) (err error)

+ func (b *Core) DoWorker(model *m.Worker) (err error)

+ func (b *Core) GetFlow(id int64) (*Flow, error)

+ func (b *Core) GetNodeById(nodeId int64) *Node

+ func (b *Core) GetNodes() (nodes map[int64]*Node)

+ func (b *Core) InitWorkflows() (err error)

+ func (b *Core) ReloadNode(node *m.Node) (err error)

+ func (b *Core) RemoveFlow(flow *m.Flow) (err error)

+ func (b *Core) RemoveNode(node *m.Node) (err error)

+ func (b *Core) RemoveWorker(_worker *m.Worker) (err error)

+ func (b *Core) Restart() (err error)

+ func (b *Core) Shutdown()

+ func (b *Core) Stop() (err error)

+ func (b *Core) UpdateFlow(flow *m.Flow) (err error)

+ func (b *Core) UpdateFlowFromDevice(device *m.Device) (err error)

+ func (b *Core) UpdateWorker(_worker *m.Worker) (err error)

+ func (b *Core) UpdateWorkflow(workflow *m.Workflow) (err error)

+ func (b *Core) UpdateWorkflowScenario(workflow *m.Workflow) (err error)

+ func (c *Core) Run() (err error)

+ func (wf *Core) GetWorkflow(workflowId int64) (workflow *Workflow, err error)

+ type Device struct

+ func (d *Device) ModbusBus(f string, address, count uint16, command []uint16) (result *DevModBusResponse)

+ func (d *Device) RunCommand(name string, args []string) (result *DevCommandResponse)

+ func (d *Device) SmartBus(command []byte) (result *DevSmartBusResponse)

+ type DeviceBind struct

+ func (d *DeviceBind) GetDescription() string

+ func (d *DeviceBind) GetModel() *m.Device

+ func (d *DeviceBind) GetName() string

+ func (d *DeviceBind) ModBus(f string, address, count uint16, command []uint16) (result *DevModBusResponse)

+ func (d *DeviceBind) RunCommand(name string, args []string) (result *DevCommandResponse)

+ func (d *DeviceBind) SmartBus(command []byte) (result *DevSmartBusResponse)

+ type Flow struct

+ Connections []*m.Connection

+ FlowElements []*FlowElement

+ Model *m.Flow

+ Node *Node

+ Workers map[int64]*Worker

+ func NewFlow(model *m.Flow, workflow *Workflow, adaptors *adaptors.Adaptors, ...) (flow *Flow, err error)

+ func (f *Flow) AddWorker(model *m.Worker) (err error)

+ func (f *Flow) InitWorkers() (err error)

+ func (f *Flow) NewMessage(message *Message) (err error)

+ func (f *Flow) NewScript(s ...*m.Script) (engine *scripts.Engine, err error)

+ func (f *Flow) Remove()

+ func (f *Flow) RemoveWorker(worker *m.Worker) (err error)

+ func (f *Flow) UpdateWorker(worker *m.Worker) (err error)

+ type FlowBind struct

+ func (f *FlowBind) GetDescription() string

+ func (f *FlowBind) GetName() string

+ func (f *FlowBind) GetVar(key string) interface{}

+ func (f *FlowBind) Node() *NodeBind

+ func (f *FlowBind) SetVar(key string, value interface{})

+ type FlowElement struct

+ Action *Action

+ Flow *Flow

+ Model *m.FlowElement

+ Prototype ActionPrototypes

+ ScriptEngine *scripts.Engine

+ Workflow *Workflow

+ func NewFlowElement(model *m.FlowElement, flow *Flow, workflow *Workflow, ...) (flowElement *FlowElement, err error)

+ func (m *FlowElement) After(message *Message) error

+ func (m *FlowElement) Before(message *Message) error

+ func (m *FlowElement) GetStatus() (status Status)

+ func (m *FlowElement) Run(msg *Message) (b bool, returnMessage *Message, err error)

+ type FlowLink struct

+ func (m *FlowLink) After(message *Message, flow *Flow) (err error)

+ func (m *FlowLink) Before(message *Message, flow *Flow) (err error)

+ func (m *FlowLink) Run(message *Message, flow *Flow) (err error)

+ func (m *FlowLink) Type() string

+ type Gateway struct

+ func (m *Gateway) After(message *Message, flow *Flow) (err error)

+ func (m *Gateway) Before(message *Message, flow *Flow) (err error)

+ func (m *Gateway) Run(message *Message, flow *Flow) (err error)

+ func (m *Gateway) Type() string

+ type IGetMap interface

+ GetMap func() *Map

+ type ITelemetry interface

+ Broadcast func(pack string)

+ BroadcastOne func(pack string, deviceId int64, elementName string)

+ Run func(core *Core)

+ Stop func()

+ type Map struct

+ func (b *Map) GetAllElements() (elements []*MapElement)

+ func (b *Map) GetDevicesStates() (states map[int64]*m.DeviceState)

+ func (b *Map) GetElement(device *m.Device, elementName string) (element *MapElement)

+ func (b *Map) GetElements(device *m.Device) (elements []*MapElement)

+ func (b *Map) NewMapElement(device *m.Device, elementName string, state *m.DeviceState) *MapElement

+ func (b *Map) SetElementState(device *m.Device, elementName, systemName string)

+ type MapBind struct

+ Map *Map

+ func (e *MapBind) GetElement(device *DeviceBind, elementName string) (element *MapElementBind)

+ func (e *MapBind) GetElements(device *DeviceBind) (elements []*MapElementBind)

+ func (e *MapBind) SetElementState(device *m.Device, elementName, newState string)

+ type MapElement struct

+ Device *m.Device

+ ElementName string

+ Map *Map

+ Options interface{}

+ State *m.DeviceState

+ func (e *MapElement) GetOptions() interface{}

+ func (e *MapElement) GetState() interface{}

+ func (e *MapElement) SetOptions(options interface{})

+ func (e *MapElement) SetState(systemName string)

+ type MapElementBind struct

+ func (e *MapElementBind) GetOptions() interface{}

+ func (e *MapElementBind) GetState() interface{}

+ func (e *MapElementBind) SetOptions(options interface{})

+ func (e *MapElementBind) SetState(name string)

+ type Message struct

+ Direction bool

+ Error string

+ Success bool

+ func NewMessage() (m *Message)

+ func (m *Message) Clear()

+ func (m *Message) Copy() (msg *Message)

+ func (m *Message) Ok()

+ func (m *Message) SetError(err string)

+ func (m *Message) Setdir(d bool)

+ type MessageEmitter struct

+ func (m *MessageEmitter) After(message *Message, flow *Flow) (err error)

+ func (m *MessageEmitter) Before(message *Message, flow *Flow) (err error)

+ func (m *MessageEmitter) Run(message *Message, flow *Flow) (err error)

+ func (m *MessageEmitter) Type() string

+ type MessageHandler struct

+ func (m *MessageHandler) After(message *Message, flow *Flow) (err error)

+ func (m *MessageHandler) Before(message *Message, flow *Flow) (err error)

+ func (m *MessageHandler) Run(message *Message, flow *Flow) (err error)

+ func (m *MessageHandler) Type() string

+ type Node struct

+ IsConnected bool

+ func NewNode(model *m.Node, mqtt *mqtt.Mqtt) *Node

+ func (n *Node) Connect() *Node

+ func (n *Node) Disconnect()

+ func (n *Node) Send(device *m.Device, command []byte) (result NodeResponse, err error)

+ type NodeBind struct

+ func (n *NodeBind) Description() string

+ func (n *NodeBind) Ip() string

+ func (n *NodeBind) IsConnected() bool

+ func (n *NodeBind) Name() string

+ func (n *NodeBind) Stat() *NodeStatModel

+ func (n *NodeBind) Status() string

+ type NodeMessage struct

+ Command json.RawMessage

+ DeviceId int64

+ DeviceType common.DeviceType

+ Properties json.RawMessage

+ type NodeResponse struct

+ DeviceId int64

+ DeviceType common.DeviceType

+ Properties json.RawMessage

+ Response json.RawMessage

+ Status string

+ Time float64

+ type NodeStatModel struct

+ Max int64

+ Min int64

+ Rps int64

+ StartedAt time.Time

+ Status NodeStatus

+ Thread int

+ type NodeStatus string

+ type Nodes []*Node

+ type Status string

+ type Storage struct

+ func (s *Storage) GetVar(key string) interface{}

+ func (s *Storage) SetVar(key string, value interface{})

+ type Task struct

+ func (m *Task) After(message *Message, flow *Flow) (err error)

+ func (m *Task) Before(message *Message, flow *Flow) (err error)

+ func (m *Task) Run(message *Message, flow *Flow) (err error)

+ func (m *Task) Type() string

+ type Worker struct

+ CronTask *cr.Task

+ Model *m.Worker

+ func NewWorker(model *m.Worker, flow *Flow, cron *cr.Cron) (worker *Worker)

+ func (w *Worker) Actions() map[int64]*Action

+ func (w *Worker) AddAction(action *Action)

+ func (w *Worker) Do()

+ func (w *Worker) RegTask()

+ func (w *Worker) RemoveActions()

+ func (w *Worker) RemoveTask() (err error)

+ type Workflow struct

+ Flows map[int64]*Flow

+ func NewWorkflow(model *m.Workflow, adaptors *adaptors.Adaptors, scripts *scripts.ScriptService, ...) (workflow *Workflow)

+ func (wf *Workflow) AddFlow(flow *m.Flow) (err error)

+ func (wf *Workflow) GetFLow(flowId int64) (flow *Flow, err error)

+ func (wf *Workflow) NewScript(model *m.Script) (engine *scripts.Engine, err error)

+ func (wf *Workflow) RemoveFlow(flow *m.Flow) (err error)

+ func (wf *Workflow) Restart() (err error)

+ func (wf *Workflow) Run() (err error)

+ func (wf *Workflow) SetScenario(systemName string) (err error)

+ func (wf *Workflow) Stop() (err error)

+ func (wf *Workflow) UpdateFlow(flow *m.Flow) (err error)

+ func (wf *Workflow) UpdateScenario() (err error)

+ type WorkflowBind struct

+ func (w *WorkflowBind) GetDescription() string

+ func (w *WorkflowBind) GetName() string

+ func (w *WorkflowBind) GetScenario() string

+ func (w *WorkflowBind) GetScenarioName() string

+ func (w *WorkflowBind) GetVar(key string) interface{}

+ func (w *WorkflowBind) SetScenario(system_name string)

+ func (w *WorkflowBind) SetVar(key string, value interface{})