redis

type Cache interface {
	cache.Cache
	Exists(key string) (bool, error)
	SetOpt(key string, value interface{}, options SetOptions) (bool, error)
	Del(key string) error
	Incr(key string) (int64, error)
}

type PubSub interface {
	Cache
	PSubscribe(patterns []string) (SubChan, error)
	PUnsubscribe(sub SubChan) error
	Publish(key string, data []byte) error
}

type RedisConfig struct {
	Endpoint       string
	ClusterMode    bool
	KeyNamespace   string
	TimeTracker    TimeTracker
	MaxIdleConns   int
	MaxActiveConns int
}

type SetOptions struct {
	ExpireIn   time.Duration
	IfNotExist bool
}

type SubChan <-chan []byte

type TimeTracker func(kpiName string, startTime time.Time)