46
)
47
48
>
func setUpPostgreSQLTest(t *testing.T, pluginName string, connectAttrs map[string]string) (PostgreSQLTestData, func()) {
postgresql_test_util.go
49
>
var testData PostgreSQLTestData
50
>
testData.Cfg = NewPostgreSQLConfig(pluginName, connectAttrs)
51
>
testData.Logger = log.NewZapLogger(zaptest.NewLogger(t))
52
>
mh := metricstest.NewCaptureHandler()
53
>
testData.Metrics = mh.StartCapture()
54
>
SetupPostgreSQLDatabase(t, testData.Cfg)
55
>
SetupPostgreSQLSchema(t, testData.Cfg)
56
>
57
>
testData.Factory = sql.NewFactory(
58
>
*testData.Cfg,
59
>
resolver.NewNoopResolver(),
60
>
testPostgreSQLClusterName,
61
>
testData.Logger,
62
>
mh,
63
>
serialization.NewSerializer(),
64
>
)
65
>
66
>
tearDown := func() {
67
>
testData.Factory.Close()
68
>
mh.StopCapture(testData.Metrics)
69
>
TearDownPostgreSQLDatabase(t, testData.Cfg)
70
>
}
71
73
}
74