stats

Jan 3, 2024

Changes in this version

+ const DBReadTime

+ const DBWriteTime

+ const NumAdapterRpcErrors

+ const NumCoreRpcErrors

+ const NumDiscoveriesReceived

+ const NumErrorsWritingToBus

+ const NumOnusActivated

+ const OmciCCTxRetries

+ const OmciCCTxTimeouts

+ const OnuDiscToActivateTime

+ const OnuDiscToFlowsPushedTime

+ const OnuDiscoveryProcTime

+ var StatsServer = PromStatsServer

+ type CollectorName string

+ const OltAdapter

+ const OnuAdapter

+ const VCore

+ func (s CollectorName) String() string

+ type DeviceCounter string

+ func (s DeviceCounter) String() string

+ type DeviceDuration string

+ func (s DeviceDuration) String() string

+ type NonDeviceCounter string

+ func (s NonDeviceCounter) String() string

+ type NonDeviceDuration string

+ func (s NonDeviceDuration) String() string

+ type NullStatsServer struct

+ func (n *NullStatsServer) Add(counter NonDeviceCounter, val float64)

+ func (n *NullStatsServer) AddForDevice(devId, sn string, counter DeviceCounter, val float64)

+ func (n *NullStatsServer) CollectDuration(dName NonDeviceDuration, startTime time.Time)

+ func (n *NullStatsServer) CollectDurationForDevice(devID, sn string, dName NonDeviceDuration, startTime time.Time)

+ func (n *NullStatsServer) Count(counter NonDeviceCounter)

+ func (n *NullStatsServer) CountForDevice(devId, sn string, counterName DeviceCounter)

+ func (n *NullStatsServer) Start(ctx context.Context, p int, name CollectorName)

+ type PromStatsServer struct

+ func (ps *PromStatsServer) Add(counter NonDeviceCounter, val float64)

+ func (ps *PromStatsServer) AddForDevice(devId, sn string, counter DeviceCounter, val float64)

+ func (ps *PromStatsServer) CollectDuration(dName NonDeviceDuration, startTime time.Time)

+ func (ps *PromStatsServer) CollectDurationForDevice(devID, sn string, dName DeviceDuration, startTime time.Time)

+ func (ps *PromStatsServer) Count(counter NonDeviceCounter)

+ func (ps *PromStatsServer) CountForDevice(devId, sn string, counterName DeviceCounter)

+ func (ps *PromStatsServer) Start(ctx context.Context, p int, name CollectorName)

+ type StatsManager interface

+ Add func(counter NonDeviceCounter, val float64)

+ AddForDevice func(devId, sn string, counter DeviceCounter, val float64)

+ CollectDuration func(dName NonDeviceDuration, startTime time.Time)

+ CollectDurationForDevice func(devID, sn string, dName NonDeviceDuration, startTime time.Time)

+ Count func(counter NonDeviceCounter)

+ CountForDevice func(devId, sn string, counterName DeviceCounter)

+ Start func(ctx context.Context, p int, name CollectorName)