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"`
	WatcherHeartbeatSec int      `json:"watcherHeartbeatSec"`
	PDAddrs             []string `json:"pdAddrs"`
	MaxRetries          int      `json:"maxRetries"`
	RetryDuration       int64    `json:"retryDuration"`
	WorkerCount         uint64   `json:"workerCount"`
	SupportCMDs         []string `json:"supportCMDs"`
}

Cfg returns cfg for proxy

func GetCfg

func GetCfg() *Cfg

GetCfg get cfg from command

type RedisProxy

type RedisProxy struct {
	sync.RWMutex
	// 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