kv

type Cancel func() bool

type DataCheck[K comparable, V any] func(map[K]V) error

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

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

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

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

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

type FetchGlobal[K comparable, V any] func() (map[K]V, error)

type FetchKey[K comparable, V any] func(K) (map[K]V, error)

type KV[K comparable, V any] interface {
	// 直接获取缓存
	GetCacheByKey(K) (V, KVError)

	// 获取缓存，如果没有命中则回源
	GetCacheOrElseSourceByKey(K) (V, KVError)

	// 直接获取缓存
	GetCache() (map[K]V, KVError)

	// 获取缓存，如果没有命中则回源
	GetCacheOrElseSource() (map[K]V, KVError)

	// 直接回源
	GetSourceByKey(K) (V, KVError)

	// 直接回源
	GetSource() (map[K]V, KVError)

	// 查询数据源，如果查询失败 则通过本地缓存兜底
	// 如果查询源数据失败，则走本地缓存。 error将返回ErrCacheDefense
	GetSourceOrElseCache() (map[K]V, KVError)

	// 查询数据源，如果查询失败 则通过本地缓存兜底
	// 如果查询源数据失败，则走本地缓存。 error将返回ErrCacheDefense
	GetSourceOrElseCacheByKey(K) (V, KVError)
}

type KVError interface {
	error
	Code() int64
}

type MetricReport func(kvEname, kvName string, err error)

type OptionFn[K comparable, V any] func(c *simpleKV[K, V])