timingwheel

Documentation

Index

• type TimingWheel
  • func NewTimingWheel(interval time.Duration, buckets int) *TimingWheel
  • func (w *TimingWheel) After(timeout time.Duration) <-chan struct{}
  • func (w *TimingWheel) Stop()

Types

type TimingWheel

type TimingWheel struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewTimingWheel

func NewTimingWheel(interval time.Duration, buckets int) *TimingWheel

func (*TimingWheel) After

func (w *TimingWheel) After(timeout time.Duration) <-chan struct{}

func (*TimingWheel) Stop

func (w *TimingWheel) Stop()