cache

type Cache interface {
	CacheKey(fnname string, fn interface{}, args ...interface{}) (string, error)
	Get(key string) (string, bool, error)
	Set(key string, value string, ttl time.Duration) error
	Invalidate(key string) error
	IncHit()
	IncMiss()
	IncShared()
	GetStat() Stat
	LaunchRefresh(fn func())
	GetSingleflightWrapper() SingleflightWrapper
}

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

type CacheConfig struct {
	KeyHash                  KeyHashType
	MonitorInterval          time.Duration
	MaxDbConcurrentRefreshes int
	ThrottleInterval         time.Duration
	ThrottlePerInterval      int
}

type InMemoryCache struct {
	CacheBase
	// contains filtered or unexported fields
}

type InMemoryCacheConfig struct {
	CacheConfig
	CleanupInterval time.Duration
}

type KeyHashType int

type SingleflightWrapper interface {
	Do(string, func() (any, error)) (any, error, bool)
}

type Stat struct {
	Hit    int64
	Miss   int64
	Shared int64
}

type ValkeyCache struct {
	CacheBase
	// contains filtered or unexported fields
}

type ValkeyCacheConfig struct {
	CacheConfig
	Url        string
	Username   string
	Password   string
	ClientName string
	Db         int
}