rate

Documentation

Index

• type RandTimer
  • func (t *RandTimer) Channel() <-chan time.Time
  • func (t *RandTimer) Reset()
  • func (t *RandTimer) Stop() bool
  • func (t *RandTimer) Wait()
• type SpeedLimiter
  • func NewRandSpeedLimiter(minInterval, maxInterval time.Duration) SpeedLimiter
  • func NewSpeedLimiter(interval time.Duration) SpeedLimiter
• type Ticker
  • func (t *Ticker) Channel() <-chan time.Time
  • func (t *Ticker) Reset()
  • func (t *Ticker) Stop() bool
  • func (t *Ticker) Wait()

Types

type RandTimer

type RandTimer struct {
	*time.Timer
	// contains filtered or unexported fields
}

func (*RandTimer) Channel

func (t *RandTimer) Channel() <-chan time.Time

func (*RandTimer) Reset

func (t *RandTimer) Reset()

func (*RandTimer) Stop

func (t *RandTimer) Stop() bool

func (*RandTimer) Wait

func (t *RandTimer) Wait()

type SpeedLimiter

type SpeedLimiter interface {
	Reset()
	Stop() bool

	Wait()

	Channel() <-chan time.Time
}

func NewRandSpeedLimiter

func NewRandSpeedLimiter(minInterval, maxInterval time.Duration) SpeedLimiter

minInterval:最小等待时间 maxInterval：最大等待时间 maxInterval-minInterval: 等待范围

func NewSpeedLimiter

func NewSpeedLimiter(interval time.Duration) SpeedLimiter

type Ticker

type Ticker time.Ticker

func (*Ticker) Channel

func (t *Ticker) Channel() <-chan time.Time

func (*Ticker) Reset

func (t *Ticker) Reset()

func (*Ticker) Stop

func (t *Ticker) Stop() bool

func (*Ticker) Wait

func (t *Ticker) Wait()