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, endpoint *endpoint.Endpoint, ...) *ControllerCommon
  • func (c *ControllerCommon) Err(client stream.IStreamClient, message stream.Message, err error)
• type ControllerDashboard
  • func NewControllerDashboard(common *ControllerCommon) *ControllerDashboard
  • func (c *ControllerDashboard) Broadcast(param interface{})
  • func (c *ControllerDashboard) Start()
  • func (c *ControllerDashboard) Stop()
• type ControllerMap
  • func NewControllerMap(common *ControllerCommon) *ControllerMap
  • func (c *ControllerMap) Broadcast(param interface{})
  • func (c *ControllerMap) Start()
  • func (c *ControllerMap) Stop()
• type Controllers
  • func NewControllers(adaptors *adaptors.Adaptors, scripts *scripts.ScriptService, core *core.Core, ...) *Controllers
  • func (s *Controllers) Start()
  • func (s *Controllers) Stop()
• type Devices
  • 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
• type Workflow
  • func NewWorkflow(metric *metrics.MetricManager) *Workflow
  • func (d *Workflow) Broadcast() (map[string]interface{}, bool)
  • func (d *Workflow) GetWorkflowStatus(client stream.IStreamClient, message stream.Message)

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

func (*ControllerAction) Start

func (c *ControllerAction) Start()

Start ...

func (*ControllerAction) Stop

func (c *ControllerAction) Stop()

Stop ...

type ControllerCommon

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

ControllerCommon ...

func NewControllerCommon

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

NewControllerCommon ...

func (*ControllerCommon) Err

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

Err ...

type ControllerDashboard

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

ControllerDashboard ...

func NewControllerDashboard

func NewControllerDashboard(common *ControllerCommon) *ControllerDashboard

NewControllerDashboard ...

func (*ControllerDashboard) Broadcast

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

Broadcast ...

func (*ControllerDashboard) Start

func (c *ControllerDashboard) Start()

Start ...

func (*ControllerDashboard) Stop

func (c *ControllerDashboard) Stop()

Stop ...

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

func (*ControllerMap) Start

func (c *ControllerMap) Start()

Start ...

func (*ControllerMap) Stop

func (c *ControllerMap) Stop()

Stop ...

type Controllers

type Controllers struct {
	Map       *ControllerMap
	Action    *ControllerAction
	Dashboard *ControllerDashboard
}

Controllers ...

func NewControllers

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

NewControllers ...

func (*Controllers) Start

func (s *Controllers) Start()

Start ...

func (*Controllers) Stop

func (s *Controllers) Stop()

Stop ...

type Devices

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

Devices ...

func NewDevices

func NewDevices(metric *metrics.MetricManager) *Devices

NewDevices ...

func (*Devices) Broadcast

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

Broadcast ...

func (*Devices) GetDevicesStates

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

only on request: 'map.get.devices'

type MapElement

type MapElement struct {
	Id          int64       `json:"id"`
	StatusId    int64       `json:"status_id"`
	Options     interface{} `json:"options"`
	ElementName string      `json:"element_name"`
}

MapElement ...

type Workflow

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

Workflow ...

func NewWorkflow

func NewWorkflow(metric *metrics.MetricManager) *Workflow

NewWorkflow ...

func (*Workflow) Broadcast

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

Broadcast ...

func (*Workflow) GetWorkflowStatus

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

only on request: 'workflow.get.status'