redis

Documentation

Index

• Variables
• type Client
  • func NewRedis(prefix string) (Client, error)
  • func NewRedisDefaultConfig(prefix string, defaultConfig *CommonConfig) (client Client, err error)
• type ClientWrapper
  • func (c *ClientWrapper) Pipeline() Pipeline
• type ClusterClientWrapper
  • func (c *ClusterClientWrapper) Pipeline() Pipeline
• type CommonConfig
• type Pipeline

Variables

var (
	ErrNoRedisConfig = errors.New("no redis configuration found with config prefix")
)

Types

type Client

type Client interface {
	Pipeline() Pipeline
	// contains filtered or unexported methods
}

func NewRedis

func NewRedis(prefix string) (Client, error)

func NewRedisDefaultConfig

func NewRedisDefaultConfig(prefix string, defaultConfig *CommonConfig) (client Client, err error)

type ClientWrapper

type ClientWrapper struct {
	*redis.Client
}

func (*ClientWrapper) Pipeline

func (c *ClientWrapper) Pipeline() Pipeline

type ClusterClientWrapper

type ClusterClientWrapper struct {
	*redis.ClusterClient
}

func (*ClusterClientWrapper) Pipeline

func (c *ClusterClientWrapper) Pipeline() Pipeline

type CommonConfig

type CommonConfig struct {
	DB           int64
	Password     string
	MaxRetries   int
	DialTimeout  time.Duration
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	PoolSize     int
	PoolTimeout  time.Duration
	IdleTimeout  time.Duration
	TryLegacy    bool
	TryLocal     bool
}

type Pipeline

type Pipeline interface {
	Exec() ([]redis.Cmder, error)
	// contains filtered or unexported methods
}