proxy

Documentation

Index

• type Cfg
  • func GetCfg() *Cfg
• type RedisProxy
  • func NewRedisProxy(cfg *Cfg) *RedisProxy
  • func (p *RedisProxy) Start() error
  • func (p *RedisProxy) Stop()

Types

type Cfg

type Cfg struct {
	Addr                 string   `json:"addr"`
	AddrNotify           string   `json:"addrNotify"`
	Advertise_AddrNotify string   `json:"advertise_addrNotify"`
	WatcherHeartbeatSec  int      `json:"watcherHeartbeatSec"`
	PDAddrs              []string `json:"pdAddrs"`
	MaxRetries           int      `json:"maxRetries"`
	RetryDuration        int64    `json:"retryDuration"`
	WorkerCount          uint64   `json:"workerCount"`
	SupportCMDs          []string `json:"supportCMDs"`

	// xiaoxiao : set timeout time
	Timeout int64 `json:"timeout"`
	// xiaoxiao : enable Follower Read
	EnableFollowerRead bool     `json:"enableFollowerRead"`
	ReadHandleCMDs     []string `json:"readhandles"`
}

Cfg returns cfg for proxy

func GetCfg

func GetCfg() *Cfg

GetCfg get cfg from command

type RedisProxy

type RedisProxy struct {
	sync.RWMutex

	// xiaoxiao :
	ReadHandleCMDs     map[string]struct{}
	EnableFollowerRead bool
	// contains filtered or unexported fields
}

RedisProxy is a redis proxy

func NewRedisProxy

func NewRedisProxy(cfg *Cfg) *RedisProxy

NewRedisProxy returns a redisp proxy

func (*RedisProxy) Start

func (p *RedisProxy) Start() error

Start starts the proxy

func (*RedisProxy) Stop

func (p *RedisProxy) Stop()

Stop stop the proxy