redis

Documentation

Index

• type Cmdable
  • func New[T string | Config | *redis.Options | redis.ClusterOptions](t T) (redisCli Cmdable, err error)
• type Config

Types

type Cmdable

type Cmdable interface {
	Pipeline() redis.Pipeliner
	Pipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error)

	TxPipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error)
	TxPipeline() redis.Pipeliner

	Command(ctx context.Context) *redis.CommandsInfoCmd
	CommandList(ctx context.Context, filter *redis.FilterBy) *redis.StringSliceCmd
	CommandGetKeys(ctx context.Context, commands ...interface{}) *redis.StringSliceCmd
	CommandGetKeysAndFlags(ctx context.Context, commands ...interface{}) *redis.KeyFlagsCmd
	ClientGetName(ctx context.Context) *redis.StringCmd
	Echo(ctx context.Context, message interface{}) *redis.StringCmd
	Ping(ctx context.Context) *redis.StatusCmd
	Quit(ctx context.Context) *redis.StatusCmd
	Unlink(ctx context.Context, keys ...string) *redis.IntCmd

	BgRewriteAOF(ctx context.Context) *redis.StatusCmd
	BgSave(ctx context.Context) *redis.StatusCmd
	ClientKill(ctx context.Context, ipPort string) *redis.StatusCmd
	ClientKillByFilter(ctx context.Context, keys ...string) *redis.IntCmd
	ClientList(ctx context.Context) *redis.StringCmd
	ClientInfo(ctx context.Context) *redis.ClientInfoCmd
	ClientPause(ctx context.Context, dur time.Duration) *redis.BoolCmd
	ClientUnpause(ctx context.Context) *redis.BoolCmd
	ClientID(ctx context.Context) *redis.IntCmd
	ClientUnblock(ctx context.Context, id int64) *redis.IntCmd
	ClientUnblockWithError(ctx context.Context, id int64) *redis.IntCmd
	ConfigGet(ctx context.Context, parameter string) *redis.MapStringStringCmd
	ConfigResetStat(ctx context.Context) *redis.StatusCmd
	ConfigSet(ctx context.Context, parameter, value string) *redis.StatusCmd
	ConfigRewrite(ctx context.Context) *redis.StatusCmd
	DBSize(ctx context.Context) *redis.IntCmd
	FlushAll(ctx context.Context) *redis.StatusCmd
	FlushAllAsync(ctx context.Context) *redis.StatusCmd
	FlushDB(ctx context.Context) *redis.StatusCmd
	FlushDBAsync(ctx context.Context) *redis.StatusCmd
	Info(ctx context.Context, section ...string) *redis.StringCmd
	LastSave(ctx context.Context) *redis.IntCmd
	Save(ctx context.Context) *redis.StatusCmd
	Shutdown(ctx context.Context) *redis.StatusCmd
	ShutdownSave(ctx context.Context) *redis.StatusCmd
	ShutdownNoSave(ctx context.Context) *redis.StatusCmd
	SlaveOf(ctx context.Context, host, port string) *redis.StatusCmd
	SlowLogGet(ctx context.Context, num int64) *redis.SlowLogCmd
	Time(ctx context.Context) *redis.TimeCmd
	DebugObject(ctx context.Context, key string) *redis.StringCmd

	MemoryUsage(ctx context.Context, key string, samples ...int) *redis.IntCmd

	ModuleLoadex(ctx context.Context, conf *redis.ModuleLoadexConfig) *redis.StringCmd

	Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error

	redis.ACLCmdable
	redis.BitMapCmdable
	redis.ClusterCmdable
	redis.GearsCmdable
	redis.GenericCmdable
	redis.GeoCmdable
	redis.HashCmdable
	redis.HyperLogLogCmdable
	redis.ListCmdable
	redis.ProbabilisticCmdable
	redis.PubSubCmdable
	redis.ScriptingFunctionsCmdable
	redis.SetCmdable
	redis.SortedSetCmdable
	redis.StringCmdable
	redis.StreamCmdable
	redis.TimeseriesCmdable
	redis.JSONCmdable
}

func New

func New[T string | Config | *redis.Options | redis.ClusterOptions](t T) (redisCli Cmdable, err error)

[2] Config [3] *redis.Options [4] *redis.ClusterOptions

type Config

type Config struct {
	Hosts    []string // for cluster
	Host     string   // for single
	Port     string   // for single
	Password string   // for all
}