bucket

Documentation

Index

• type Int64bucket
  • func (b *Int64bucket) GetFreeResource() int64
  • func (b *Int64bucket) GetResDetected(cost int64, timer *time.Timer) error
  • func (b *Int64bucket) GetResource(cost int64) error
  • func (b *Int64bucket) ReleaseResource(freeResource int64)
• type ResourceBucket
  • func NewInt64Bucket(timeOut time.Duration, TotalResource int64, outOfLimitOnce bool) ResourceBucket

Types

type Int64bucket

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

func (*Int64bucket) GetFreeResource

func (b *Int64bucket) GetFreeResource() int64

func (*Int64bucket) GetResDetected

func (b *Int64bucket) GetResDetected(cost int64, timer *time.Timer) error

func (*Int64bucket) GetResource

func (b *Int64bucket) GetResource(cost int64) error

func (*Int64bucket) ReleaseResource

func (b *Int64bucket) ReleaseResource(freeResource int64)

!use getResImpl to get resource must use ReleaseResource to release

type ResourceBucket

type ResourceBucket interface {
	ReleaseResource(int64)
	GetResource(int64) error
	GetResDetected(int64, *time.Timer) error
	GetFreeResource() int64
}

func NewInt64Bucket

func NewInt64Bucket(timeOut time.Duration, TotalResource int64, outOfLimitOnce bool) ResourceBucket