stats

package

v0.0.0-...-177afef Latest Latest Go to latest Published: Feb 8, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Counter struct {
	Total  int64 // 总调用次数(limiter)
	Failed int64 // 失败次数
	// contains filtered or unexported fields
}

计数器

func NewCounter() *Counter

func (c *Counter) AddRecord(idx int64, err error, cost int64)

func (c *Counter) Idx() (idx int64)

idx < 0 表示用尽

func (c *Counter) Report(title string, totalns int64, concurrent int, total int64, echoSize int) error

func (c *Counter) Reset(total int64)

type Limiter struct {
	sync.Once
	// contains filtered or unexported fields
}

QPS 限制器

func NewLimiter(maxQps int64, window time.Duration) *Limiter

公用全局 Timer reset 减少开销, 但 AddNotify 无法回收, 因此不能频繁创建 Limiter must use *Limiter, 否则配置会被复制导致失效

func (l *Limiter) QpsOverrun() bool

true 代表超过上限, maxQps <= 0表示没有上限

func (l *Limiter) Reset(maxQps int64)

has race here but will not appear

type Timer struct {
	sync.Once
	// contains filtered or unexported fields
}

全局 Timer, 共享时间周期, 并在到期时执行回调

func NewTimer(window time.Duration) *Timer

func (t *Timer) Now() int64

Timer 为共享计时器, 减少系统时间调用

func (t *Timer) Window() time.Duration