Versions in this module Expand all Collapse all v0 v0.0.2 Mar 6, 2018 v0.0.1 Feb 13, 2018 Changes in this version + var ErrServerClosed = errors.New("server is closed") + type Monitor struct + func StartMonitor(addr model.Addr, opts ...Option) (*Monitor, error) + func (m *Monitor) Addr() model.Addr + func (m *Monitor) RequestImmediateCheck() + func (m *Monitor) Stop() + func (m *Monitor) Subscribe() (<-chan *model.Server, func(), error) + type Option func(*config) error + func WithConnectionOpener(opener conn.Opener) Option + func WithConnectionOptions(opts ...conn.Option) Option + func WithHeartbeatInterval(interval time.Duration) Option + func WithHeartbeatTimeout(timeout time.Duration) Option + func WithMaxConnections(max uint16) Option + func WithMaxIdleConnections(size uint16) Option + func WithMoreConnectionOptions(opts ...conn.Option) Option + func WithWrappedConnectionOpener(wrapper func(conn.Opener) conn.Opener) Option + type Server struct + func New(addr model.Addr, opts ...Option) (*Server, error) + func NewWithMonitor(monitor *Monitor, opts ...Option) (*Server, error) + func (s *Server) Close() error + func (s *Server) Connection(ctx context.Context) (conn.Connection, error) + func (s *Server) Model() *model.Server
Go to main page