dashboard_models

Documentation

Index

• func FlowsStatus(client *stream.Client, message stream.Message)
• type AppMemory
  • func (m *AppMemory) String() string
  • func (m *AppMemory) Update()
• 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()
• type Workflow
  • func NewWorkflow(adaptors *adaptors.Adaptors, core *core.Core) *Workflow
  • func (w *Workflow) Broadcast() (map[string]interface{}, bool)
  • func (w *Workflow) BroadcastOne(params telemetry.WorkflowScenario) (map[string]interface{}, bool)
  • func (w *Workflow) Update()

Functions

func FlowsStatus

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

Types

type AppMemory

type AppMemory struct {
	sync.Mutex
	Alloc      uint64    `json:"alloc"`
	HeapAlloc  uint64    `json:"heap_alloc"`
	TotalAlloc uint64    `json:"total_alloc"`
	Sys        uint64    `json:"sys"`
	NumGC      uint64    `json:"num_gc"`
	LastGC     time.Time `json:"last_gc"`
}

func (*AppMemory) String

func (m *AppMemory) String() string

func (*AppMemory) Update

func (m *AppMemory) Update()

type Cpu

type Cpu struct {
	sync.Mutex
	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.DashboardDeviceStatus `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 {
	sync.Mutex
	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 {
	sync.Mutex
	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 {
	sync.Mutex
	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 {
	sync.Mutex
	Total uint64 `json:"total"`
	Idle  uint64 `json:"idle"`
}

func (*Uptime) Update

func (u *Uptime) Update()

type Workflow

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

func NewWorkflow

func NewWorkflow(adaptors *adaptors.Adaptors,
	core *core.Core) *Workflow

func (*Workflow) Broadcast

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

status all workflows

func (*Workflow) BroadcastOne

func (w *Workflow) BroadcastOne(params telemetry.WorkflowScenario) (map[string]interface{}, bool)

func (*Workflow) Update

func (w *Workflow) Update()