1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
// Copyright (C) MongoDB, Inc. 2017-present.
//
// Licensed under the Apache License, Version 2.0 (the "License"); you may
// not use this file except in compliance with the License. You may obtain
// a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
package mtest
import (
"context"
"fmt"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/x/mongo/driver/connstring"
"go.mongodb.org/mongo-driver/x/mongo/driver/topology"
)
// AuthEnabled returns whether or not the cluster requires auth.
func AuthEnabled() bool {
return testContext.authEnabled
}
// SSLEnabled returns whether or not the cluster requires SSL.
func SSLEnabled() bool {
return testContext.sslEnabled
}
// ClusterTopologyKind returns the topology kind of the cluster under test.
func ClusterTopologyKind() TopologyKind {
return testContext.topoKind
}
// ClusterURI returns the connection string for the cluster.
func ClusterURI() string {
return testContext.connString.Original
}
// Serverless returns whether the test is running against a serverless instance.
func Serverless() bool {
return testContext.serverless
}
// SingleMongosLoadBalancerURI returns the URI for a load balancer fronting a single mongos. This will only be set
// if the cluster is load balanced.
func SingleMongosLoadBalancerURI() string {
return testContext.singleMongosLoadBalancerURI
}
// MultiMongosLoadBalancerURI returns the URI for a load balancer fronting multiple mongoses. This will only be set
// if the cluster is load balanced.
func MultiMongosLoadBalancerURI() string {
return testContext.multiMongosLoadBalancerURI
}
// ClusterConnString returns the parsed ConnString for the cluster.
func ClusterConnString() *connstring.ConnString {
return testContext.connString
}
// GlobalClient returns a Client connected to the cluster configured with read concern majority, write concern majority,
// and read preference primary.
func GlobalClient() *mongo.Client {
return testContext.client
}
// GlobalTopology returns a Topology that's connected to the cluster.
func GlobalTopology() *topology.Topology {
return testContext.topo
}
// ServerVersion returns the server version of the cluster. This assumes that all nodes in the cluster have the same
// version.
func ServerVersion() string {
return testContext.serverVersion
}
// SetFailPoint configures the provided fail point on the cluster under test using the provided Client.
func SetFailPoint(fp FailPoint, client *mongo.Client) error {
admin := client.Database("admin")
if err := admin.RunCommand(context.Background(), fp).Err(); err != nil {
return fmt.Errorf("error creating fail point: %w", err)
}
return nil
}
// SetRawFailPoint configures the fail point represented by the fp parameter on the cluster under test using the
// provided Client
func SetRawFailPoint(fp bson.Raw, client *mongo.Client) error {
admin := client.Database("admin")
if err := admin.RunCommand(context.Background(), fp).Err(); err != nil {
return fmt.Errorf("error creating fail point: %w", err)
}
return nil
}
|
