revert: "feat(mqtt): enable dialer pool for everyone (#4565)" (#4582)

This reverts commit dc08c57.
influxdata · Mar 22, 2022 · 5e19bfa · 5e19bfa
1 parent 1f921a2
commit 5e19bfa
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 3 deletions.
diff --git a/dependencies/mqtt/mqtt.go b/dependencies/mqtt/mqtt.go
@@ -12,6 +12,7 @@ import (
 	"github.com/influxdata/flux/codes"
 	"github.com/influxdata/flux/dependency"
 	"github.com/influxdata/flux/internal/errors"
+	"github.com/influxdata/flux/internal/feature"
 )
 
 const (
@@ -25,9 +26,11 @@ const clientKey key = iota
 
 // Inject will inject this Dialer into the dependency chain.
 func Inject(ctx context.Context, dialer Dialer) context.Context {
-	pool := newPoolDialer(dialer)
-	dependency.OnFinish(ctx, pool)
-	dialer = pool
+	if feature.MqttPoolDialer().Enabled(ctx) {
+		pool := newPoolDialer(dialer)
+		dependency.OnFinish(ctx, pool)
+		dialer = pool
+	}
 	return context.WithValue(ctx, clientKey, dialer)
 }
 

diff --git a/internal/feature/flags.go b/internal/feature/flags.go
diff --git a/internal/feature/flags.yml b/internal/feature/flags.yml
@@ -34,6 +34,12 @@
   default: false
   contact: Jonathan Sternberg
 
+- name: MQTT Pool Dialer
+  description: MQTT pool dialer
+  key: mqttPoolDialer
+  default: false
+  contact: Jonathan Sternberg
+
 - name: Vectorized Map
   description: Enables the version of map that supports vectorized functions
   key: vectorizedMap