service

Documentation

Index

• Variables
• type DbConnector
  • func (dc *DbConnector) Listen(localPort int) (net.Listener, error)
• type ProxyBridge
  • func (pb *ProxyBridge) Proxy(clientConn, redisConn net.Conn)
• type RedisConnector
  • func NewRedisConnector(requestTimeout int) *RedisConnector
  • func (rc *RedisConnector) Connect(addr string) (net.Conn, error)
  • func (rc *RedisConnector) Ping(addr string) error
• type SentinelConnector
  • func NewSentinelConnector(sentinelAddrList []string, requestTimeout int) *SentinelConnector
  • func (sc *SentinelConnector) AddSentinelClient(sentinelAddr string)
  • func (sc *SentinelConnector) GetActualRedisAddr(dbName string) (string, error)

Variables

var AllSentinelsBrokenErr = errors.New("all sentinels unavailable")

Types

type DbConnector

type DbConnector struct{}

func (*DbConnector) Listen

func (dc *DbConnector) Listen(localPort int) (net.Listener, error)

type ProxyBridge

type ProxyBridge struct{}

func (*ProxyBridge) Proxy

func (pb *ProxyBridge) Proxy(clientConn, redisConn net.Conn)

type RedisConnector

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

func NewRedisConnector

func NewRedisConnector(requestTimeout int) *RedisConnector

func (*RedisConnector) Connect

func (rc *RedisConnector) Connect(addr string) (net.Conn, error)

func (*RedisConnector) Ping

func (rc *RedisConnector) Ping(addr string) error

type SentinelConnector

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

func NewSentinelConnector

func NewSentinelConnector(sentinelAddrList []string, requestTimeout int) *SentinelConnector

func (*SentinelConnector) AddSentinelClient

func (sc *SentinelConnector) AddSentinelClient(sentinelAddr string)

func (*SentinelConnector) GetActualRedisAddr

func (sc *SentinelConnector) GetActualRedisAddr(dbName string) (string, error)