connection

package

Go to main page

Versions in this module

v1

v1.0.4

Jul 9, 2019 GO-2021-0112

GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

v1.0.3

Jun 6, 2019 GO-2021-0112

GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

v1.0.2

May 16, 2019 GO-2021-0112

GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

v1.0.1

Apr 18, 2019 GO-2021-0112

GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

v1.0.0

Mar 13, 2019 GO-2021-0112

GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

type Option

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

v1.0.0-rc2

Mar 7, 2019 GO-2021-0112

GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

v1.0.0-rc1

Feb 22, 2019 GO-2021-0112

GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

v0

v0.3.0

Feb 1, 2019 GO-2021-0112

GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

v0.2.0

Jan 8, 2019 GO-2021-0112

GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

v0.1.0

Dec 6, 2018 GO-2021-0112

GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ var ErrConnectionClosed = Error

+ var ErrPoolClosed = PoolError("pool is closed")

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

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

+ var ErrSizeLargerThanCapacity = PoolError("size is larger than capacity")

+ type Addr string

+ func (Addr) Canonicalize() Addr

+ func (Addr) Network() string

+ func (Addr) String() string

+ type Connection interface

+ Alive func() bool

+ Close func() error

+ Expired func() bool

+ ID func() string

+ ReadWireMessage func(context.Context) (wiremessage.WireMessage, error)

+ WriteWireMessage func(context.Context, wiremessage.WireMessage) error

+ func New(ctx context.Context, addr address.Address, opts ...Option) (Connection, *description.Server, error)

+ 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 Error struct

+ ConnectionID string

+ Wrapped error

+ func (e Error) Error() string

+ type Handler interface

+ HandleConnection func(Connection)

+ type Handshaker interface

+ Handshake func(context.Context, address.Address, wiremessage.ReadWriter) (description.Server, error)

+ type HandshakerFunc func(context.Context, address.Address, wiremessage.ReadWriter) (description.Server, error)

+ func (hf HandshakerFunc) Handshake(ctx context.Context, addr address.Address, rw wiremessage.ReadWriter) (description.Server, error)

+ type Listener interface

+ Accept func() (Connection, error)

+ Addr func() Addr

+ Close func() error

+ func Listen(network, address string) (Listener, error)

+ type NetworkError struct

+ ConnectionID string

+ Wrapped error

+ func (ne NetworkError) Error() string

+ type Option func(*config) error

+ func WithAppName(fn func(string) string) Option

+ func WithCompressors(fn func([]compressor.Compressor) []compressor.Compressor) Option

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

+ func WithDialer(fn func(Dialer) Dialer) Option

+ func WithHandshaker(fn func(Handshaker) Handshaker) Option

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

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

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

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

+ func WithTLSConfig(fn func(*TLSConfig) *TLSConfig) Option

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

+ type Pool interface

+ Connect func(context.Context) error

+ Disconnect func(context.Context) error

+ Drain func() error

+ Get func(context.Context) (Connection, *description.Server, error)

+ func NewPool(addr address.Address, size, capacity uint64, opts ...Option) (Pool, error)

+ type PoolError string

+ func (pe PoolError) Error() string

+ type Proxy struct

+ Pool Pool

+ Processor wiremessage.Transformer

+ func (*Proxy) HandleConnection(Connection)

+ type Server struct

+ Addr Addr

+ Handler Handler

+ func (*Server) ListenAndServe() error

+ func (*Server) Serve(Listener) error

+ func (*Server) Shutdown(context.Context) error

+ type TLSConfig struct

+ func NewTLSConfig() *TLSConfig

+ func (c *TLSConfig) AddCACertFromFile(file string) error

+ func (c *TLSConfig) AddClientCertFromFile(clientFile string) (string, error)

+ func (c *TLSConfig) Clone() *TLSConfig

+ func (c *TLSConfig) SetClientCertDecryptPassword(f func() string)

+ func (c *TLSConfig) SetInsecure(allow bool)

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