metrics

package

Go to main page

Versions in this module

v0

v0.5.5

Feb 7, 2022

v0.5.4

Feb 6, 2022

v0.5.3

Feb 5, 2022

v0.5.2

Jan 27, 2022

v0.5.1

Dec 8, 2021

v0.5.0

Nov 28, 2021

Changes in this version

+ type Entity struct

+ Entities map[string]EntityState

+ Total int64

+ type EntityAdd struct

+ Num int64

+ type EntityCursor struct

+ DeviceId int64

+ ElementName string

+ type EntityDelete struct

+ Num int64

+ type EntityManager struct

+ func NewEntityManager(publisher IPublisher) *EntityManager

+ func (d *EntityManager) Snapshot() Entity

+ type EntitySetOption struct

+ DeviceId int64

+ ElementName string

+ StateId int64

+ StateOptions interface{}

+ type EntitySetState struct

+ DeviceId int64

+ ElementName string

+ StateId int64

+ type EntityState struct

+ DeviceId int64

+ ElementName string

+ StateId int64

+ StateOptions interface{}

type MetricConfig

+ Enabled bool

v0.4.0

Apr 11, 2020

v0.3.0

Apr 8, 2020

v0.2.0

Mar 31, 2020

Changes in this version

+ type History struct

+ Items []HistoryItem

+ type HistoryItem struct

+ CreatedAt time.Time

+ Description string

+ DeviceDescription string

+ DeviceName string

+ LogLevel string

+ Type string

+ type HistoryManager struct

+ func NewHistoryManager(publisher IPublisher, adaptors *adaptors.Adaptors) *HistoryManager

+ func (d HistoryManager) Snapshot() History

type MetricManager

+ History *HistoryManager

+ type Zigbee2MqttUpdate struct

v0.1.26

Feb 29, 2020

v0.1.3

Mar 12, 2020

v0.1.2

Mar 10, 2020

Changes in this version

+ var ErrRecordNotFound = errors.New("record not found")

+ type AppMemory struct

+ Alloc uint64

+ HeapAlloc uint64

+ LastGC time.Time

+ NumGC uint64

+ Sys uint64

+ TotalAlloc uint64

+ type AppMemoryManager struct

+ func NewAppMemoryManager(publisher IPublisher) *AppMemoryManager

+ func (d AppMemoryManager) Snapshot() AppMemory

+ type Cpu struct

+ All float64

+ Cores int64

+ Mhz float64

+ type CpuManager struct

+ func NewCpuManager(publisher IPublisher) (c *CpuManager)

+ func (c *CpuManager) All() float64

+ func (c *CpuManager) Snapshot() Cpu

+ type Device struct

+ Disabled int64

+ Total int64

+ type DeviceAdd struct

+ DisabledNum int64

+ TotalNum int64

+ type DeviceDelete struct

+ DisabledNum int64

+ TotalNum int64

+ type DeviceManager struct

+ func NewDeviceManager(publisher IPublisher) *DeviceManager

+ func (d *DeviceManager) Snapshot() Device

+ type Disk struct

+ Root UsageStat

+ type DiskManager struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewDiskManager(publisher IPublisher) (manager *DiskManager)

+ func (d *DiskManager) Snapshot() Disk

+ type Flow struct

+ Disabled int64

+ Total int64

+ type FlowAdd struct

+ EnabledNum int64

+ TotalNum int64

+ type FlowDelete struct

+ EnabledNum int64

+ TotalNum int64

+ type FlowManager struct

+ func NewFlowManager(publisher IPublisher, adaptors *adaptors.Adaptors) (flow *FlowManager)

+ func (d *FlowManager) Snapshot() Flow

+ type Gate struct

+ AccessToken string

+ Status string

+ type GateManager struct

+ func NewGateManager(publisher IPublisher) *GateManager

+ func (d *GateManager) Snapshot() Gate

+ type GateUpdate struct

+ AccessToken string

+ Status string

+ type IPublisher interface

+ Broadcast func(interface{})

+ type ISubscriber interface

+ Broadcast func(interface{})

+ type MapElement struct

+ Elements map[string]MapElementState

+ Total int64

+ type MapElementAdd struct

+ Num int64

+ type MapElementCursor struct

+ DeviceId int64

+ ElementName string

+ type MapElementDelete struct

+ Num int64

+ type MapElementManager struct

+ func NewMapElementManager(publisher IPublisher) *MapElementManager

+ func (d *MapElementManager) Snapshot() MapElement

+ type MapElementSetOption struct

+ DeviceId int64

+ ElementName string

+ StateId int64

+ StateOptions interface{}

+ type MapElementSetState struct

+ DeviceId int64

+ ElementName string

+ StateId int64

+ type MapElementState struct

+ DeviceId int64

+ ElementName string

+ StateId int64

+ StateOptions interface{}

+ type Memory struct

+ MemFree uint64

+ MemTotal uint64

+ SwapFree uint64

+ SwapTotal uint64

+ type MemoryManager struct

+ func NewMemoryManager(publisher IPublisher) *MemoryManager

+ func (d *MemoryManager) Snapshot() Memory

+ type MetricManager struct

+ AppMemory *AppMemoryManager

+ Cpu *CpuManager

+ Device *DeviceManager

+ Disk *DiskManager

+ Flow *FlowManager

+ Gate *GateManager

+ MapElement *MapElementManager

+ Memory *MemoryManager

+ Mqtt *MqttManager

+ Node *NodeManager

+ Uptime *UptimeManager

+ Workflow *WorkflowManager

+ Zigbee2Mqtt *Zigbee2MqttManager

+ func NewMetricManager(cfg *MetricConfig, graceful *graceful_service.GracefulService, ...) *MetricManager

+ func (m *MetricManager) Start()

+ func (m *MetricManager) Update(t interface{})

+ func (m MetricManager) Shutdown()

+ type Mqtt struct

+ ClientState MqttClientStats

+ type MqttClientStats struct

+ ActiveCurrent uint64

+ ConnectedTotal uint64

+ DisconnectedTotal uint64

+ ExpiredTotal uint64

+ InactiveCurrent uint64

+ type MqttManager struct

+ func NewMqttManager(publisher IPublisher) *MqttManager

+ func (d *MqttManager) Snapshot() Mqtt

+ type Node struct

+ Status map[int64]string

+ Total int64

+ type NodeAdd struct

+ Num int64

+ type NodeDelete struct

+ Num int64

+ type NodeManager struct

+ func NewNodeManager(publisher IPublisher) *NodeManager

+ func (d *NodeManager) GetStatus(nodeId int64) (status string, err error)

+ func (d *NodeManager) Snapshot() Node

+ type NodeUpdateStatus struct

+ Id int64

+ Status string

+ type Publisher struct

+ func NewPublisher() (t *Publisher)

+ func (p *Publisher) Broadcast(param interface{})

+ func (p *Publisher) Subscribe(command string, f ISubscriber)

+ func (p *Publisher) UnSubscribe(command string)

+ type Uptime struct

+ AppStarted time.Time

+ Total uint64

+ type UptimeManager struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewUptimeManager(publisher IPublisher) (uptime *UptimeManager)

+ func NewUptimeManager(publisher IPublisher) *UptimeManager

+ func (d *UptimeManager) Snapshot() Uptime

+ func (d UptimeManager) Snapshot() Uptime

+ type UsageStat struct

+ Free uint64

+ Fstype string

+ InodesFree uint64

+ InodesTotal uint64

+ InodesUsed uint64

+ InodesUsedPercent float64

+ Path string

+ Total uint64

+ Used uint64

+ UsedPercent float64

+ type Workflow struct

+ Disabled int64

+ Status map[int64]WorkflowStatus

+ Total int64

+ type WorkflowAdd struct

+ EnabledNum int64

+ TotalNum int64

+ type WorkflowDelete struct

+ EnabledNum int64

+ TotalNum int64

+ type WorkflowManager struct

+ func NewWorkflowManager(publisher IPublisher, adaptors *adaptors.Adaptors) (wf *WorkflowManager)

+ func (d *WorkflowManager) GetStatus(workflowId int64) (status WorkflowStatus, err error)

+ func (d *WorkflowManager) Snapshot() Workflow

+ type WorkflowStatus struct

+ Id int64

+ ScenarioId int64

+ type WorkflowUpdateScenario struct

+ Id int64

+ ScenarioId int64

+ type Zigbee2Mqtt struct

+ Disabled int64

+ Total int64

+ type Zigbee2MqttAdd struct

+ DisabledNum int64

+ TotalNum int64

+ type Zigbee2MqttDelete struct

+ DisabledNum int64

+ TotalNum int64

+ type Zigbee2MqttManager struct

+ func NewZigbee2MqttManager(publisher IPublisher) *Zigbee2MqttManager

+ func (d *Zigbee2MqttManager) Snapshot() Zigbee2Mqtt

v0.1.1

Mar 4, 2020

v0.1.0

Mar 2, 2020

v0.0.26

Feb 17, 2020

v0.0.25

Feb 13, 2020

Changes in this version

+ type MetricConfig struct

+ Host string

+ Port int

+ RunMode config.RunMode

+ func NewMetricConfig(cfg *config.AppConfig) *MetricConfig

+ type MetricServer struct

+ func NewMetricServer(cfg *MetricConfig, graceful *graceful_service.GracefulService) *MetricServer

+ func (m MetricServer) Start()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL