dashboard_models

Documentation

Index

• type AppMemory
  • func NewAppMemory(metric *metrics.MetricManager) (memory *AppMemory)
  • func (g *AppMemory) Broadcast() (map[string]interface{}, bool)
• type Cpu
  • func NewCpu(metric *metrics.MetricManager) (node *Cpu)
  • func (g *Cpu) Broadcast() (map[string]interface{}, bool)
• type Devices
  • func NewDevices(metric *metrics.MetricManager) *Devices
  • func (d *Devices) Broadcast() (map[string]interface{}, bool)
• type Disk
  • func NewDisk(metric *metrics.MetricManager) (memory *Disk)
  • func (g *Disk) Broadcast() (map[string]interface{}, bool)
• type Flow
  • func NewFlow(metric *metrics.MetricManager) (node *Flow)
  • func (g *Flow) Broadcast() (map[string]interface{}, bool)
• type Gate
  • func NewGate(metric *metrics.MetricManager) (node *Gate)
  • func (g *Gate) Broadcast() (map[string]interface{}, bool)
  • func (t *Gate) Status(client stream.IStreamClient, message stream.Message)
• type History
  • func NewHistory(metric *metrics.MetricManager) (memory *History)
  • func (g *History) Broadcast() (map[string]interface{}, bool)
• type Memory
  • func NewMemory(metric *metrics.MetricManager) (memory *Memory)
  • func (g *Memory) Broadcast() (map[string]interface{}, bool)
• type Mqtt
  • func NewMqtt(metric *metrics.MetricManager) (memory *Mqtt)
  • func (g *Mqtt) Broadcast() (map[string]interface{}, bool)
• type Nodes
  • func NewNode(metric *metrics.MetricManager) (node *Nodes)
  • func (n *Nodes) Broadcast() (map[string]interface{}, bool)
  • func (n *Nodes) NodesStatus(client stream.IStreamClient, message stream.Message)
• type Uptime
  • func NewUptime(metric *metrics.MetricManager) (memory *Uptime)
  • func (g *Uptime) Broadcast() (map[string]interface{}, bool)
• type Workflow
  • func NewWorkflow(metric *metrics.MetricManager) *Workflow
  • func (w *Workflow) Broadcast() (map[string]interface{}, bool)
• type Zigbee2Mqtt
  • func NewZigbee2Mqtt(metric *metrics.MetricManager) (memory *Zigbee2Mqtt)
  • func (g *Zigbee2Mqtt) Broadcast() (map[string]interface{}, bool)

Types

type AppMemory

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

AppMemory ...

func NewAppMemory

func NewAppMemory(metric *metrics.MetricManager) (memory *AppMemory)

NewAppMemory ...

func (*AppMemory) Broadcast

func (g *AppMemory) Broadcast() (map[string]interface{}, bool)

Broadcast ...

type Cpu

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

Cpu ...

func NewCpu

func NewCpu(metric *metrics.MetricManager) (node *Cpu)

NewCpu ...

func (*Cpu) Broadcast

func (g *Cpu) Broadcast() (map[string]interface{}, bool)

Broadcast ...

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() (map[string]interface{}, bool)

Broadcast ...

type Disk

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

Disk ...

func NewDisk

func NewDisk(metric *metrics.MetricManager) (memory *Disk)

NewDisk ...

func (*Disk) Broadcast

func (g *Disk) Broadcast() (map[string]interface{}, bool)

Broadcast ...

type Flow

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

Flow ...

func NewFlow

func NewFlow(metric *metrics.MetricManager) (node *Flow)

NewFlow ...

func (*Flow) Broadcast

func (g *Flow) Broadcast() (map[string]interface{}, bool)

Broadcast ...

type Gate

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

Gate ...

func NewGate

func NewGate(metric *metrics.MetricManager) (node *Gate)

NewGate ...

func (*Gate) Broadcast

func (g *Gate) Broadcast() (map[string]interface{}, bool)

Broadcast ...

func (*Gate) Status

func (t *Gate) Status(client stream.IStreamClient, message stream.Message)

only on request: 'dashboard.get.gate.status'

type History

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

History ...

func NewHistory

func NewHistory(metric *metrics.MetricManager) (memory *History)

NewHistory ...

func (*History) Broadcast

func (g *History) Broadcast() (map[string]interface{}, bool)

Broadcast ...

type Memory

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

Memory ...

func NewMemory

func NewMemory(metric *metrics.MetricManager) (memory *Memory)

NewMemory ...

func (*Memory) Broadcast

func (g *Memory) Broadcast() (map[string]interface{}, bool)

Broadcast ...

type Mqtt

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

Mqtt ...

func NewMqtt

func NewMqtt(metric *metrics.MetricManager) (memory *Mqtt)

NewMqtt ...

func (*Mqtt) Broadcast

func (g *Mqtt) Broadcast() (map[string]interface{}, bool)

Broadcast ...

type Nodes

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

Nodes ...

func NewNode

func NewNode(metric *metrics.MetricManager) (node *Nodes)

NewNode ...

func (*Nodes) Broadcast

func (n *Nodes) Broadcast() (map[string]interface{}, bool)

Broadcast ...

func (*Nodes) NodesStatus

func (n *Nodes) NodesStatus(client stream.IStreamClient, message stream.Message)

only on request: 'dashboard.get.nodes.status'

type Uptime

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

Uptime ...

func NewUptime

func NewUptime(metric *metrics.MetricManager) (memory *Uptime)

NewUptime ...

func (*Uptime) Broadcast

func (g *Uptime) Broadcast() (map[string]interface{}, bool)

Broadcast ...

type Workflow

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

Workflow ...

func NewWorkflow

func NewWorkflow(metric *metrics.MetricManager) *Workflow

NewWorkflow ...

func (*Workflow) Broadcast

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

status all workflows

type Zigbee2Mqtt

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

Zigbee2Mqtt ...

func NewZigbee2Mqtt

func NewZigbee2Mqtt(metric *metrics.MetricManager) (memory *Zigbee2Mqtt)

NewZigbee2Mqtt ...

func (*Zigbee2Mqtt) Broadcast

func (g *Zigbee2Mqtt) Broadcast() (map[string]interface{}, bool)

Broadcast ...