Merge pull request #263 from sknot-rh/logging

Set glog levels to control verbosity

kafka_exporter.go

@@ -33,6 +33,12 @@ const (
 	clientID  = "kafka_exporter"
 )
 
+const (
+	INFO = 0
+	DEBUG = 1
+	TRACE = 2
+)
+
 var (
 	clusterBrokers                     *prometheus.Desc
 	topicPartitions                    *prometheus.Desc
@@ -225,7 +231,7 @@ func NewExporter(opts kafkaOpts, topicFilter string, groupFilter string) (*Expor
 	}
 
 	if opts.useZooKeeperLag {
-		glog.Infoln("Using zookeeper lag, so connecting to zookeeper")
+		glog.V(DEBUG).Infoln("Using zookeeper lag, so connecting to zookeeper")
 		zookeeperClient, err = kazoo.NewKazoo(opts.uriZookeeper, nil)
 		if err != nil {
 			return nil, errors.Wrap(err, "error connecting to zookeeper")
@@ -245,7 +251,7 @@ func NewExporter(opts kafkaOpts, topicFilter string, groupFilter string) (*Expor
 		return nil, errors.Wrap(err, "Error Init Kafka Client")
 	}
 
-	glog.Infoln("Done Init Clients")
+	glog.V(TRACE).Infoln("Done Init Clients")
 	// Init our exporter.
 	return &Exporter{
 		client:                  client,
@@ -309,7 +315,7 @@ func (e *Exporter) Collect(ch chan<- prometheus.Metric) {
 		e.sgWaitCh = make(chan struct{})
 		go e.collectChans(e.sgWaitCh)
 	} else {
-		glog.Info("concurrent calls detected, waiting for first to finish")
+		glog.V(TRACE).Info("concurrent calls detected, waiting for first to finish")
 	}
 	// Put in another variable to ensure not overwriting it in another Collect once we wait
 	waiter := e.sgWaitCh
@@ -357,7 +363,7 @@ func (e *Exporter) collect(ch chan<- prometheus.Metric) {
 	now := time.Now()
 
 	if now.After(e.nextMetadataRefresh) {
-		glog.Info("Refreshing client metadata")
+		glog.V(DEBUG).Info("Refreshing client metadata")
 
 		if err := e.client.RefreshMetadata(); err != nil {
 			glog.Errorf("Cannot refresh topics, using cached data: %v", err)
@@ -628,7 +634,7 @@ func (e *Exporter) collect(ch chan<- prometheus.Metric) {
 		}
 	}
 
-	glog.Info("Fetching consumer group metrics")
+	glog.V(DEBUG).Info("Fetching consumer group metrics")
 	if len(e.client.Brokers()) > 0 {
 		for _, broker := range e.client.Brokers() {
 			wg.Add(1)
@@ -730,8 +736,8 @@ func setup(
 	flag.Parse()
 	defer glog.Flush()
 
-	glog.Infoln("Starting kafka_exporter", version.Info())
-	glog.Infoln("Build context", version.BuildContext())
+	glog.V(INFO).Infoln("Starting kafka_exporter", version.Info())
+	glog.V(DEBUG).Infoln("Build context", version.BuildContext())
 
 	clusterBrokers = prometheus.NewDesc(
 		prometheus.BuildFQName(namespace, "", "brokers"),
@@ -847,7 +853,7 @@ func setup(
 	})
 
 	if opts.serverUseTLS {
-		glog.Infoln("Listening on HTTPS", listenAddress)
+		glog.V(INFO).Infoln("Listening on HTTPS", listenAddress)
 
 		_, err := CanReadCertAndKey(opts.serverTlsCertFile, opts.serverTlsKeyFile)
 		if err != nil {
@@ -890,7 +896,7 @@ func setup(
 		}
 		glog.Fatal(server.ListenAndServeTLS(opts.serverTlsCertFile, opts.serverTlsKeyFile))
 	} else {
-		glog.Infoln("Listening on HTTP", listenAddress)
+		glog.V(INFO).Infoln("Listening on HTTP", listenAddress)
 		glog.Fatal(http.ListenAndServe(listenAddress, nil))
 	}
 }