controllers

Documentation

Index

• type ControllerAction
  • 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
  • func NewControllerCommon(adaptors *adaptors.Adaptors, stream *stream.StreamService, ...) *ControllerCommon
  • func (c *ControllerCommon) Err(client stream.IStreamClient, message stream.Message, err error)
• type ControllerDashboard
  • func NewControllerDashboard(common *ControllerCommon) (dashboard *ControllerDashboard)
  • func (t *ControllerDashboard) Broadcast(param interface{})
  • func (c *ControllerDashboard) Start()
  • func (c *ControllerDashboard) Stop()
  • func (t *ControllerDashboard) Telemetry(client stream.IStreamClient, message stream.Message)
• type ControllerImage
  • func NewControllerImage(common *ControllerCommon) *ControllerImage
  • func (c *ControllerImage) GetFilterList(client stream.IStreamClient, message stream.Message)
  • func (c *ControllerImage) GetImageList(client stream.IStreamClient, message stream.Message)
  • func (c *ControllerImage) RemoveImage(client stream.IStreamClient, message stream.Message)
  • func (c *ControllerImage) Start()
  • func (c *ControllerImage) Stop()
• type ControllerMap
  • func NewControllerMap(common *ControllerCommon) *ControllerMap
  • func (c *ControllerMap) Broadcast(param interface{})
  • func (c *ControllerMap) Start()
  • func (c *ControllerMap) Stop()
• type ControllerWorker
  • func NewControllerWorker(common *ControllerCommon) *ControllerWorker
  • func (c *ControllerWorker) DoWorker(client stream.IStreamClient, message stream.Message)
  • func (c *ControllerWorker) Start()
  • func (c *ControllerWorker) Stop()
• type Controllers
  • func NewControllers(adaptors *adaptors.Adaptors, stream *stream.StreamService, ...) *Controllers
  • func (s *Controllers) Start()
  • func (s *Controllers) Stop()

Types

type ControllerAction

type ControllerAction struct {
	*ControllerCommon
}

func NewControllerAction

func NewControllerAction(common *ControllerCommon) *ControllerAction

func (*ControllerAction) DoAction

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

Stream

func (*ControllerAction) Start

func (c *ControllerAction) Start()

func (*ControllerAction) Stop

func (c *ControllerAction) Stop()

type ControllerCommon

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

func NewControllerCommon

func NewControllerCommon(adaptors *adaptors.Adaptors,
	stream *stream.StreamService,
	endpoint *endpoint.Endpoint,
	scripts *scripts.ScriptService,
	core *core.Core,
	metric *metrics.MetricManager,
	mqtt *mqtt.Mqtt,
	zigbee2mqtt *zigbee2mqtt.Zigbee2mqtt) *ControllerCommon

func (*ControllerCommon) Err

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

type ControllerDashboard

type ControllerDashboard struct {
	*ControllerCommon
	Nodes       *dashboardModel.Nodes
	Devices     *dashboardModel.Devices
	Workflow    *dashboardModel.Workflow
	Gate        *dashboardModel.Gate
	Cpu         *dashboardModel.Cpu
	Flow        *dashboardModel.Flow
	Memory      *dashboardModel.Memory
	AppMemory   *dashboardModel.AppMemory
	Uptime      *dashboardModel.Uptime
	Disk        *dashboardModel.Disk
	Mqtt        *dashboardModel.Mqtt
	History     *dashboardModel.History
	Zigbee2Mqtt *dashboardModel.Zigbee2Mqtt
	// contains filtered or unexported fields
}

func NewControllerDashboard

func NewControllerDashboard(common *ControllerCommon) (dashboard *ControllerDashboard)

func (*ControllerDashboard) Broadcast

func (t *ControllerDashboard) Broadcast(param interface{})

func (*ControllerDashboard) Start

func (c *ControllerDashboard) Start()

func (*ControllerDashboard) Stop

func (c *ControllerDashboard) Stop()

func (*ControllerDashboard) Telemetry

func (t *ControllerDashboard) Telemetry(client stream.IStreamClient, message stream.Message)

only on request: 'dashboard.get.telemetry'

type ControllerImage

type ControllerImage struct {
	*ControllerCommon
}

func NewControllerImage

func NewControllerImage(common *ControllerCommon) *ControllerImage

func (*ControllerImage) GetFilterList

func (c *ControllerImage) GetFilterList(client stream.IStreamClient, message stream.Message)

func (*ControllerImage) GetImageList

func (c *ControllerImage) GetImageList(client stream.IStreamClient, message stream.Message)

Stream

func (*ControllerImage) RemoveImage

func (c *ControllerImage) RemoveImage(client stream.IStreamClient, message stream.Message)

func (*ControllerImage) Start

func (c *ControllerImage) Start()

func (*ControllerImage) Stop

func (c *ControllerImage) Stop()

type ControllerMap

type ControllerMap struct {
	*ControllerCommon
	// contains filtered or unexported fields
}

func NewControllerMap

func NewControllerMap(common *ControllerCommon) *ControllerMap

func (*ControllerMap) Broadcast

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

method callable from metric service

func (*ControllerMap) Start

func (c *ControllerMap) Start()

func (*ControllerMap) Stop

func (c *ControllerMap) Stop()

type ControllerWorker

type ControllerWorker struct {
	*ControllerCommon
}

func NewControllerWorker

func NewControllerWorker(common *ControllerCommon) *ControllerWorker

func (*ControllerWorker) DoWorker

func (c *ControllerWorker) DoWorker(client stream.IStreamClient, message stream.Message)

Stream

func (*ControllerWorker) Start

func (c *ControllerWorker) Start()

func (*ControllerWorker) Stop

func (c *ControllerWorker) Stop()

type Controllers

type Controllers struct {
	Image     *ControllerImage
	Worker    *ControllerWorker
	Action    *ControllerAction
	Dashboard *ControllerDashboard
	Map       *ControllerMap
}

func NewControllers

func NewControllers(adaptors *adaptors.Adaptors,
	stream *stream.StreamService,
	scripts *scripts.ScriptService,
	core *core.Core,
	endpoint *endpoint.Endpoint,
	metrics *metrics2.MetricManager,
	mqtt *mqtt.Mqtt,
	zigbee2mqtt *zigbee2mqtt.Zigbee2mqtt) *Controllers

func (*Controllers) Start

func (s *Controllers) Start()

func (*Controllers) Stop

func (s *Controllers) Stop()