cache

type Cache interface {
	CacheKey(fnname string, fn any, args ...any) (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
}