dashboard_models

Documentation

Index

• func FlowsStatus(client *stream.Client, message stream.Message)
• type Cpu
  • func NewCpu() (_cpu *Cpu)
  • func (m *Cpu) Update()
• type Devices
  • func NewDevices(adaptors *adaptors.Adaptors, core *core.Core) *Devices
  • func (d *Devices) Broadcast() (map[string]interface{}, bool)
  • func (d *Devices) BroadcastOne(deviceId int64, elementName string) (map[string]interface{}, bool)
  • func (d *Devices) Update()
• type Disk
  • func NewDisk() (_disk *Disk)
  • func (d *Disk) Update()
• type Flow
  • func (f *Flow) Update()
• type Gate
  • func NewGate(gate *gate_client.GateClient) *Gate
  • func (g *Gate) Broadcast() (map[string]interface{}, bool)
  • func (g *Gate) GatesStatus(client *stream.Client, message stream.Message)
  • func (g *Gate) Update()
• type Memory
  • func (m *Memory) Update()
• type Nodes
  • func NewNode(adaptors *adaptors.Adaptors, core *core.Core) (node *Nodes)
  • func (n *Nodes) Broadcast() (map[string]interface{}, bool)
  • func (n *Nodes) NodesStatus(client *stream.Client, message stream.Message)
  • func (n *Nodes) Update()
• type Processors
• type Uptime
  • func (u *Uptime) Update()

Functions

func FlowsStatus

func FlowsStatus(client *stream.Client, message stream.Message)

Types

type Cpu

type Cpu struct {
	Cpuinfo *Processors     `json:"processors"`
	All     float64         `json:"all"`
	Usage   map[int]float64 `json:"usage"`
	// contains filtered or unexported fields
}

func NewCpu

func NewCpu() (_cpu *Cpu)

func (*Cpu) Update

func (m *Cpu) Update()

type Devices

type Devices struct {
	Total  int64                             `json:"total"`
	Status map[int64]*m.DashboardDeviceState `json:"status"`
	// contains filtered or unexported fields
}

func NewDevices

func NewDevices(adaptors *adaptors.Adaptors,
	core *core.Core) *Devices

func (*Devices) Broadcast

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

func (*Devices) BroadcastOne

func (d *Devices) BroadcastOne(deviceId int64, elementName string) (map[string]interface{}, bool)

func (*Devices) Update

func (d *Devices) Update()

type Disk

type Disk struct {
	Root *disk.UsageStat `json:"root"`
}

func NewDisk

func NewDisk() (_disk *Disk)

func (*Disk) Update

func (d *Disk) Update()

type Flow

type Flow struct {
}

func (*Flow) Update

func (f *Flow) Update()

type Gate

type Gate struct {
	Status      string `json:"status"`
	AccessToken string `json:"-"`
	// contains filtered or unexported fields
}

func NewGate

func NewGate(gate *gate_client.GateClient) *Gate

func (*Gate) Broadcast

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

func (*Gate) GatesStatus

func (g *Gate) GatesStatus(client *stream.Client, message stream.Message)

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

func (*Gate) Update

func (g *Gate) Update()

type Memory

type Memory struct {
	SwapTotal uint64 `json:"swap_total"`
	SwapFree  uint64 `json:"swap_free"`
	MemTotal  uint64 `json:"mem_total"`
	MemFree   uint64 `json:"mem_free"`
}

func (*Memory) Update

func (m *Memory) Update()

type Nodes

type Nodes struct {
	sync.Mutex
	Total  int64            `json:"total"`
	Status map[int64]string `json:"status"`
	// contains filtered or unexported fields
}

func NewNode

func NewNode(adaptors *adaptors.Adaptors,
	core *core.Core) (node *Nodes)

func (*Nodes) Broadcast

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

func (*Nodes) NodesStatus

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

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

func (*Nodes) Update

func (n *Nodes) Update()

type Processors

type Processors struct {
	Processors []cpu.InfoStat `json:"processors"`
}

type Uptime

type Uptime struct {
	Total uint64 `json:"total"`
	Idle  uint64 `json:"idle"`
}

func (*Uptime) Update

func (u *Uptime) Update()