redis

Documentation

Index

• Variables
• func UseTls(cnf *config.RedisConfig, opts ...option.Option) (*tls.Config, error)
• func WithTlsOption(f func(cnf *config.RedisConfig) (*tls.Config, error)) option.Option
• type Adapter
  • func NewAdapter(name string, cfg *config.RedisConfig, sentinelCfg *config.RedisConfig, ...) (*Adapter, error)
  • func (a *Adapter) Cluster() *redis.ClusterClient
  • func (a *Adapter) Name() string
  • func (a *Adapter) Rds() *redis.Client
  • func (a *Adapter) Sentinel() *redis.SentinelClient
• type Client
  • func NewRedis(conf []config.Redis, opts ...option.Option) (Client, error)
• type Connector
  • func (c *Connector) Close(name string) error
  • func (c *Connector) CloseAll()
  • func (c *Connector) Get(name string) (Redis, error)
  • func (c *Connector) Select(name string)
  • func (c *Connector) SelectDB(name string, index int) error
• type Logger
  • func (l *Logger) Printf(ctx context.Context, format string, v ...interface{})
• type Redis

Variables

var DefaultTlsFunc = func(cnf *config.RedisConfig) (*tls.Config, error) {
	if strings.EqualFold(cnf.Tls.Key, "false") {
		return nil, result.RErrNotSupport
	}
	if strings.EqualFold(cnf.Tls.Key, "true") {
		return &tls.Config{}, nil
	}
	if strings.EqualFold(cnf.Tls.Key, "skip-verify") ||
		strings.EqualFold(cnf.Tls.Key, "preferred") {
		return &tls.Config{InsecureSkipVerify: true}, nil
	}
	cert, rootCertPool, err := daotls.GetCertificate(&cnf.Tls)
	if err != nil {
		return nil, err
	}
	return &tls.Config{
		RootCAs:      rootCertPool,
		Certificates: []tls.Certificate{cert},
	}, nil
}

Functions

func UseTls

func UseTls(cnf *config.RedisConfig, opts ...option.Option) (*tls.Config, error)

func WithTlsOption

func WithTlsOption(f func(cnf *config.RedisConfig) (*tls.Config, error)) option.Option

Types

type Adapter

type Adapter struct {
	// contains filtered or unexported fields
}

func NewAdapter

func NewAdapter(name string, cfg *config.RedisConfig, sentinelCfg *config.RedisConfig, clusterCfg *config.RedisConfig, opts ...option.Option) (*Adapter, error)

func (*Adapter) Cluster

func (a *Adapter) Cluster() *redis.ClusterClient

func (*Adapter) Name

func (a *Adapter) Name() string

func (*Adapter) Rds

func (a *Adapter) Rds() *redis.Client

func (*Adapter) Sentinel

func (a *Adapter) Sentinel() *redis.SentinelClient

type Client

type Client interface {
	Get(name string) (Redis, error)
	Close(name string) error
	CloseAll()
	Select(name string)                    //选哪个redis
	SelectDB(name string, index int) error //选哪个redis db
}

func NewRedis

func NewRedis(conf []config.Redis, opts ...option.Option) (Client, error)

type Connector

type Connector struct {
	// contains filtered or unexported fields
}

func (*Connector) Close

func (c *Connector) Close(name string) error

func (*Connector) CloseAll

func (c *Connector) CloseAll()

func (*Connector) Get

func (c *Connector) Get(name string) (Redis, error)

func (*Connector) Select

func (c *Connector) Select(name string)

func (*Connector) SelectDB

func (c *Connector) SelectDB(name string, index int) error

type Logger

type Logger struct {
	config.RedisLogger
}

func (*Logger) Printf

func (l *Logger) Printf(ctx context.Context, format string, v ...interface{})

type Redis

type Redis interface {
	Rds() *redis.Client
	Sentinel() *redis.SentinelClient
	Cluster() *redis.ClusterClient
	Name() string
}