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 AutoCreateIndexes(t *testing.T, keys []string)
• func AutoDropCollection(t *testing.T)
• func AutoInsertDocs(t *testing.T, writeConcern *writeconcern.WriteConcern, docs ...*bson.Document)
• func ColName(t *testing.T) string
• func ConnString(t *testing.T) connstring.ConnString
• func DBName(t *testing.T) string
• func DisableMaxTimeFailPoint(t *testing.T, s *topology.Server)
• func DropCollection(t *testing.T, dbname, colname string)
• func EnableMaxTimeFailPoint(t *testing.T, s *topology.Server) error
• func GetConnString() (connstring.ConnString, error)
• func GetDBName(cs connstring.ConnString) string
• func InsertDocs(t *testing.T, dbname, colname string, writeConcern *writeconcern.WriteConcern, docs ...*bson.Document)
• func Integration(t *testing.T)
• func MonitoredTopology(t *testing.T, monitor *event.CommandMonitor) *topology.Topology
• func RunCommand(t *testing.T, s *topology.Server, db string, b *bson.Document) (bson.Reader, 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 AutoCreateIndexes ¶

func AutoCreateIndexes(t *testing.T, keys []string)

AutoCreateIndexes creates an index in the test cluster.

func AutoDropCollection ¶

func AutoDropCollection(t *testing.T)

AutoDropCollection drops the collection in the test cluster.

func AutoInsertDocs ¶

func AutoInsertDocs(t *testing.T, writeConcern *writeconcern.WriteConcern, docs ...*bson.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 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 DisableMaxTimeFailPoint ¶

func DisableMaxTimeFailPoint(t *testing.T, s *topology.Server)

DisableMaxTimeFailPoint turns off the max time fail point in the test cluster.

func DropCollection ¶

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

DropCollection drops the collection in the test cluster.

func EnableMaxTimeFailPoint ¶

func EnableMaxTimeFailPoint(t *testing.T, s *topology.Server) error

EnableMaxTimeFailPoint turns on the max time fail point 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 ...*bson.Document)

InsertDocs inserts the docs into the test cluster.

func Integration ¶

func Integration(t *testing.T)

Integration should be called at the beginning of integration tests to ensure that they are skipped if integration testing is turned off.

func MonitoredTopology ¶

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

MonitoredTopology gets the globally configured topology and attaches a command monitor.

func RunCommand ¶

func RunCommand(t *testing.T, s *topology.Server, db string, b *bson.Document) (bson.Reader, 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 ¶