limitpool

Documentation

Index

• Constants
• type Pool
  • func NewPool(limit rate.Limit, burst int) (p *Pool)
  • func (p *Pool) Tokens(key any) float64
  • func (p *Pool) Wait(ctx context.Context, key any) error
  • func (p *Pool) WaitN(ctx context.Context, key any, n int) (err error)

Constants

const IDLE_DEADLINE_PERIOD = 30

Types

type Pool

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

func NewPool

func NewPool(limit rate.Limit, burst int) (p *Pool)

func (*Pool) Tokens

func (p *Pool) Tokens(key any) float64

func (*Pool) Wait

func (p *Pool) Wait(ctx context.Context, key any) error

func (*Pool) WaitN

func (p *Pool) WaitN(ctx context.Context, key any, n int) (err error)