status

Documentation

Index

• func Default(deviceNames []string) (OfflineDecision, *Manager)
• func ValidateOfflineDecision(decision OfflineDecision) error
• type ManagedDevice
  • func NewManagedDevice(deviceName string) *ManagedDevice
  • func (md *ManagedDevice) ReportImmediately()
  • func (md *ManagedDevice) ReportPeriodically()
  • func (md *ManagedDevice) Stop()
• type Manager
  • func NewManager(deviceNames []string, decision OfflineDecision) (*Manager, error)
  • func (m *Manager) OnAddDevice(deviceName string)
  • func (m *Manager) OnHandleCommandsFailed(deviceName string, n int64)
  • func (m *Manager) OnHandleCommandsSuccessfully(deviceName string, n int64)
  • func (m *Manager) OnRemoveDevice(deviceName string)
  • func (m *Manager) SetDeviceOffline(deviceName string, reason string)
  • func (m *Manager) SetDeviceOnline(deviceName string)
  • func (m *Manager) UpdateDeviceStatus(deviceName string, status string, reason string)
• type OfflineDecision
  • func NewOfflineDecision(policy Policy, threshold int64) OfflineDecision
• type Policy

Functions

func Default

func Default(deviceNames []string) (OfflineDecision, *Manager)

func ValidateOfflineDecision

func ValidateOfflineDecision(decision OfflineDecision) error

Types

type ManagedDevice

type ManagedDevice struct {
	Status              string
	Reason              string
	UpTime              int64
	DownTime            int64
	LastReportedTime    int64
	Frequency           metrics.GaugeFloat64
	DeltaCollected      metrics.Counter
	DeltaFailures       metrics.Counter
	ConsecutiveErrorNum metrics.Counter
	// contains filtered or unexported fields
}

func NewManagedDevice

func NewManagedDevice(deviceName string) *ManagedDevice

func (*ManagedDevice) ReportImmediately

func (md *ManagedDevice) ReportImmediately()

func (*ManagedDevice) ReportPeriodically

func (md *ManagedDevice) ReportPeriodically()

func (*ManagedDevice) Stop

func (md *ManagedDevice) Stop()

type Manager

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

func NewManager

func NewManager(deviceNames []string, decision OfflineDecision) (*Manager, error)

func (*Manager) OnAddDevice

func (m *Manager) OnAddDevice(deviceName string)

func (*Manager) OnHandleCommandsFailed

func (m *Manager) OnHandleCommandsFailed(deviceName string, n int64)

func (*Manager) OnHandleCommandsSuccessfully

func (m *Manager) OnHandleCommandsSuccessfully(deviceName string, n int64)

func (*Manager) OnRemoveDevice

func (m *Manager) OnRemoveDevice(deviceName string)

func (*Manager) SetDeviceOffline

func (m *Manager) SetDeviceOffline(deviceName string, reason string)

func (*Manager) SetDeviceOnline

func (m *Manager) SetDeviceOnline(deviceName string)

func (*Manager) UpdateDeviceStatus

func (m *Manager) UpdateDeviceStatus(deviceName string, status string, reason string)

type OfflineDecision

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

func NewOfflineDecision

func NewOfflineDecision(policy Policy, threshold int64) OfflineDecision

type Policy

type Policy string

const (
	ExceedConsecutiveErrorNum     Policy = "ExceedConsecutiveErrorNum"
	ExceedContinuousErrorDuration Policy = "ExceedContinuousErrorDuration"
)