Move to controller-util log util functions

Gopkg.toml

@@ -28,7 +28,7 @@ required = [
 
 [[constraint]]
   name="github.com/presslabs/controller-util"
-  version = "v0.1.9"
+  version = "v0.1.10"
 
 # use wgliang version of cron because provides cron removal
 [[override]]

cmd/mysql-operator-sidecar/main.go

@@ -21,14 +21,14 @@ import (
 	"fmt"
 	"os"
 
+	utilLog "github.com/presslabs/controller-util/log"
 	"github.com/spf13/cobra"
 	"sigs.k8s.io/controller-runtime/pkg/runtime/signals"
 
 	"github.com/presslabs/mysql-operator/pkg/sidecar/appclone"
 	"github.com/presslabs/mysql-operator/pkg/sidecar/appconf"
 	"github.com/presslabs/mysql-operator/pkg/sidecar/apphelper"
 	"github.com/presslabs/mysql-operator/pkg/sidecar/apptakebackup"
-	customLog "github.com/presslabs/mysql-operator/pkg/util/log"
 	logf "sigs.k8s.io/controller-runtime/pkg/runtime/log"
 )
 
@@ -49,14 +49,16 @@ func main() {
 	}
 
 	// add flags and parse them
+	debug := false
+	flag.BoolVar(&debug, "debug", false, "Set logger in debug mode")
 	cmd.PersistentFlags().AddGoFlagSet(flag.CommandLine)
 	if err := cmd.ParseFlags(os.Args[1:]); err != nil {
 		fmt.Fprintf(os.Stderr, "failed to parse global flags, see helps, err: %s", err)
 		os.Exit(1)
 	}
 
 	// setup logging
-	logf.SetLogger(customLog.ZapLogger())
+	logf.SetLogger(utilLog.ZapLogger(debug))
 
 	confCmd := &cobra.Command{
 		Use:   "init-configs",

cmd/mysql-operator/main.go

@@ -21,9 +21,10 @@ import (
 	"fmt"
 	"os"
 
-	customLog "github.com/presslabs/mysql-operator/pkg/util/log"
+	utilLog "github.com/presslabs/controller-util/log"
 	"github.com/spf13/pflag"
 	_ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
+	"k8s.io/klog"
 	"sigs.k8s.io/controller-runtime/pkg/client/config"
 	"sigs.k8s.io/controller-runtime/pkg/manager"
 	logf "sigs.k8s.io/controller-runtime/pkg/runtime/log"
@@ -40,6 +41,9 @@ func main() {
 	fs := pflag.NewFlagSet(os.Args[0], pflag.ExitOnError)
 	fs.AddGoFlagSet(flag.CommandLine)
 
+	debug := false
+	fs.BoolVar(&debug, "debug", false, "Set logger in debug mode")
+
 	opt := options.GetOptions()
 	opt.AddFlags(fs)
 	if err := fs.Parse(os.Args); err != nil {
@@ -48,7 +52,12 @@ func main() {
 	}
 
 	// set logging
-	logf.SetLogger(customLog.ZapLogger())
+	klogFlags := flag.NewFlagSet("klog", flag.ExitOnError)
+	klog.InitFlags(klogFlags)
+	klogFlags.Set("logtostderr", "true")      // nolint: errcheck
+	klogFlags.Set("alsologtostderr", "false") // nolint: errcheck
+
+	logf.SetLogger(utilLog.ZapLogger(debug))
 
 	if err := opt.Validate(); err != nil {
 		log.Error(err, "failed to validate command line args, see help.")

hack/dev-values.yaml

@@ -1,5 +1,4 @@
 extraArgs:
-  - -v=1
   - --debug
 
 installCRDs: false

hack/docker/sidecar-entrypoint.sh

@@ -36,7 +36,7 @@ ${GCS_SERVICE_ACCOUNT_JSON_KEY}
 EOF
 
 SIDECAR_BIN=mysql-operator-sidecar
-VERBOSE="-v 1 --debug"
+VERBOSE="--debug"
 
 # exec command
 case "$1" in

pkg/controller/internal/testutil/testutil.go

@@ -22,10 +22,8 @@ import (
 
 	// loggging
 	"github.com/go-logr/logr"
-	"github.com/go-logr/zapr"
-	"go.uber.org/zap"
-	"go.uber.org/zap/zapcore"
 
+	utilLog "github.com/presslabs/controller-util/log"
 	"sigs.k8s.io/controller-runtime/pkg/reconcile"
 )
 
@@ -46,16 +44,6 @@ func DrainChan(requests <-chan reconcile.Request) {
 }
 
 // NewTestLogger returns a logger good for tests
-func NewTestLogger(w io.Writer, options ...zap.Option) logr.Logger {
-	encoderCfg := zapcore.EncoderConfig{
-		MessageKey:     "msg",
-		LevelKey:       "level",
-		NameKey:        "logger",
-		EncodeLevel:    zapcore.LowercaseLevelEncoder,
-		EncodeTime:     zapcore.ISO8601TimeEncoder,
-		EncodeDuration: zapcore.StringDurationEncoder,
-	}
-	sink := zapcore.AddSync(w)
-	core := zapcore.NewCore(zapcore.NewConsoleEncoder(encoderCfg), sink, zap.DebugLevel)
-	return zapr.NewLogger(zap.New(core).WithOptions(options...))
+func NewTestLogger(w io.Writer) logr.Logger {
+	return utilLog.ZapLoggerTo(w, true)
 }

test/e2e-values.yaml

@@ -1,5 +1,4 @@
 extraArgs:
-  - -v=1
   - --debug
 
 orchestrator: