topology

package

Go to main page

Versions in this module

v1

v1.0.0

Mar 13, 2019

Changes in this version

type Server

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

v1.0.0-rc2

Mar 7, 2019

v1.0.0-rc1

Feb 22, 2019

v0

v0.3.0

Feb 1, 2019

Changes in this version

type Server

+ func (s *Server) String() string

type Topology

+ func (t *Topology) String() string

v0.2.0

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)

v0.1.0

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL