redisproxy

Documentation

Index

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

Variables

var Default *redisProxy

Default 默认的redis代理对象

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

var ErrProxyAllreadySettedUniversalClient = errors.New("proxy allready setted universal client")

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

var ErrProxyNotYetSettedUniversalClient = errors.New("proxy notSet universal client yet")

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

var ErrUnknownClientType = errors.New("unknown client type")

ErrUnknownClientType 未知的redis客户端类型

Functions

func New

func New() *redisProxy

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

func WithClusterOptions

func WithClusterOptions(RedisOptions *redis.ClusterOptions) optparams.Option[Options]

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

func WithFailoverClusterOptions

func WithFailoverClusterOptions(RedisOptions *redis.FailoverOptions) optparams.Option[Options]

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

func WithFailoverOptions

func WithFailoverOptions(RedisOptions *redis.FailoverOptions) optparams.Option[Options]

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

func WithHooks

func WithHooks(hooks ...redis.Hook) optparams.Option[Options]

WithHooks 增加redis钩子

func WithOptions

func WithOptions(RedisOptions *redis.Options) optparams.Option[Options]

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

func WithParallelCallback

func WithParallelCallback() optparams.Option[Options]

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

func WithQueryTimeoutMS

func WithQueryTimeoutMS(QueryTimeout int) optparams.Option[Options]

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

func WithRingOptions

func WithRingOptions(RedisOptions *redis.RingOptions) optparams.Option[Options]

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

func WithURL

func WithURL(URL string) optparams.Option[Options]

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

Types

type Callback

type Callback func(cli redis.UniversalClient) error

Callback 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
)