throttle

Documentation

Index

• Variables
• type RefCounter
  • func NewRefCounter(client *redis.Client, quota int64) *RefCounter
  • func (rc *RefCounter) Ref(key string, expiration ...time.Duration) bool
  • func (rc *RefCounter) SafeUnref(key string)
  • func (rc *RefCounter) UnrefAsync(key string)

Variables

var DefaultExpiration = time.Minute

Types

type RefCounter

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

RefCounter allows to throttle based on reference counter.

func NewRefCounter

func NewRefCounter(client *redis.Client, quota int64) *RefCounter

func (*RefCounter) Ref

func (rc *RefCounter) Ref(key string, expiration ...time.Duration) bool

func (*RefCounter) SafeUnref

func (rc *RefCounter) SafeUnref(key string)

func (*RefCounter) UnrefAsync

func (rc *RefCounter) UnrefAsync(key string)