bucket

Documentation

Index

• func GenExpiry(curTime int64, ttl int32) int64
• type KeyBucket
  • func NewKeyBucket(clock clock.Clock) *KeyBucket
  • func (b *KeyBucket) GetEntry(key string) *KeyEntry
  • func (b *KeyBucket) Incr(key string, count int32, limit int32, window int32) (bool, int64, bool)
  • func (b *KeyBucket) Lookup() map[string]*KeyEntry
  • func (b *KeyBucket) Sync(key string, count int32, expiry int64)
• type KeyEntry
  • func NewEntry(count int32, expires int64, clock clock.Clock) *KeyEntry
  • func (e *KeyEntry) Count() int32
  • func (e *KeyEntry) Expired() bool
  • func (e *KeyEntry) Expiry() int64
  • func (e *KeyEntry) Incr(count int32) int32
  • func (e *KeyEntry) LastModified() int64
  • func (e *KeyEntry) ReInit(count int32, expires int64, clock clock.Clock)
  • func (e *KeyEntry) Sync(count int32) int32

Functions

func GenExpiry

func GenExpiry(curTime int64, ttl int32) int64

* ttl in seconds, return expiry in Nano

Types

type KeyBucket

type KeyBucket struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewKeyBucket

func NewKeyBucket(clock clock.Clock) *KeyBucket

func (*KeyBucket) GetEntry

func (b *KeyBucket) GetEntry(key string) *KeyEntry

func (*KeyBucket) Incr

func (b *KeyBucket) Incr(key string, count int32, limit int32, window int32) (bool, int64, bool)

func (*KeyBucket) Lookup

func (b *KeyBucket) Lookup() map[string]*KeyEntry

func (*KeyBucket) Sync

func (b *KeyBucket) Sync(key string, count int32, expiry int64)

type KeyEntry

type KeyEntry struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewEntry

func NewEntry(count int32, expires int64, clock clock.Clock) *KeyEntry

func (*KeyEntry) Count

func (e *KeyEntry) Count() int32

func (*KeyEntry) Expired

func (e *KeyEntry) Expired() bool

func (*KeyEntry) Expiry

func (e *KeyEntry) Expiry() int64

func (*KeyEntry) Incr

func (e *KeyEntry) Incr(count int32) int32

* return total count and curr second count

func (*KeyEntry) LastModified

func (e *KeyEntry) LastModified() int64

func (*KeyEntry) ReInit

func (e *KeyEntry) ReInit(count int32, expires int64, clock clock.Clock)

func (*KeyEntry) Sync

func (e *KeyEntry) Sync(count int32) int32