servers

Apr 12, 2018

Changes in this version

+ type Manager struct

+ func New(logger *log.Logger, shutdownCh chan struct{}, connPoolPinger Pinger) (m *Manager)

+ func (m *Manager) FindServer() *Server

+ func (m *Manager) GetServers() Servers

+ func (m *Manager) NotifyFailedServer(s *Server)

+ func (m *Manager) NumNodes() int32

+ func (m *Manager) NumServers() int

+ func (m *Manager) RebalanceServers()

+ func (m *Manager) ResetRebalanceTimer()

+ func (m *Manager) SetNumNodes(n int32)

+ func (m *Manager) SetServers(servers Servers) bool

+ func (m *Manager) Start()

+ type Pinger interface

+ Ping func(addr net.Addr) error

+ type Server struct

+ Addr net.Addr

+ DC string

+ func (s *Server) Copy() *Server

+ func (s *Server) Equal(o *Server) bool

+ func (s *Server) String() string

+ type Servers []*Server

+ func (s Servers) Equal(o Servers) bool

+ func (s Servers) Sort()

+ func (s Servers) String() string