Versions in this module Expand all Collapse all v0 v0.1.3 Jun 25, 2022 v0.1.0 Jun 25, 2022 Changes in this version + var MaxTime = time.Unix(1<<63 - 62135596801, 0) + type AdaptiveTimeoutConfig struct + InitialTimeout time.Duration + MaximumTimeout time.Duration + MinimumTimeout time.Duration + TimeoutCoefficient float64 + TimeoutHalflife time.Duration + type AdaptiveTimeoutManager struct + func (tm *AdaptiveTimeoutManager) Dispatch() + func (tm *AdaptiveTimeoutManager) Initialize(config *AdaptiveTimeoutConfig, metricsNamespace string, ...) error + func (tm *AdaptiveTimeoutManager) ObserveLatency(latency time.Duration) + func (tm *AdaptiveTimeoutManager) Put(id ids.ID, msgType constants.MsgType, timeoutHandler func()) time.Time + func (tm *AdaptiveTimeoutManager) Remove(id ids.ID) + func (tm *AdaptiveTimeoutManager) Stop() + func (tm *AdaptiveTimeoutManager) Timeout() + func (tm *AdaptiveTimeoutManager) TimeoutDuration() time.Duration + type Clock struct + func (c *Clock) Set(time time.Time) + func (c *Clock) Sync() + func (c *Clock) Time() time.Time + func (c *Clock) Unix() uint64 + type Meter interface + Tick func() + Ticks func() int + type Repeater struct + func NewRepeater(handler func(), frequency time.Duration) *Repeater + func (r *Repeater) Dispatch() + func (r *Repeater) Stop() + type TimedMeter struct + Clock *Clock + Duration time.Duration + func (tm *TimedMeter) Tick() + func (tm *TimedMeter) Ticks() int + type TimeoutManager struct + func (tm *TimeoutManager) Dispatch() + func (tm *TimeoutManager) Initialize(duration time.Duration) + func (tm *TimeoutManager) Put(id ids.ID, handler func()) + func (tm *TimeoutManager) Remove(id ids.ID) + func (tm *TimeoutManager) Stop() + func (tm *TimeoutManager) Timeout() + type Timer struct + func NewStagedTimer(f func() (time.Duration, bool)) *Timer + func NewTimer(handler func()) *Timer + func (t *Timer) Cancel() + func (t *Timer) Dispatch() + func (t *Timer) SetTimeoutIn(duration time.Duration) + func (t *Timer) Stop()