package contention

import "github.com/etcd-io/etcd/pkg/contention"

Package contention provides facilities for detecting system contention.

Index ¶

• type TimeoutDetector
• func NewTimeoutDetector(maxDuration time.Duration) *TimeoutDetector
• func (td *TimeoutDetector) Observe(which uint64) (bool, time.Duration)
• func (td *TimeoutDetector) Reset()

Package Files ¶

contention.go doc.go

type TimeoutDetector ¶ Uses

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

TimeoutDetector detects routine starvations by observing the actual time duration to finish an action or between two events that should happen in a fixed interval. If the observed duration is longer than the expectation, the detector will report the result.

func NewTimeoutDetector ¶ Uses

func NewTimeoutDetector(maxDuration time.Duration) *TimeoutDetector

NewTimeoutDetector creates the TimeoutDetector.

func (*TimeoutDetector) Observe ¶ Uses

func (td *TimeoutDetector) Observe(which uint64) (bool, time.Duration)

Observe observes an event for given id. It returns false and exceeded duration if the interval is longer than the expectation.

func (*TimeoutDetector) Reset ¶ Uses

func (td *TimeoutDetector) Reset()

Reset resets the NewTimeoutDetector.