Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FlowsStatus ¶
func FlowsStatus(client stream.IStreamClient, message stream.Message)
Types ¶
type AppMemory ¶ added in v0.0.25
type Cpu ¶
type Devices ¶
type Devices struct {
Total int64 `json:"total"`
Status map[int64]*m.DashboardDeviceStatus `json:"status"`
// contains filtered or unexported fields
}
func (*Devices) BroadcastOne ¶
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) GatesStatus ¶
func (g *Gate) GatesStatus(client stream.IStreamClient, message stream.Message)
only on request: 'dashboard.get.gate.status'
type Memory ¶
type Nodes ¶
type Nodes struct {
sync.Mutex
Total int64 `json:"total"`
Status map[int64]string `json:"status"`
// contains filtered or unexported fields
}
func (*Nodes) NodesStatus ¶
func (n *Nodes) NodesStatus(client stream.IStreamClient, message stream.Message)
only on request: 'dashboard.get.nodes.status'
type Processors ¶
type Workflow ¶ added in v0.0.25
type Workflow struct {
Total int `json:"total"`
Status map[int64]m.DashboardWorkflowStatus `json:"status"`
// contains filtered or unexported fields
}
func NewWorkflow ¶ added in v0.0.25
func (*Workflow) BroadcastOne ¶ added in v0.0.25
func (w *Workflow) BroadcastOne(params telemetry.WorkflowScenario) (map[string]interface{}, bool)
Click to show internal directories.
Click to hide internal directories.