stabilization

Jul 16, 2025

Changes in this version

+ type Clock interface

+ Now func() time.Time

+ var SystemClock Clock = &systemClock{}

+ type Config struct

+ Clock Clock

+ MinimumPeriods int

+ NumPeriodsForStabilization int

+ PeriodDuration time.Duration

+ StabilizationFactor float64

+ WarmupTime time.Duration

+ type Detector struct

+ OnMonitoringStart func(t time.Time)

+ OnPeriodComplete func(t time.Time, countInPeriod int, stDev float64)

+ OnStabilized func(t time.Time, totalCount int)

+ func NewDetector(cfg Config) (*Detector, error)

+ func (d *Detector) Close()

+ func (d *Detector) IsStabilized() bool

+ func (d *Detector) Record() time.Time

+ func (d *Detector) State() RateState

+ func (d *Detector) Subscribe() (c <-chan struct{}, cancel func())

+ type RateState int

+ const StateIdle

+ const StateMonitoring

+ const StateStabilized

+ func (rs RateState) String() string

+ type Subscriber interface

+ IsStabilized func() bool

+ Subscribe func() (c <-chan struct{}, cancel func())