package testutil

import "go.mongodb.org/mongo-driver/internal/testutil"

Index ¶

• func AddCompressorToURI(uri string) string
• func AddOptionsToURI(uri string, opts ...string) string
• func AddTLSConfigToURI(uri string) string
• func AddTestServerAPIVersion(opts *options.ClientOptions)
• func AutoInsertDocs(t *testing.T, writeConcern *writeconcern.WriteConcern, docs ...bsoncore.Document)
• func ColName(t *testing.T) string
• func CompareVersions(t *testing.T, v1 string, v2 string) int
• func ConnString(t *testing.T) connstring.ConnString
• func DBName(t *testing.T) string
• func DropCollection(t *testing.T, dbname, colname string)
• func GetConnString() (connstring.ConnString, error)
• func GetDBName(cs connstring.ConnString) string
• func InsertDocs(t *testing.T, dbname, colname string, writeConcern *writeconcern.WriteConcern, docs ...bsoncore.Document)
• func MonitoredTopology(t *testing.T, dbName string, monitor *event.CommandMonitor) *topology.Topology
• func RunCommand(t *testing.T, s driver.Server, db string, cmd bsoncore.Document) (bsoncore.Document, error)
• func Topology(t *testing.T) *topology.Topology
• func TopologyWithConnString(t *testing.T, cs connstring.ConnString) *topology.Topology

Functions ¶

func AddCompressorToURI ¶

func AddCompressorToURI(uri string) string

AddCompressorToURI checks for the environment variable indicating that the tests are being run with compression enabled. If so, it returns a new URI with the necessary configuration

func AddOptionsToURI ¶

func AddOptionsToURI(uri string, opts ...string) string

AddOptionsToURI appends connection string options to a URI.

func AddTLSConfigToURI ¶

func AddTLSConfigToURI(uri string) string

AddTLSConfigToURI checks for the environmental variable indicating that the tests are being run on an SSL-enabled server, and if so, returns a new URI with the necessary configuration.

func AddTestServerAPIVersion ¶

func AddTestServerAPIVersion(opts *options.ClientOptions)

AddTestServerAPIVersion adds the latest server API version in a ServerAPIOptions to passed-in opts.

func AutoInsertDocs ¶

func AutoInsertDocs(t *testing.T, writeConcern *writeconcern.WriteConcern, docs ...bsoncore.Document)

AutoInsertDocs inserts the docs into the test cluster.

func ColName ¶

func ColName(t *testing.T) string

ColName gets a collection name that should be unique to the currently executing test.

func CompareVersions ¶

func CompareVersions(t *testing.T, v1 string, v2 string) int

CompareVersions compares two version number strings (i.e. positive integers separated by periods). Comparisons are done to the lesser precision of the two versions. For example, 3.2 is considered equal to 3.2.11, whereas 3.2.0 is considered less than 3.2.11.

Returns a positive int if version1 is greater than version2, a negative int if version1 is less than version2, and 0 if version1 is equal to version2.

func ConnString ¶

func ConnString(t *testing.T) connstring.ConnString

ConnString gets the globally configured connection string.

func DBName ¶

func DBName(t *testing.T) string

DBName gets the globally configured database name.

func DropCollection ¶

func DropCollection(t *testing.T, dbname, colname string)

DropCollection drops the collection in the test cluster.

func GetConnString ¶

func GetConnString() (connstring.ConnString, error)

func GetDBName ¶

func GetDBName(cs connstring.ConnString) string

func InsertDocs ¶

func InsertDocs(t *testing.T, dbname, colname string, writeConcern *writeconcern.WriteConcern, docs ...bsoncore.Document)

InsertDocs inserts the docs into the test cluster.

func MonitoredTopology ¶

func MonitoredTopology(t *testing.T, dbName string, monitor *event.CommandMonitor) *topology.Topology

MonitoredTopology returns a new topology with the command monitor attached

func RunCommand ¶

func RunCommand(t *testing.T, s driver.Server, db string, cmd bsoncore.Document) (bsoncore.Document, error)

RunCommand runs an arbitrary command on a given database of target server

func Topology ¶

func Topology(t *testing.T) *topology.Topology

Topology gets the globally configured topology.

func TopologyWithConnString ¶

func TopologyWithConnString(t *testing.T, cs connstring.ConnString) *topology.Topology

TopologyWithConnString takes a connection string and returns a connected topology, or else bails out of testing

Source Files ¶

config.go ops.go

Directories ¶