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
• type Counter
• type Deleter
• type Expirer
• type Getter
• type Lister
• type MultiGetCache
• type MultiGetDeleteCountCache
• type MultiGetter
• type PFGetter
• type PFMerger
• type PipeLiner
• type Putter

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
}

type Counter

type Counter interface {
	Increment(key string) (int64, error)
	PFAdd(key string, els ...string) (int64, error)
}

type Deleter

type Deleter interface {
	Delete(key string) error
}

type Expirer

type Expirer interface {
	Expire(key string, expiration time.Duration) (bool, 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 MultiGetDeleteCountCache

type MultiGetDeleteCountCache interface {
	MultiGetCache
	Deleter
	Counter
	PipeLiner
	Expirer
	PFGetter
	PFMerger
}

type MultiGetter

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

type PFGetter

type PFGetter interface {
	PFCount(keys ...string) (int64, error)
}

type PFMerger

type PFMerger interface {
	PFMerge(dest string, keys ...string) error
}

type PipeLiner

type PipeLiner interface {
	Pipeline() redis.PipeClient
}

type Putter

type Putter interface {
	Put(key interface{}, value interface{}, expiration time.Duration) error
}