throttle

Documentation

Overview

Package throttle is used to limit concurrent activities

Index

• func AcquireMulti(ctx context.Context, tList []*Throttle) (context.Context, error)
• func ReleaseMulti(ctx context.Context, tList []*Throttle) error
• type Throttle
  • func New(count int) *Throttle
  • func (t *Throttle) Acquire(ctx context.Context) error
  • func (t *Throttle) Release(ctx context.Context) error
  • func (t *Throttle) TryAcquire(ctx context.Context) (bool, error)

Functions

func AcquireMulti

func AcquireMulti(ctx context.Context, tList []*Throttle) (context.Context, error)

func ReleaseMulti

func ReleaseMulti(ctx context.Context, tList []*Throttle) error

Types

type Throttle

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

func New

func New(count int) *Throttle

func (*Throttle) Acquire

func (t *Throttle) Acquire(ctx context.Context) error

func (*Throttle) Release

func (t *Throttle) Release(ctx context.Context) error

func (*Throttle) TryAcquire

func (t *Throttle) TryAcquire(ctx context.Context) (bool, error)