logrus based logger

logger.go

@@ -0,0 +1,66 @@
+/*
+ * Minio Cloud Storage, (C) 2015 Minio, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package main
+
+import (
+	"encoding/json"
+
+	"github.com/Sirupsen/logrus"
+	"github.com/minio/minio/pkg/probe"
+	"github.com/weekface/mgorus"
+)
+
+type fields map[string]interface{}
+
+var log = logrus.New() // Default console logger.
+
+// log2Mongo enables logging to mongodb. Use capped collection to
+func log2Mongo(url, db, collection string) *probe.Error {
+	hooker, e := mgorus.NewHooker(url, db, collection)
+	if e != nil {
+		return probe.NewError(e)
+	}
+
+	log.Hooks.Add(hooker)                   // Add mongodb hook.
+	log.Formatter = &logrus.JSONFormatter{} // JSON formatted log.
+	log.Level = logrus.InfoLevel            // Minimum log level.
+	return nil
+}
+
+func errorIf(err *probe.Error, msg string, fields map[string]interface{}) {
+	if err == nil {
+		return
+	}
+	if fields == nil {
+		fields = make(map[string]interface{})
+	}
+
+	fields["error"] = err.ToGoError()
+	if jsonErr, e := json.Marshal(err); e == nil {
+		fields["probe"] = string(jsonErr)
+	}
+	log.WithFields(fields).Error(msg)
+
+}
+
+func audit(msg string, fields logrus.Fields) {
+	if fields == nil {
+		fields = make(map[string]interface{})
+	}
+
+	log.WithFields(fields).Info(msg)
+}