Versions in this module Expand all Collapse all v1 v1.8.4 Feb 22, 2022 v1.8.3 Feb 22, 2022 Changes in this version + func EstimateETA(startTime time.Time, progress, end uint64) time.Duration + 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, op message.Op, 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 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 *mockable.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()
Go to main page