Changed sampling algo. Added logger

logger/logger.go

@@ -0,0 +1,111 @@
+// Copyright 2013-2017 Aerospike, 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 logger
+
+import (
+	"log"
+	"os"
+	"sync"
+)
+
+// LogPriority specifies the logging level for the client
+type LogPriority int
+
+const (
+	DEBUG LogPriority = iota - 1
+	INFO
+	WARNING
+	ERR
+	OFF LogPriority = 999
+)
+
+type genericLogger interface {
+	Printf(format string, v ...interface{})
+}
+
+type logger struct {
+	Logger genericLogger
+
+	level LogPriority
+	mutex sync.RWMutex
+}
+
+// Logger is the default logger instance
+var Logger = newLogger()
+
+func newLogger() *logger {
+	return &logger{
+		Logger: log.New(os.Stdout, "", log.LstdFlags),
+		level:  OFF,
+	}
+}
+
+// SetLogger sets the *log.Logger object where log messages should be sent to.
+func (lgr *logger) SetLogger(l genericLogger) {
+	lgr.mutex.Lock()
+	defer lgr.mutex.Unlock()
+
+	lgr.Logger = l
+}
+
+// SetLevel sets logging level. Default is ERR.
+func (lgr *logger) SetLevel(level LogPriority) {
+	lgr.mutex.Lock()
+	defer lgr.mutex.Unlock()
+
+	lgr.level = level
+}
+
+// Error logs a message if log level allows to do so.
+func (lgr *logger) LogAtLevel(level LogPriority, format string, v ...interface{}) {
+	switch level {
+	case DEBUG:
+		lgr.Debug(format, v)
+	case INFO:
+		lgr.Info(format, v)
+	case WARNING:
+		lgr.Warn(format, v)
+	case ERR:
+		lgr.Error(format, v)
+	}
+}
+
+// Debug logs a message if log level allows to do so.
+func (lgr *logger) Debug(format string, v ...interface{}) {
+	if lgr.level <= DEBUG {
+		lgr.Logger.Printf("DEBUG: " + format, v...)
+	}
+}
+
+// Info logs a message if log level allows to do so.
+func (lgr *logger) Info(format string, v ...interface{}) {
+	if lgr.level <= INFO {
+		lgr.Logger.Printf("INFO: " + format, v...)
+	}
+}
+
+// Warn logs a message if log level allows to do so.
+func (lgr *logger) Warn(format string, v ...interface{}) {
+	if lgr.level <= WARNING {
+		lgr.Logger.Printf("WARNING: " + format, v...)
+	}
+}
+
+// Error logs a message if log level allows to do so.
+func (lgr *logger) Error(format string, v ...interface{}) {
+	if lgr.level <= ERR {
+		lgr.Logger.Printf("ERROR: " + format, v...)
+	}
+}