removed dupllicate code

middleware-labs · Jun 11, 2024 · e2d37fd · e2d37fd
1 parent 49981b7
commit e2d37fd
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 23 deletions.
diff --git a/receiver/postgresqlreceiver/client.go b/receiver/postgresqlreceiver/client.go
@@ -45,7 +45,6 @@ type client interface {
 	getLatestWalAgeSeconds(ctx context.Context) (int64, error)
 	getMaxConnections(ctx context.Context) (int64, error)
 	getIndexStats(ctx context.Context, database string) (map[indexIdentifer]indexStat, error)
-	getActiveConnections(ctx context.Context) (int64, error)
 	listDatabases(ctx context.Context) ([]string, error)
 	getRowStats(ctx context.Context) ([]RowStats, error)
 	getQueryStats(ctx context.Context) ([]queryStats, error)
@@ -659,14 +658,6 @@ func (c *postgreSQLClient) getBufferHit(ctx context.Context) ([]BufferHit, error
 	return bh, errors
 }
 
-func (c *postgreSQLClient) getActiveConnections(ctx context.Context) (int64, error) {
-	query := `SELECT COUNT(*) FROM pg_stat_activity WHERE state = 'active';`
-	row := c.client.QueryRowContext(ctx, query)
-	var activeConns int64
-	err := row.Scan(&activeConns)
-	return activeConns, err
-}
-
 func (c *postgreSQLClient) getVersionString(ctx context.Context) (string, error) {
 	var version string
 	err := c.client.QueryRowContext(ctx, "SHOW server_version").Scan(&version)

diff --git a/receiver/postgresqlreceiver/scraper.go b/receiver/postgresqlreceiver/scraper.go
@@ -397,20 +397,6 @@ func (p *postgreSQLScraper) collectQueryPerfStats(
 	}
 }
 
-func (p *postgreSQLScraper) collectActiveConnections(
-	ctx context.Context,
-	now pcommon.Timestamp,
-	client client,
-	errs *errsMux,
-) {
-	ac, err := client.getActiveConnections(ctx)
-	if err != nil {
-		errs.addPartial(err)
-		return
-	}
-	p.mb.RecordPostgresqlConnectionCountDataPoint(now, ac)
-}
-
 func (p *postgreSQLScraper) collectBufferHits(
 	ctx context.Context,
 	now pcommon.Timestamp,