Add new env var LOG_LEVEL to set logging levels

deploy-all-in-one.yaml

@@ -218,6 +218,9 @@ spec:
           env:
             - name: CONFIG_PATH
               value: "/config/"
+            # set one of the log levels- info, warn, debug, error, fatal, panic
+            - name: LOG_LEVEL
+              value: "info"
       volumes:
         - name: config-volume
           configMap:

helm/botkube/templates/deployment.yaml

@@ -34,6 +34,8 @@ spec:
           env:
             - name: CONFIG_PATH
               value: "/config/"
+            - name: LOG_LEVEL
+              value: {{ .Values.logLevel | quote }}
       volumes:
         - name: config-volume
           configMap:

helm/botkube/values.yaml

@@ -12,6 +12,9 @@ image:
 nameOverride: ""
 fullnameOverride: ""
 
+# set one of the log levels- info, warn, debug, error, fatal, panic
+logLevel: info
+
 config:
   ## Resources you want to watch
   resources:

pkg/controller/controller.go

@@ -88,7 +88,7 @@ func RegisterInformers(c *config.Config) {
 
 	// Register informers for k8s events
 	if len(c.Events.Types) > 0 {
-		log.Logger.Info("Registering kubernetes events informer")
+		log.Logger.Infof("Registering kubernetes events informer for types: %+v", c.Events.Types)
 		watchlist := cache.NewListWatchFromClient(
 			utils.KubeClient.CoreV1().RESTClient(), "events", apiV1.NamespaceAll, fields.Everything())
 
@@ -112,7 +112,7 @@ func RegisterInformers(c *config.Config) {
 					// Filter and forward
 					if (utils.AllowedEventKindsMap[utils.EventKind{kind, "all"}] ||
 						utils.AllowedEventKindsMap[utils.EventKind{kind, ns}]) && (utils.AllowedEventTypesMap[eType]) {
-						log.Logger.Infof("Processing add to events: %s. Invoked Object: %s:%s", key, eventObj.InvolvedObject.Kind, eventObj.InvolvedObject.Namespace)
+						log.Logger.Debugf("Processing add to events: %s. Invoked Object: %s:%s", key, eventObj.InvolvedObject.Kind, eventObj.InvolvedObject.Namespace)
 						sendEvent(obj, c, "events", "create", err)
 					}
 				},

pkg/logging/logging.go

@@ -14,6 +14,11 @@ func init() {
 	Logger.SetOutput(os.Stdout)
 
 	// Only log the warning severity or above.
-	Logger.SetLevel(logrus.DebugLevel)
+	logLevel, err := logrus.ParseLevel(os.Getenv("LOG_LEVEL"))
+	if err != nil {
+		// Set Info level as a default
+		logLevel = logrus.InfoLevel
+	}
+	Logger.SetLevel(logLevel)
 	Logger.Formatter = &logrus.TextFormatter{ForceColors: true, FullTimestamp: true}
 }

pkg/notify/elasticsearch.go

@@ -54,6 +54,9 @@ func init() {
 	if err != nil {
 		log.Logger.Fatal(fmt.Sprintf("Error in loading configuration. Error:%s", err.Error()))
 	}
+	if !c.Communications.ElasticSearch.Enable {
+		return
+	}
 	// create elasticsearch client
 	elsClient, err = elastic.NewClient(elastic.SetURL(c.Communications.ElasticSearch.Server), elastic.SetBasicAuth(c.Communications.ElasticSearch.Username, c.Communications.ElasticSearch.Password), elastic.SetSniff(false), elastic.SetHealthcheck(false), elastic.SetGzip(true))
 	if err != nil {

pkg/utils/utils.go

@@ -130,7 +130,7 @@ func createMaps() {
 		AllowedEventTypesMap[strings.ToLower(t)] = true
 	}
 
-	log.Logger.Info("AllowedEventKindsMap:: %+v", AllowedEventKindsMap)
+	log.Logger.Infof("Allowed Events - %+v", AllowedEventKindsMap)
 }
 
 // GetObjectMetaData returns metadata of the given object