Skip to content

Commit f44538d

Browse files
committed
Clean up autoDiscoverDatabases in the new collector
Signed-off-by: Joe Adams <[email protected]>
1 parent f0f0f4d commit f44538d

File tree

3 files changed

+3
-22
lines changed

3 files changed

+3
-22
lines changed

cmd/postgres_exporter/main.go

-1
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,6 @@ func main() {
119119
logger,
120120
dsn,
121121
[]string{},
122-
collector.WithAutoDiscoverDatabases(*autoDiscoverDatabases),
123122
)
124123
if err != nil {
125124
level.Error(logger).Log("msg", "Failed to create PostgresCollector", "err", err.Error())

collector/collector.go

-17
Original file line numberDiff line numberDiff line change
@@ -87,10 +87,6 @@ type PostgresCollector struct {
8787
logger log.Logger
8888

8989
servers map[string]*server
90-
91-
// autoDiscoverDatabases will cause the collector to query the database
92-
// to find other servers and also scrape them.
93-
autoDiscoverDatabases bool
9490
}
9591

9692
type Option func(*PostgresCollector) error
@@ -146,12 +142,6 @@ func NewPostgresCollector(logger log.Logger, dsns []string, filters []string, op
146142
if err != nil {
147143
return nil, err
148144
}
149-
// Manually provided servers are always classified as "primary"
150-
s.isPrimary = true
151-
152-
// TODO(@sysadmind): We need to discover the downstream servers and add them here.
153-
// if p.autoDiscoverDatabases {
154-
// }
155145

156146
servers[dsn] = s
157147
}
@@ -161,13 +151,6 @@ func NewPostgresCollector(logger log.Logger, dsns []string, filters []string, op
161151
return p, nil
162152
}
163153

164-
func WithAutoDiscoverDatabases(discover bool) Option {
165-
return func(p *PostgresCollector) error {
166-
p.autoDiscoverDatabases = discover
167-
return nil
168-
}
169-
}
170-
171154
// Describe implements the prometheus.Collector interface.
172155
func (p PostgresCollector) Describe(ch chan<- *prometheus.Desc) {
173156
ch <- scrapeDurationDesc

collector/server.go

+3-4
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,9 @@ import (
2222
)
2323

2424
type server struct {
25-
dsn string
26-
name string
27-
db *sql.DB
28-
isPrimary bool // Certain queries are only run on the primary server
25+
dsn string
26+
name string
27+
db *sql.DB
2928
}
3029

3130
func makeServer(dsn string) (*server, error) {

0 commit comments

Comments
 (0)