conn

Documentation

Index

• type CachePipel
• type RedisClient
• type RedisConf
  • func (rc *RedisConf) NewRedisDbConn(ctx context.Context, name string) (RedisClient, error)
• type RedisDI

Types

type CachePipel

type CachePipel interface {
	Get(key string) *redis.StringCmd
	Exec() ([]redis.Cmder, error)
}

type RedisClient

type RedisClient interface {
	Close() error
	Ping() string
	CountKeys() (int, error)
	Get(k string) ([]byte, error)
	Set(k string, v interface{}, exp time.Duration) (string, error)
	Del(k string) (int64, error)
	LPush(k string, v interface{}) (int64, error)
	RPop(k string) ([]byte, error)
	HGet(key string, field string) string
	HSet(key string, values map[string]string) error
	HGetAll(key string) map[string]string
	Exists(key string) bool
	Expired(key string, d time.Duration) (bool, error)
	NewPiple() CachePipel
	Keys(pattern string) ([]string, error)
}

type RedisConf

type RedisConf struct {
	Host  string         `yaml:"host"`
	Pwd   string         `yaml:"pass"`
	DbMap map[string]int `yaml:"dbMap"`
}

func (*RedisConf) NewRedisDbConn

func (rc *RedisConf) NewRedisDbConn(ctx context.Context, name string) (RedisClient, error)

type RedisDI

type RedisDI interface {
	NewRedisDbConn(ctx context.Context, name string) (RedisClient, error)
}