cache

Jul 30, 2025

Changes in this version

type ValkeyCacheConfig

+ ClientName string

+ Username string

Jul 24, 2025

Changes in this version

+ const DefaultKeyHash

+ func CallCached[T any](c Cache, ttl time.Duration, fnname string, fn interface{}, args ...interface{}) (T, error)

+ func DecodeKey(key string, keyHash KeyHashType) (string, error)

+ func StatStr(stat Stat) string

+ type Cache interface

+ CacheKey func(fnname string, fn interface{}, args ...interface{}) (string, error)

+ Get func(key string) (string, bool, error)

+ GetStat func() Stat

+ IncHit func()

+ IncMiss func()

+ Invalidate func(key string) error

+ LaunchRefresh func(fn func())

+ Set func(key string, value string, ttl time.Duration) error

+ func NewCache(ctx context.Context, wg *sync.WaitGroup, config interface{}) Cache

+ type CacheBase struct

+ func NewCacheBase(ctx context.Context, wg *sync.WaitGroup, config CacheConfig) *CacheBase

+ func (cb *CacheBase) IncHit()

+ func (cb *CacheBase) IncMiss()

+ func (cb *CacheBase) LaunchRefresh(fn func())

+ func (cb CacheBase) CacheKey(fnname string, fn interface{}, args ...interface{}) (string, error)

+ func (cb CacheBase) EncodeKey(key string) string

+ func (cb CacheBase) GetStat() Stat

+ type CacheConfig struct

+ KeyHash KeyHashType

+ MaxDbConcurrentRefreshes int

+ MonitorInterval time.Duration

+ ThrottleInterval time.Duration

+ ThrottlePerInterval int

+ type InMemoryCache struct

+ func NewInMemoryCache(ctx context.Context, wg *sync.WaitGroup, config InMemoryCacheConfig) *InMemoryCache

+ func (imc InMemoryCache) Get(key string) (string, bool, error)

+ func (imc InMemoryCache) Invalidate(key string) error

+ func (imc InMemoryCache) Set(key string, value string, ttl time.Duration) error

+ type InMemoryCacheConfig struct

+ CleanupInterval time.Duration

+ type KeyHashType int

+ const KEY_HASH_BASE64

+ const KEY_HASH_HEX

+ const KEY_HASH_NONE

+ const KEY_HASH_SHA256

+ const KEY_HASH_SHA512

+ func ParseKeyHashType(s string) KeyHashType

+ func (k KeyHashType) String() string

+ type NoCache struct

+ func NewNoCache() *NoCache

+ func (nc NoCache) CacheKey(fnname string, fn interface{}, args ...interface{}) (string, error)

+ func (nc NoCache) Get(key string) (string, bool, error)

+ func (nc NoCache) GetStat() Stat

+ func (nc NoCache) IncHit()

+ func (nc NoCache) IncMiss()

+ func (nc NoCache) Invalidate(key string) error

+ func (nc NoCache) LaunchRefresh(func())

+ func (nc NoCache) Set(key string, value string, ttl time.Duration) error

+ type Stat struct

+ Hit int64

+ Miss int64

+ type ValkeyCache struct

+ func NewValkeyCache(ctx context.Context, wg *sync.WaitGroup, config ValkeyCacheConfig) *ValkeyCache

+ func (vc *ValkeyCache) Get(key string) (string, bool, error)

+ func (vc *ValkeyCache) Invalidate(key string) error

+ func (vc *ValkeyCache) Set(key string, value string, ttl time.Duration) error

+ type ValkeyCacheConfig struct

+ Db int

+ Password string

+ Url string