controllers

Apr 8, 2020

Changes in this version

+ type ControllerDashboard struct

+ func NewControllerDashboard(common *ControllerCommon) *ControllerDashboard

+ func (c *ControllerDashboard) Broadcast(param interface{})

+ func (c *ControllerDashboard) Start()

+ func (c *ControllerDashboard) Stop()

type Controllers

+ Dashboard *ControllerDashboard

+ type Workflow struct

+ func NewWorkflow(metric *metrics.MetricManager) *Workflow

+ func (d *Workflow) Broadcast() (map[string]interface{}, bool)

+ func (d *Workflow) GetWorkflowStatus(client stream.IStreamClient, message stream.Message)

Mar 10, 2020

Changes in this version

+ type ControllerAction struct

+ func NewControllerAction(common *ControllerCommon) *ControllerAction

+ func (c *ControllerAction) DoAction(client stream.IStreamClient, message stream.Message)

+ func (c *ControllerAction) Start()

+ func (c *ControllerAction) Stop()

+ type ControllerCommon struct

+ func NewControllerCommon(adaptors *adaptors.Adaptors, endpoint *endpoint.Endpoint, ...) *ControllerCommon

+ func (c *ControllerCommon) Err(client stream.IStreamClient, message stream.Message, err error)

+ type ControllerMap struct

+ func NewControllerMap(common *ControllerCommon) *ControllerMap

+ func (c *ControllerMap) Broadcast(param interface{})

+ func (c *ControllerMap) Start()

+ func (c *ControllerMap) Stop()

+ type Controllers struct

+ Action *ControllerAction

+ Map *ControllerMap

+ func NewControllers(adaptors *adaptors.Adaptors, scripts *scripts.ScriptService, core *core.Core, ...) *Controllers

+ func (s *Controllers) Start()

+ func (s *Controllers) Stop()

+ type Devices struct

+ func NewDevices(metric *metrics.MetricManager) *Devices

+ func (d *Devices) Broadcast(cursor metrics.MapElementCursor) (map[string]interface{}, bool)

+ func (d *Devices) GetDevicesStates(client stream.IStreamClient, message stream.Message)

+ type MapElement struct

+ ElementName string

+ Id int64

+ Options interface{}

+ StatusId int64