limiter

Documentation

Index

• func NewCachedTrafficLimiter(limiter traffic.TrafficLimiter, opts ...Option) traffic.TrafficLimiter
• type Cache
  • func NewCache(cleanupInterval time.Duration) *Cache
  • func (c *Cache) Get(key string) *Item
  • func (c *Cache) Set(key string, item *Item)
• type Item
  • func NewItem(v interface{}, d time.Duration) *Item
  • func (p *Item) Expired() bool
  • func (p *Item) Value() interface{}
• type Option
  • func CleanupIntervalOption(interval time.Duration) Option
  • func RefreshIntervalOption(interval time.Duration) Option
  • func ScopeOption(scope string) Option

Functions

func NewCachedTrafficLimiter

func NewCachedTrafficLimiter(limiter traffic.TrafficLimiter, opts ...Option) traffic.TrafficLimiter

Types

type Cache

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

func NewCache

func NewCache(cleanupInterval time.Duration) *Cache

func (*Cache) Get

func (c *Cache) Get(key string) *Item

func (*Cache) Set

func (c *Cache) Set(key string, item *Item)

type Item

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

func NewItem

func NewItem(v interface{}, d time.Duration) *Item

func (*Item) Expired

func (p *Item) Expired() bool

func (*Item) Value

func (p *Item) Value() interface{}

type Option

type Option func(*options)

func CleanupIntervalOption

func CleanupIntervalOption(interval time.Duration) Option

func RefreshIntervalOption

func RefreshIntervalOption(interval time.Duration) Option

func ScopeOption

func ScopeOption(scope string) Option