cache

Documentation

Index

• Variables
• func Bytes(value interface{}) ([]byte, error)
• func MakeHashSlotKey(hashTag, id, environmentNamespace string) string
• func MakeKey(kind, id, environmentNamespace string) string
• func MakeKeyPrefix(kind, environmentNamespace string) string
• type Cache
  • func NewRedisCache(cluster redis.Cluster) Cache
• type Deleter
• type Getter
• type Lister
• type MultiGetCache
• type MultiGetDeleteCache
• type MultiGetter
• type Putter
• type TTLCache
  • func NewTTLCache(ttl time.Duration, evictionInterval time.Duration) *TTLCache
  • func (c *TTLCache) Destroy()
  • func (c *TTLCache) Get(key interface{}) (interface{}, error)
  • func (c *TTLCache) Put(key interface{}, value interface{}) error

Variables

var (
	ErrNotFound    = errors.New("cache: not found")
	ErrInvalidType = errors.New("cache: not expected type")
)

Functions

func Bytes

func Bytes(value interface{}) ([]byte, error)

func MakeHashSlotKey

func MakeHashSlotKey(hashTag, id, environmentNamespace string) string

MakeHashSlotKey creates a key to ensure that multiple keys are allocated in the same hash slot. https://redis.io/topics/cluster-spec#keys-hash-tags

func MakeKey

func MakeKey(kind, id, environmentNamespace string) string

func MakeKeyPrefix

func MakeKeyPrefix(kind, environmentNamespace string) string

Types

type Cache

type Cache interface {
	Getter
	Putter
}

func NewRedisCache

func NewRedisCache(cluster redis.Cluster) Cache

type Deleter

type Deleter interface {
	Delete(key string) error
}

type Getter

type Getter interface {
	Get(key interface{}) (interface{}, error)
}

type Lister

type Lister interface {
	Keys(pattern string, maxSize int) ([]string, error)
}

FIXME: remove after persistent-redis migration

type MultiGetCache

type MultiGetCache interface {
	Cache
	MultiGetter
}

type MultiGetDeleteCache

type MultiGetDeleteCache interface {
	MultiGetCache
	Deleter
}

type MultiGetter

type MultiGetter interface {
	GetMulti(keys interface{}) ([]interface{}, error)
	Scan(cursor, key, count interface{}) (uint64, []string, error)
}

type Putter

type Putter interface {
	Put(key interface{}, value interface{}) error
}

type TTLCache

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

func NewTTLCache

func NewTTLCache(ttl time.Duration, evictionInterval time.Duration) *TTLCache

func (*TTLCache) Destroy

func (c *TTLCache) Destroy()

func (*TTLCache) Get

func (c *TTLCache) Get(key interface{}) (interface{}, error)

func (*TTLCache) Put

func (c *TTLCache) Put(key interface{}, value interface{}) error