controllers

Documentation

Index

• type ControllerAction
  • func NewControllerAction(common *ControllerCommon) *ControllerAction
  • func (c *ControllerAction) DoAction(client *stream.Client, 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.Client, message stream.Message, err error)
• type ControllerDashboard
  • func NewControllerDashboard(common *ControllerCommon) *ControllerDashboard
  • func (t *ControllerDashboard) Broadcast(pack string)
  • func (t *ControllerDashboard) BroadcastOne(pack string, deviceId int64, elementName string)
  • func (t *ControllerDashboard) GetStates() *ControllerDashboard
  • func (c *ControllerDashboard) Start()
  • func (c *ControllerDashboard) Stop()
  • func (t *ControllerDashboard) Telemetry(client *stream.Client, message stream.Message)
• type ControllerImage
  • func NewControllerImage(common *ControllerCommon) *ControllerImage
  • func (c *ControllerImage) GetFilterList(client *stream.Client, message stream.Message)
  • func (c *ControllerImage) GetImageList(client *stream.Client, message stream.Message)
  • func (c *ControllerImage) RemoveImage(client *stream.Client, message stream.Message)
  • func (c *ControllerImage) Start()
  • func (c *ControllerImage) Stop()
• type ControllerMap
  • func NewControllerMap(common *ControllerCommon) *ControllerMap
  • func (c *ControllerMap) Broadcast(pack string)
  • func (c *ControllerMap) BroadcastOne(pack string, deviceId int64, elementName string)
  • func (c *ControllerMap) Start()
  • func (c *ControllerMap) Stop()
• type ControllerWorker
  • func NewControllerWorker(common *ControllerCommon) *ControllerWorker
  • func (c *ControllerWorker) DoWorker(client *stream.Client, 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.Client, 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,
	telemetry *telemetry.Telemetry,
	gate *gate_client.GateClient) *ControllerCommon

func (*ControllerCommon) Err

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

type ControllerDashboard

type ControllerDashboard struct {
	*ControllerCommon

	Nodes *dashboardModel.Nodes
	Gate  *dashboardModel.Gate

	Memory *dashboardModel.Memory
	Cpu    *dashboardModel.Cpu
	Uptime *dashboardModel.Uptime
	Disk   *dashboardModel.Disk
	// contains filtered or unexported fields
}

func NewControllerDashboard

func NewControllerDashboard(common *ControllerCommon) *ControllerDashboard

func (*ControllerDashboard) Broadcast

func (t *ControllerDashboard) Broadcast(pack string)

func (*ControllerDashboard) BroadcastOne

func (t *ControllerDashboard) BroadcastOne(pack string, deviceId int64, elementName string)

func (*ControllerDashboard) GetStates

func (t *ControllerDashboard) GetStates() *ControllerDashboard

func (*ControllerDashboard) Start

func (c *ControllerDashboard) Start()

func (*ControllerDashboard) Stop

func (c *ControllerDashboard) Stop()

func (*ControllerDashboard) Telemetry

func (t *ControllerDashboard) Telemetry(client *stream.Client, 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.Client, message stream.Message)

func (*ControllerImage) GetImageList

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

Stream

func (*ControllerImage) RemoveImage

func (c *ControllerImage) RemoveImage(client *stream.Client, 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(pack string)

func (*ControllerMap) BroadcastOne

func (c *ControllerMap) BroadcastOne(pack string, deviceId int64, elementName string)

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.Client, 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,
	telemetry *telemetry.Telemetry,
	gate *gate_client.GateClient) *Controllers

func (*Controllers) Start

func (s *Controllers) Start()

func (*Controllers) Stop

func (s *Controllers) Stop()