[receiver/redisreceiver] add scraper shutdown

receiver/redisreceiver/client.go

@@ -25,6 +25,8 @@ type client interface {
 	// line delimiter
 	// redis lines are delimited by \r\n, files (for testing) by \n
 	delimiter() string
+	// close
+	close() error
 }
 
 // Wraps a real Redis client, implements `client` interface.
@@ -50,3 +52,8 @@ func (c *redisClient) delimiter() string {
 func (c *redisClient) retrieveInfo() (string, error) {
 	return c.client.Info("all").Result()
 }
+
+// close.
+func (c *redisClient) close() error {
+	return c.client.Close()
+}

receiver/redisreceiver/client_test.go

@@ -44,6 +44,10 @@ func (fakeClient) retrieveInfo() (string, error) {
 	return readFile("info")
 }
 
+func (fakeClient) close() error {
+	return nil
+}
+
 func readFile(fname string) (string, error) {
 	file, err := os.ReadFile(filepath.Join("testdata", fname+".txt"))
 	if err != nil {

receiver/redisreceiver/redis_scraper.go

@@ -34,6 +34,7 @@ import (
 // Runs intermittently, fetching info from Redis, creating metrics/datapoints,
 // and feeding them to a metricsConsumer.
 type redisScraper struct {
+	client   client
 	redisSvc *redisSvc
 	settings component.TelemetrySettings
 	mb       *metadata.MetricsBuilder
@@ -58,11 +59,23 @@ func newRedisScraper(cfg *Config, settings receiver.CreateSettings) (scraperhelp
 
 func newRedisScraperWithClient(client client, settings receiver.CreateSettings, cfg *Config) (scraperhelper.Scraper, error) {
 	rs := &redisScraper{
+		client:   client,
 		redisSvc: newRedisSvc(client),
 		settings: settings.TelemetrySettings,
 		mb:       metadata.NewMetricsBuilder(cfg.Metrics, settings),
 	}
-	return scraperhelper.NewScraper(typeStr, rs.Scrape)
+	return scraperhelper.NewScraper(
+		typeStr,
+		rs.Scrape,
+		scraperhelper.WithShutdown(rs.shutdown),
+	)
+}
+
+func (rs *redisScraper) shutdown(context.Context) error {
+	if rs.client != nil {
+		return rs.client.close()
+	}
+	return nil
 }
 
 // Scrape is called periodically, querying Redis and building Metrics to send to