speeds

Documentation

Overview

Package speeds 速度计算工具包

Index

• type RateLimit
  • func NewRateLimit(maxRate int64) *RateLimit
  • func (rl *RateLimit) Add(count int64)
  • func (rl *RateLimit) SetInterval(i time.Duration)
  • func (rl *RateLimit) Stop()
• type Speeds
  • func (sps *Speeds) Add(count int64)
  • func (sps *Speeds) GetSpeeds() (speeds int64)
  • func (sps *Speeds) SetInterval(interval time.Duration)

Types

type RateLimit

type RateLimit struct {
	MaxRate int64
	// contains filtered or unexported fields
}

func NewRateLimit

func NewRateLimit(maxRate int64) *RateLimit

func (*RateLimit) Add

func (rl *RateLimit) Add(count int64)

func (*RateLimit) SetInterval

func (rl *RateLimit) SetInterval(i time.Duration)

func (*RateLimit) Stop

func (rl *RateLimit) Stop()

type Speeds

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

Speeds 统计速度

func (*Speeds) Add

func (sps *Speeds) Add(count int64)

Add 原子操作, 增加数据量

func (*Speeds) GetSpeeds

func (sps *Speeds) GetSpeeds() (speeds int64)

GetSpeeds 结束统计速度, 并返回速度

func (*Speeds) SetInterval

func (sps *Speeds) SetInterval(interval time.Duration)

SetInterval 设置刷新周期