close influxdb clients (influxdata#993)

influxdb/client.go

@@ -35,6 +35,7 @@ type Client interface {
 type ClientUpdater interface {
 	Client
 	Update(new Config) error
+	Close() error
 }
 
 // BatchPointsConfig is the config data needed to create an instance of the BatchPoints struct
@@ -173,6 +174,10 @@ func (c *HTTPClient) loadHTTPClient() *http.Client {
 	return client
 }
 
+func (c *HTTPClient) Close() error {
+	return nil
+}
+
 // UpdateURLs updates the running list of URLs.
 func (c *HTTPClient) Update(new Config) error {
 	if new.UserAgent == "" {

services/influxdb/service.go

@@ -515,7 +515,7 @@ func (c *influxdbCluster) Close() error {
 	if c.subSyncTicker != nil {
 		c.subSyncTicker.Stop()
 	}
-
+	c.client.Close()
 	return c.closeServices()
 }
 

services/influxdb/service_test.go

@@ -1231,6 +1231,10 @@ type influxDBClient struct {
 	UpdateFunc  func(influxcli.Config) error
 }
 
+func (c influxDBClient) Close() error {
+	return nil
+}
+
 func (c influxDBClient) Ping(ctx context.Context) (time.Duration, string, error) {
 	if c.PingFunc != nil {
 		return c.PingFunc(ctx)