service

Documentation

Index

• Variables
• type DbConnector
  • func (dc *DbConnector) Listen(localPort int) (net.Listener, error)
• type MongoConnector
  • func NewMongoBalancer(username, password string, addrs []string) *MongoConnector
  • func (m *MongoConnector) CheckHealth(addr string) bool
  • func (m *MongoConnector) ChooseBackEnd() string
• type Proxy
  • func NewProxy() *Proxy
  • func (p *Proxy) AddConnection(c string, upStream, downStram net.Conn)
  • func (p *Proxy) Close()
  • func (p *Proxy) DeleteConnection(c string)
• 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(masterName 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 MongoConnector

type MongoConnector struct {
	Username string
	Password string
	// contains filtered or unexported fields
}

func NewMongoBalancer

func NewMongoBalancer(username, password string, addrs []string) *MongoConnector

func (*MongoConnector) CheckHealth

func (m *MongoConnector) CheckHealth(addr string) bool

func (*MongoConnector) ChooseBackEnd

func (m *MongoConnector) ChooseBackEnd() string

type Proxy

type Proxy struct {
	Tracks map[string]track
	// contains filtered or unexported fields
}

func NewProxy

func NewProxy() *Proxy

func (*Proxy) AddConnection

func (p *Proxy) AddConnection(c string, upStream, downStram net.Conn)

func (*Proxy) Close

func (p *Proxy) Close()

func (*Proxy) DeleteConnection

func (p *Proxy) DeleteConnection(c string)

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(masterName string) (string, error)