@@ -13,8 +13,9 @@ import (
1313)
1414
1515// Helper function to create a test SourceConn with pgxmock
16- func createTestSourceConn () (* sources.SourceConn , pgxmock.PgxPoolIface , error ) {
16+ func createTestSourceConn (t * testing. T ) (* sources.SourceConn , pgxmock.PgxPoolIface ) {
1717 mock , err := pgxmock .NewPool ()
18+ require .NoError (t , err )
1819 md := & sources.SourceConn {
1920 Conn : mock ,
2021 Source : sources.Source {Name : "testdb" },
@@ -23,7 +24,7 @@ func createTestSourceConn() (*sources.SourceConn, pgxmock.PgxPoolIface, error) {
2324 ChangeState : make (map [string ]map [string ]string ),
2425 },
2526 }
26- return md , mock , err
27+ return md , mock
2728}
2829
2930func TestTryCreateMetricsFetchingHelpers (t * testing.T ) {
@@ -74,8 +75,7 @@ func TestDetectSprocChanges(t *testing.T) {
7475 }
7576
7677 // Create single connection and reaper to maintain state across calls
77- md , mock , err := createTestSourceConn ()
78- assert .NoError (t , err )
78+ md , mock := createTestSourceConn (t )
7979 defer mock .Close ()
8080
8181 reaper := & Reaper {
@@ -152,8 +152,7 @@ func TestDetectTableChanges(t *testing.T) {
152152 }
153153
154154 // Create single connection and reaper to maintain state across calls
155- md , mock , err := createTestSourceConn ()
156- assert .NoError (t , err )
155+ md , mock := createTestSourceConn (t )
157156 defer mock .Close ()
158157
159158 reaper := & Reaper {
@@ -233,8 +232,7 @@ func TestDetectIndexChanges(t *testing.T) {
233232 }
234233
235234 // Create single connection and reaper to maintain state across calls
236- md , mock , err := createTestSourceConn ()
237- assert .NoError (t , err )
235+ md , mock := createTestSourceConn (t )
238236
239237 reaper := & Reaper {
240238 measurementCh : make (chan metrics.MeasurementEnvelope , 10 ),
@@ -313,8 +311,7 @@ func TestDetectPrivilegeChanges(t *testing.T) {
313311 }
314312
315313 // Create single connection and reaper to maintain state across calls
316- md , mock , err := createTestSourceConn ()
317- assert .NoError (t , err )
314+ md , mock := createTestSourceConn (t )
318315
319316 reaper := & Reaper {
320317 measurementCh : make (chan metrics.MeasurementEnvelope , 10 ),
0 commit comments