ApplyFlags applies flags to the given query session.

BuildWriteConcern takes a string and a NodeType indicating the type of node the write concern is intended to be used against, and converts the write concern string argument into an mgo.Safe object that's usable on sessions for that node type.

XXX Requires GODRIVER-492 for legacy server support Assumes that mongo.Database will normalize legacy names to omit database name as required by the Enumerate Collections spec.

GetIndexes returns an iterator to thethe raw index info for a collection by using the listIndexes command if available, or by falling back to querying against system.indexes (pre-3.0 systems).

IsConnectionError returns a boolean indicating if a given error is due to an error in an underlying DB connection (as opposed to some other write failure such as a duplicate key error).

IsNoCmd reeturns true if err indicates a query command is not supported, otherwise, returns false.

IsNoNamespace returns true if err indicates a query resulted in a "NamespaceNotFound" error otherwise, returns false.

NewBSONSource creates a BSONSource with a reusable I/O buffer.

NewBufferedBulkInserter returns an initialized BufferedBulkInserter for writing.

NewBufferlessBSONSource creates a BSONSource without a reusable I/O buffer.

NewSessionProvider constructs a session provider but does not attempt to create the initial session.

Default port for integration tests.

Session flags.

replication errors list the replset name if we are talking to a mongos, so we can only check for this universal prefix.

Query flags.

16MB - maximum BSON document size.

Session flags.

Session flags.

Query flags.

Query flags.

Hard coded socket timeout in seconds.

ApplyOpsResponse represents the response from an 'applyOps' command.

BSONSource reads documents from the underlying io.ReadCloser, Stream which wraps a stream of BSON documents.

BufferedBulkInserter implements a bufio.Writer-like design for queuing up documents and inserting them in bulk when the given doc limit (or max message size) is reached.

DecodedBSONSource reads documents from the underlying io.ReadCloser, Stream which wraps a stream of BSON documents.

DeferredQuery represents a deferred query.

Oplog represents a MongoDB oplog document.

Used to manage database sessions.

CommandRunner exposes functions that can be run against a server XXX Does anything rely on this?.

RawDocSource wraps basic functions for reading a BSON source file.