fix: Xatu Keepalive False (#379)

* feat(output): Allow keepalive config * fix: Fix pointer dereference in config.KeepAlive.Enabled
ethpandaops · Sep 20, 2024 · 6201a63 · 6201a63
1 parent ab67593
commit 6201a63
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/output/xatu/config.go b/pkg/output/xatu/config.go
@@ -20,7 +20,7 @@ type Config struct {
 }
 
 type KeepAliveConfig struct {
-	Enabled bool          `yaml:"enabled" default:"true"`
+	Enabled *bool         `yaml:"enabled" default:"true"`
 	Time    time.Duration `yaml:"time" default:"10s"`
 	Timeout time.Duration `yaml:"timeout" default:"30s"`
 }

diff --git a/pkg/output/xatu/exporter.go b/pkg/output/xatu/exporter.go
@@ -39,7 +39,7 @@ func NewItemExporter(name string, config *Config, log logrus.FieldLogger) (ItemE
 		grpc.WithChainStreamInterceptor(grpc_prometheus.StreamClientInterceptor, retry.StreamClientInterceptor()),
 	}
 
-	if config.KeepAlive.Enabled {
+	if config.KeepAlive.Enabled != nil && *config.KeepAlive.Enabled {
 		log.
 			WithField("keepalive_time", config.KeepAlive.Time).
 			WithField("keepalive_timeout", config.KeepAlive.Timeout).