redis

Documentation

Index

• type Cache
  • func NewCache(c *redis.Client, wt time.Duration, rt time.Duration) *Cache
  • func (c *Cache) GetCounter(keyId string, rateLimitUnit key.TimeUnit) (int64, error)
  • func (c *Cache) IncrementCounter(keyId string, timeUnit key.TimeUnit, incr int64) error
• type Store
  • func NewStore(c *redis.Client, wt time.Duration, rt time.Duration) *Store
  • func (s *Store) DeleteCounter(keyId string) error
  • func (s *Store) GetCounter(keyId string) (int64, error)
  • func (s *Store) IncrementCounter(keyId string, incr int64) error

Types

type Cache

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

func NewCache

func NewCache(c *redis.Client, wt time.Duration, rt time.Duration) *Cache

func (*Cache) GetCounter

func (c *Cache) GetCounter(keyId string, rateLimitUnit key.TimeUnit) (int64, error)

func (*Cache) IncrementCounter

func (c *Cache) IncrementCounter(keyId string, timeUnit key.TimeUnit, incr int64) error

type Store

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

func NewStore

func NewStore(c *redis.Client, wt time.Duration, rt time.Duration) *Store

func (*Store) DeleteCounter

func (s *Store) DeleteCounter(keyId string) error

func (*Store) GetCounter

func (s *Store) GetCounter(keyId string) (int64, error)

func (*Store) IncrementCounter

func (s *Store) IncrementCounter(keyId string, incr int64) error