topology

Jun 2, 2019

Changes in this version

+ var ErrConnectionClosed = ConnectionError

+ var ErrPoolConnected = PoolError("pool is connected")

+ var ErrPoolDisconnected = PoolError("pool is disconnected or disconnecting")

+ var ErrWrongPool = PoolError("connection does not belong to this pool")

+ type Connection struct

+ func (c *Connection) Address() address.Address

+ func (c *Connection) Close() error

+ func (c *Connection) CompressWireMessage(src, dst []byte) ([]byte, error)

+ func (c *Connection) Description() description.Server

+ func (c *Connection) ID() string

+ func (c *Connection) ReadWireMessage(ctx context.Context, dst []byte) ([]byte, error)

+ func (c *Connection) WriteWireMessage(ctx context.Context, wm []byte) error

+ type ConnectionError struct

+ ConnectionID string

+ Wrapped error

+ func (e ConnectionError) Error() string

+ type ConnectionOption func(*connectionConfig) error

+ func WithAppName(fn func(string) string) ConnectionOption

+ func WithCompressors(fn func([]string) []string) ConnectionOption

+ func WithConnectTimeout(fn func(time.Duration) time.Duration) ConnectionOption

+ func WithDialer(fn func(Dialer) Dialer) ConnectionOption

+ func WithHandshaker(fn func(Handshaker) Handshaker) ConnectionOption

+ func WithIdleTimeout(fn func(time.Duration) time.Duration) ConnectionOption

+ func WithLifeTimeout(fn func(time.Duration) time.Duration) ConnectionOption

+ func WithMonitor(fn func(*event.CommandMonitor) *event.CommandMonitor) ConnectionOption

+ func WithReadTimeout(fn func(time.Duration) time.Duration) ConnectionOption

+ func WithTLSConfig(fn func(*tls.Config) *tls.Config) ConnectionOption

+ func WithWriteTimeout(fn func(time.Duration) time.Duration) ConnectionOption

+ func WithZlibLevel(fn func(*int) *int) ConnectionOption

+ type Dialer interface

+ DialContext func(ctx context.Context, network, address string) (net.Conn, error)

+ var DefaultDialer Dialer = &net.Dialer{}

+ type DialerFunc func(ctx context.Context, network, address string) (net.Conn, error)

+ func (df DialerFunc) DialContext(ctx context.Context, network, address string) (net.Conn, error)

+ type Handshaker = driver.Handshaker

+ type HandshakerFunc = driver.HandshakerFunc

+ type PoolError string

+ func (pe PoolError) Error() string

type Server

+ func (s *Server) ConnectionLegacy(ctx context.Context) (connectionlegacy.Connection, error)

+ func (s *Server) ProcessError(err error)

type Topology

+ func (t *Topology) Kind() description.TopologyKind

+ func (t *Topology) SelectServerLegacy(ctx context.Context, ss description.ServerSelector) (*SelectedServer, error)

+ func (t *Topology) SupportsRetry() bool

Mar 13, 2019

Changes in this version

type Server

+ func (s *Server) ProcessWriteConcernError(err *result.WriteConcernError)

Feb 1, 2019

Changes in this version

type Server

+ func (s *Server) String() string

type Topology

+ func (t *Topology) String() string

Jan 8, 2019

Changes in this version

+ func NewListCollectionsCursor(c command.Cursor) command.Cursor

type Server

+ func (s *Server) BuildLegacyCursor(ns command.Namespace, cursorID int64, batch []bson.Raw, limit int32, ...) (command.Cursor, error)

Dec 6, 2018

Changes in this version

+ var ErrServerClosed = errors.New("server is closed")

+ var ErrServerConnected = errors.New("server is connected")

+ var ErrServerSelectionTimeout = errors.New("server selection timeout")

+ var ErrSubscribeAfterClosed = errors.New("cannot subscribe after close")

+ var ErrTopologyClosed = errors.New("topology is closed")

+ var ErrTopologyConnected = errors.New("topology is connected or connecting")

+ type MonitorMode uint8

+ const AutomaticMode

+ const SingleMode

+ type Option func(*config) error

+ func WithConnString(fn func(connstring.ConnString) connstring.ConnString) Option

+ func WithMode(fn func(MonitorMode) MonitorMode) Option

+ func WithReplicaSetName(fn func(string) string) Option

+ func WithSeedList(fn func(...string) []string) Option

+ func WithServerOptions(fn func(...ServerOption) []ServerOption) Option

+ func WithServerSelectionTimeout(fn func(time.Duration) time.Duration) Option

+ type SelectedServer struct

+ Kind description.TopologyKind

+ func (ss *SelectedServer) Description() description.SelectedServer

+ type Server struct

+ func ConnectServer(ctx context.Context, addr address.Address, opts ...ServerOption) (*Server, error)

+ func NewServer(addr address.Address, opts ...ServerOption) (*Server, error)

+ func (s *Server) BuildCursor(result bson.Raw, clientSession *session.Client, clock *session.ClusterClock, ...) (command.Cursor, error)

+ func (s *Server) Connect(ctx context.Context) error

+ func (s *Server) Connection(ctx context.Context) (connection.Connection, error)

+ func (s *Server) Description() description.Server

+ func (s *Server) Disconnect(ctx context.Context) error

+ func (s *Server) Drain() error

+ func (s *Server) RequestImmediateCheck()

+ func (s *Server) SelectedDescription() description.SelectedServer

+ func (s *Server) Subscribe() (*ServerSubscription, error)

+ type ServerOption func(*serverConfig) error

+ func WithClock(fn func(clock *session.ClusterClock) *session.ClusterClock) ServerOption

+ func WithCompressionOptions(fn func(...string) []string) ServerOption

+ func WithConnectionOptions(fn func(...connection.Option) []connection.Option) ServerOption

+ func WithHeartbeatInterval(fn func(time.Duration) time.Duration) ServerOption

+ func WithHeartbeatTimeout(fn func(time.Duration) time.Duration) ServerOption

+ func WithMaxConnections(fn func(uint16) uint16) ServerOption

+ func WithMaxIdleConnections(fn func(uint16) uint16) ServerOption

+ func WithRegistry(fn func(*bsoncodec.Registry) *bsoncodec.Registry) ServerOption

+ type ServerSubscription struct

+ C <-chan description.Server

+ func (ss *ServerSubscription) Unsubscribe() error

+ type Subscription struct

+ C <-chan description.Topology

+ func (s *Subscription) Unsubscribe() error

+ type Topology struct

+ SessionPool *session.Pool

+ func New(opts ...Option) (*Topology, error)

+ func (t *Topology) Connect(ctx context.Context) error

+ func (t *Topology) Description() description.Topology

+ func (t *Topology) Disconnect(ctx context.Context) error

+ func (t *Topology) FindServer(selected description.Server) (*SelectedServer, error)

+ func (t *Topology) RequestImmediateCheck()

+ func (t *Topology) SelectServer(ctx context.Context, ss description.ServerSelector) (*SelectedServer, error)

+ func (t *Topology) Subscribe() (*Subscription, error)

+ func (t *Topology) SupportsSessions() bool