Documentation
¶
Index ¶
- type ControllerAction
- type ControllerCommon
- type ControllerDashboard
- type 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
- type ControllerWorker
- type Controllers
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ControllerAction ¶
type ControllerAction struct {
*ControllerCommon
}
ControllerAction ...
func NewControllerAction ¶
func NewControllerAction(common *ControllerCommon) *ControllerAction
NewControllerAction ...
func (*ControllerAction) DoAction ¶
func (c *ControllerAction) DoAction(client stream.IStreamClient, message stream.Message)
Stream
type ControllerCommon ¶
type ControllerCommon struct {
// contains filtered or unexported fields
}
ControllerCommon ...
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
NewControllerCommon ...
func (*ControllerCommon) Err ¶
func (c *ControllerCommon) Err(client stream.IStreamClient, message stream.Message, err error)
Err ...
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
}
ControllerDashboard ...
func NewControllerDashboard ¶
func NewControllerDashboard(common *ControllerCommon) (dashboard *ControllerDashboard)
NewControllerDashboard ...
func (*ControllerDashboard) Broadcast ¶
func (t *ControllerDashboard) Broadcast(param interface{})
Broadcast ...
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
}
ControllerImage ...
func NewControllerImage ¶
func NewControllerImage(common *ControllerCommon) *ControllerImage
NewControllerImage ...
func (*ControllerImage) GetFilterList ¶
func (c *ControllerImage) GetFilterList(client stream.IStreamClient, message stream.Message)
GetFilterList ...
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)
RemoveImage ...
type ControllerMap ¶
type ControllerMap struct {
*ControllerCommon
// contains filtered or unexported fields
}
ControllerMap ...
func NewControllerMap ¶
func NewControllerMap(common *ControllerCommon) *ControllerMap
NewControllerMap ...
func (*ControllerMap) Broadcast ¶
func (c *ControllerMap) Broadcast(param interface{})
method callable from metric service
type ControllerWorker ¶
type ControllerWorker struct {
*ControllerCommon
}
ControllerWorker ...
func NewControllerWorker ¶
func NewControllerWorker(common *ControllerCommon) *ControllerWorker
NewControllerWorker ...
func (*ControllerWorker) DoWorker ¶
func (c *ControllerWorker) DoWorker(client stream.IStreamClient, message stream.Message)
Stream
type Controllers ¶
type Controllers struct {
Image *ControllerImage
Worker *ControllerWorker
Action *ControllerAction
Dashboard *ControllerDashboard
Map *ControllerMap
}
Controllers ...
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
NewControllers ...
Source Files
¶
Click to show internal directories.
Click to hide internal directories.