rd

type ACLManager interface {
	redis.ACLCmdable
}

type BitMapManager interface {
	redis.BitMapCmdable
}

type Closer interface {
	Close() error
}

type ClusterManager interface {
	redis.ClusterCmdable
}

type Commander interface {
	redis.Cmdable
}

type Config struct {
	InMemory        bool          `mapstructure:"in_memory" default:"false"`
	Network         string        `mapstructure:"network" default:"tcp"`
	Addr            string        `mapstructure:"addr" default:"127.0.0.1:6379"`
	Protocol        int           `mapstructure:"protocol" default:"3"`
	Username        string        `mapstructure:"username"`
	Password        string        `mapstructure:"password"`
	DB              int           `mapstructure:"db" default:"0"`
	DialTimeout     time.Duration `mapstructure:"dial_timeout" default:"5s"`
	ReadTimeout     time.Duration `mapstructure:"read_timeout" default:"3s"`
	WriteTimeout    time.Duration `mapstructure:"write_timeout" default:"3s"`
	PoolSize        int           `mapstructure:"pool_size" default:"10"`
	MinIdleConns    int           `mapstructure:"min_idle_conns" default:"0"`
	MaxIdleConns    int           `mapstructure:"max_idle_conns" default:"0"`
	MaxActiveConns  int           `mapstructure:"max_active_conns" default:"0"`
	PoolTimeout     time.Duration `mapstructure:"pool_timeout" default:"4s"`
	ConnMaxIdleTime time.Duration `mapstructure:"conn_max_idle_time" default:"30m"`
	ConnMaxLifetime time.Duration `mapstructure:"conn_max_lifetime" default:"0s"`
}

type GenericManager interface {
	redis.GenericCmdable
}

type GeoManager interface {
	redis.GeoCmdable
}

type HashManager interface {
	redis.HashCmdable
}

type HookAdder interface {
	AddHook(hook redis.Hook)
}

type HyperLogLogManager interface {
	redis.HyperLogLogCmdable
}

type JSONManager interface {
	redis.JSONCmdable
}

type ListManager interface {
	redis.ListCmdable
}

type PoolStatser interface {
	PoolStats() *redis.PoolStats
}

type ProbabilisticManager interface {
	redis.ProbabilisticCmdable
}

type Processor interface {
	Do(ctx context.Context, args ...interface{}) *redis.Cmd
	Process(ctx context.Context, cmd redis.Cmder) error
}

type PubSubManager interface {
	redis.PubSubCmdable
}

type RedisClient interface {
	RedisManager
	HookAdder
	Watcher
	Processor
	Subscriber
	Closer
	PoolStatser
}

type RedisManager interface {
	Commander
	ACLManager
	BitMapManager
	ClusterManager
	GenericManager
	GeoManager
	HashManager
	HyperLogLogManager
	ListManager
	ProbabilisticManager
	PubSubManager
	ScriptingManager
	SearchManager
	SetManager
	SortedSetManager
	StringManager
	StreamManager
	TimeseriesManager
	JSONManager
	VectorSetManager
}

type ScriptingManager interface {
	redis.ScriptingFunctionsCmdable
}

type SearchManager interface {
	redis.SearchCmdable
}

type SetManager interface {
	redis.SetCmdable
}

type SortedSetManager interface {
	redis.SortedSetCmdable
}

type StatefulCommander interface {
	redis.StatefulCmdable
}

type StreamManager interface {
	redis.StreamCmdable
}

type StringManager interface {
	redis.StringCmdable
}

type Subscriber interface {
	Subscribe(ctx context.Context, channels ...string) *redis.PubSub
	PSubscribe(ctx context.Context, channels ...string) *redis.PubSub
	SSubscribe(ctx context.Context, channels ...string) *redis.PubSub
}

type TimeseriesManager interface {
	redis.TimeseriesCmdable
}

type VectorSetManager interface {
	redis.VectorSetCmdable
}

type Watcher interface {
	Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error
}