allow for subscriptions to be disabled

CHANGELOG.md

@@ -8,6 +8,7 @@
 
 - [#360](https://github.com/influxdata/kapacitor/pull/360): Forking tasks by measurement in order to improve performance
 - [#386](https://github.com/influxdata/kapacitor/issues/386): Adds official Go HTTP client package.
+- [#399](https://github.com/influxdata/kapacitor/issues/399): Allow disabling of subscriptions.
 
 ### Bugfixes
 

services/influxdb/config.go

@@ -32,6 +32,7 @@ type Config struct {
 	InsecureSkipVerify bool `toml:"insecure-skip-verify"`
 
 	Timeout               toml.Duration       `toml:"timeout"`
+	DisableSubscriptions  bool                `toml:"disable-subscriptions"`
 	Subscriptions         map[string][]string `toml:"subscriptions"`
 	ExcludedSubscriptions map[string][]string `toml:"excluded-subscriptions"`
 	UDPBuffer             int                 `toml:"udp-buffer"`

services/influxdb/service.go

@@ -90,6 +90,7 @@ func NewService(configs []Config, defaultInfluxDB int, hostname string, l *log.L
 			startupTimeout: time.Duration(c.StartUpTimeout),
 			clusterID:      clusterID,
 			subName:        subName,
+			disableSubs:    c.DisableSubscriptions,
 		}
 		if defaultInfluxDB == i {
 			defaultInfluxDBName = c.Name
@@ -148,6 +149,7 @@ type influxdb struct {
 	udpBuffer      int
 	udpReadBuffer  int
 	startupTimeout time.Duration
+	disableSubs    bool
 
 	clusterID string
 	subName   string
@@ -177,7 +179,10 @@ type subInfo struct {
 }
 
 func (s *influxdb) Open() error {
-	return s.linkSubscriptions()
+	if !s.disableSubs {
+		return s.linkSubscriptions()
+	}
+	return nil
 }
 
 func (s *influxdb) Close() error {