redis

Documentation

Index

• type AccessCache
  • func NewAccessCache(c *redis.Client, wt time.Duration, rt time.Duration) *AccessCache
  • func (ac *AccessCache) Delete(key string) error
  • func (ac *AccessCache) GetAccessStatus(key string) bool
  • func (ac *AccessCache) Set(key string, timeUnit key.TimeUnit) error
• type Cache
  • func NewCache(c *redis.Client, wt time.Duration, rt time.Duration) *Cache
  • func (c *Cache) Delete(key string) error
  • func (c *Cache) GetBytes(key string) ([]byte, error)
  • func (c *Cache) GetCounter(keyId string, rateLimitUnit key.TimeUnit) (int64, error)
  • func (c *Cache) IncrementCounter(keyId string, timeUnit key.TimeUnit, incr int64) error
  • func (c *Cache) Set(key string, value interface{}, ttl time.Duration) 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
• type ThreadCache
  • func NewThreadCache(c *redis.Client, wt time.Duration, rt time.Duration) *ThreadCache
  • func (ac *ThreadCache) Delete(key string) error
  • func (ac *ThreadCache) GetThreadStatus(key string) bool
  • func (ac *ThreadCache) Set(key string, dur time.Duration) error

Types

type AccessCache

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

func NewAccessCache

func NewAccessCache(c *redis.Client, wt time.Duration, rt time.Duration) *AccessCache

func (*AccessCache) Delete

func (ac *AccessCache) Delete(key string) error

func (*AccessCache) GetAccessStatus

func (ac *AccessCache) GetAccessStatus(key string) bool

func (*AccessCache) Set

func (ac *AccessCache) Set(key string, timeUnit key.TimeUnit) error

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) Delete

func (c *Cache) Delete(key string) error

func (*Cache) GetBytes

func (c *Cache) GetBytes(key string) ([]byte, error)

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

func (*Cache) Set

func (c *Cache) Set(key string, value interface{}, ttl time.Duration) 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

type ThreadCache

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

func NewThreadCache

func NewThreadCache(c *redis.Client, wt time.Duration, rt time.Duration) *ThreadCache

func (*ThreadCache) Delete

func (ac *ThreadCache) Delete(key string) error

func (*ThreadCache) GetThreadStatus

func (ac *ThreadCache) GetThreadStatus(key string) bool

func (*ThreadCache) Set

func (ac *ThreadCache) Set(key string, dur time.Duration) error