limit

package

v0.0.0-...-cca27e0 Latest Latest Go to latest Published: Feb 6, 2024 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.

View Source

var StopErr = errors.New("stop limit.Every")

This section is empty.

type Counter interface {
	Add(int64) int64
	Count() int64
	Reset()
}

Counter 计数器接口

func LoadCounter(base int64) Counter

LoadCounter 基数计数器

func NewCounter() Counter

NewCounter 计数器

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

Every every

func NewEvery(wait time.Duration, fn func() error) *Every

NewEvery newEvery

func (v *Every) Exit(exit func(error) bool) *Every

func (v Every) Name() string

func (v *Every) Run(ctx context.Context) error

Run 每隔every秒开始执行下一次，如果一次任务的运行时长超过了every，那么下一次直接发起

type Limit struct {
	Err chan error
	// contains filtered or unexported fields
}

Limit limit

func NewLimit(max int) *Limit

NewLimit newLimit

func (limit *Limit) Add(delta int)

func (limit *Limit) Done()

func (limit *Limit) Go(fc func() error)

func (limit *Limit) Len() int

Len len

func (limit *Limit) Wait() error

Wait wait all groutine close