proxy

Documentation

Index

• Variables
• func New() *redisProxy
• type Callback
• type Option
  • func WithClusterOptions(RedisOptions *redis.ClusterOptions) Option
  • func WithFailoverClusterOptions(RedisOptions *redis.FailoverOptions) Option
  • func WithFailoverOptions(RedisOptions *redis.FailoverOptions) Option
  • func WithHooks(hooks ...redis.Hook) Option
  • func WithOptions(RedisOptions *redis.Options) Option
  • func WithParallelCallback() Option
  • func WithQueryTimeoutMS(QueryTimeout int) Option
  • func WithRingOptions(RedisOptions *redis.RingOptions) Option
  • func WithURL(URL string) Option
• type Options
• type RedisType

Variables

var DefaultOpts = Options{
	StandAloneOptions: &redis.Options{Addr: "localhost:6379"},
	Type:              Redis_Standalone,
	Parallelcallback:  false,
	Hooks:             []redis.Hook{},
}

var ErrProxyAllreadySettedUniversalClient = errors.New("代理不能重复设置客户端对象")

ErrProxyAllreadySettedUniversalClient 代理已经设置过redis客户端对象

var ErrProxyNotYetSettedUniversalClient = errors.New("代理还未设置客户端对象")

ErrProxyNotYetSettedUniversalClient 代理还未设置客户端对象

var ErrUnknownClientType = errors.New("未知的redis客户端类型")

ErrUnknownClientType 未知的redis客户端类型

var Proxy = New()

Proxy 默认的redis代理对象

Functions

func New

func New() *redisProxy

New 创建一个新的数据库客户端代理

Types

type Callback

type Callback func(cli redis.UniversalClient) error

Callback redis操作的回调函数

type Option

type Option interface {
	Apply(*Options)
}

Option configures how we set up the connection.

func WithClusterOptions

func WithClusterOptions(RedisOptions *redis.ClusterOptions) Option

WithClusterOptions 使用特定redis集群连接设置

func WithFailoverClusterOptions

func WithFailoverClusterOptions(RedisOptions *redis.FailoverOptions) Option

WithFailoverOptions 使用特定redis集群哨兵连接设置

func WithFailoverOptions

func WithFailoverOptions(RedisOptions *redis.FailoverOptions) Option

WithFailoverOptions 使用特定redis哨兵连接设置

func WithHooks

func WithHooks(hooks ...redis.Hook) Option

WithHooks 增加redis钩子

func WithOptions

func WithOptions(RedisOptions *redis.Options) Option

WithOptions 使用特定单机redis连接设置

func WithParallelCallback

func WithParallelCallback() Option

WithParallelCallback 设置初始化后回调并行执行而非串行执行

func WithQueryTimeoutMS

func WithQueryTimeoutMS(QueryTimeout int) Option

WithQueryTimeoutMS 设置最大请求超时,单位ms

func WithRingOptions

func WithRingOptions(RedisOptions *redis.RingOptions) Option

WithRingOptions 使用特定redis的Ring集群连接设置

func WithURL

func WithURL(URL string) Option

WithURL 使用特定url设置单机redis的连接

type Options

type Options struct {
	Type              RedisType
	Parallelcallback  bool
	QueryTimeout      time.Duration
	StandAloneOptions *redis.Options
	ClusterOptions    *redis.ClusterOptions
	FailoverOptions   *redis.FailoverOptions
	RingOptions       *redis.RingOptions
	Hooks             []redis.Hook
}

Option 设置key行为的选项

type RedisType

type RedisType int32

redis类型

const (
	Redis_Standalone      RedisType = 0
	Redis_Cluster         RedisType = 1
	Redis_Failover        RedisType = 2
	Redis_FailoverCluster RedisType = 3
	Redis_Ring            RedisType = 4
)