Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, endpoint *endpoint.Endpoint, scripts *scripts.ScriptService, core *core.Core, gate *gate_client.GateClient, metric *metrics.MetricManager) *ControllerCommon
func (*ControllerCommon) Err ¶
func (c *ControllerCommon) Err(client stream.IStreamClient, message stream.Message, err error)
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 Controllers ¶
type Controllers struct {
Map *ControllerMap
Action *ControllerAction
}
func NewControllers ¶
func NewControllers(adaptors *adaptors.Adaptors, scripts *scripts.ScriptService, core *core.Core, endpoint *endpoint.Endpoint, gate *gate_client.GateClient, metrics *metrics2.MetricManager) *Controllers
func (*Controllers) Start ¶
func (s *Controllers) Start()
func (*Controllers) Stop ¶
func (s *Controllers) Stop()
type Devices ¶
type Devices struct {
// contains filtered or unexported fields
}
func NewDevices ¶
func NewDevices(metric *metrics.MetricManager) *Devices
func (*Devices) Broadcast ¶
func (d *Devices) Broadcast(cursor metrics.MapElementCursor) (map[string]interface{}, bool)
func (*Devices) GetDevicesStates ¶
func (d *Devices) GetDevicesStates(client stream.IStreamClient, message stream.Message)
only on request: 'map.get.devices'
type MapElement ¶
Source Files
Click to show internal directories.
Click to hide internal directories.