leakybucket

Documentation

Index

• type Bucket
  • func NewBucket(id string, rateLimit uint64, duration time.Duration, inactiveCycles uint64) *Bucket
  • func (b *Bucket) CheckLimit(ctx context.Context) bool
  • func (b *Bucket) Inactive(ctx context.Context) <-chan struct{}
  • func (b *Bucket) ResetLimit(ctx context.Context)

Types

type Bucket

type Bucket struct {
	ID string
	// contains filtered or unexported fields
}

Bucket struct

func NewBucket

func NewBucket(id string, rateLimit uint64, duration time.Duration, inactiveCycles uint64) *Bucket

NewBucket Bucket constructor

func (*Bucket) CheckLimit

func (b *Bucket) CheckLimit(ctx context.Context) bool

CheckLimit Method to check bucket limit

func (*Bucket) Inactive

func (b *Bucket) Inactive(ctx context.Context) <-chan struct{}

Inactive Method to get "done" channel

func (*Bucket) ResetLimit

func (b *Bucket) ResetLimit(ctx context.Context)

ResetLimit Method to reset bucket limit