Skip to content

Commit

Permalink
Merge branch 'master' of github.com:replicatedhq/kots into 1.19.0
Browse files Browse the repository at this point in the history
  • Loading branch information
sgalsaleh committed Sep 11, 2020
2 parents 02f44a5 + c48e8bb commit 07e5805
Show file tree
Hide file tree
Showing 6 changed files with 40 additions and 8 deletions.
7 changes: 7 additions & 0 deletions kotsadm/cmd/kotsadm/cli/api.go
Expand Up @@ -4,6 +4,7 @@ import (
"strings"

"github.com/replicatedhq/kots/kotsadm/pkg/apiserver"
"github.com/replicatedhq/kots/kotsadm/pkg/logger"
"github.com/spf13/cobra"
"github.com/spf13/viper"
)
Expand All @@ -17,6 +18,12 @@ func APICmd() *cobra.Command {
viper.BindPFlags(cmd.Flags())
},
RunE: func(cmd *cobra.Command, args []string) error {
v := viper.GetViper()

if v.GetString("log-level") == "debug" {
logger.SetDebug()
}

apiserver.Start()
return nil
},
Expand Down
6 changes: 6 additions & 0 deletions kotsadm/cmd/kotsadm/cli/restore.go
Expand Up @@ -5,6 +5,7 @@ import (
"strings"

"github.com/pkg/errors"
"github.com/replicatedhq/kots/kotsadm/pkg/logger"
"github.com/replicatedhq/kots/kotsadm/pkg/snapshot"
"github.com/replicatedhq/kots/pkg/kotsadm"
kotsadmtypes "github.com/replicatedhq/kots/pkg/kotsadm/types"
Expand All @@ -26,6 +27,11 @@ func RestoreCmd() *cobra.Command {
os.Exit(1)
}

v := viper.GetViper()
if v.GetString("log-level") == "debug" {
logger.SetDebug()
}

if err := kotsadm.Delete(&kotsadmtypes.DeleteOptions{}); err != nil {
return errors.Wrap(err, "failed to delete kotsadm")
}
Expand Down
2 changes: 2 additions & 0 deletions kotsadm/cmd/kotsadm/cli/root.go
Expand Up @@ -25,6 +25,8 @@ func RootCmd() *cobra.Command {

cobra.OnInitialize(initConfig)

cmd.PersistentFlags().String("log-level", "info", "set the log level")

cmd.AddCommand(APICmd())
cmd.AddCommand(OperatorCmd())
cmd.AddCommand(RestoreCmd())
Expand Down
2 changes: 2 additions & 0 deletions kotsadm/kustomize/overlays/dev/deployment.yaml
Expand Up @@ -21,6 +21,8 @@ spec:
- name: kubelet-client-cert
mountPath: /etc/kubernetes/pki/kubelet
env:
- name: KOTSADM_LOG_LEVEL
value: "debug"
- name: DISABLE_SPA_SERVING
value: "1"
- name: KOTSADM_TARGET_NAMESPACE
Expand Down
2 changes: 1 addition & 1 deletion kotsadm/pkg/handlers/snapshots.go
Expand Up @@ -439,7 +439,7 @@ func GetVeleroStatus(w http.ResponseWriter, r *http.Request) {

if detectVelero == nil {
getVeleroStatusResponse.IsVeleroInstalled = false
JSON(w, 404, getVeleroStatusResponse)
JSON(w, 200, getVeleroStatusResponse)
return
}

Expand Down
29 changes: 22 additions & 7 deletions kotsadm/pkg/logger/logger.go
@@ -1,20 +1,35 @@
package logger

import (
"os"

"go.uber.org/zap"
"go.uber.org/zap/zapcore"
)

var log *zap.Logger
var atom zap.AtomicLevel

func init() {
l, err := zap.NewDevelopment(zap.AddCallerSkip(1))
if err != nil {
panic(err)
}
atom = zap.NewAtomicLevel()
atom.SetLevel(zapcore.InfoLevel)

encoderCfg := zap.NewProductionEncoderConfig()

l := zap.New(zapcore.NewCore(
zapcore.NewJSONEncoder(encoderCfg),
zapcore.Lock(os.Stdout),
atom,
))
defer l.Sync()

log = l
}

func SetDebug() {
atom.SetLevel(zapcore.DebugLevel)
}

func Error(err error) {
defer log.Sync()
sugar := log.Sugar()
Expand All @@ -24,7 +39,7 @@ func Error(err error) {
func Errorf(template string, args ...interface{}) {
defer log.Sync()
sugar := log.Sugar()
sugar.Errorf(template, args...)
sugar.Errorf(template, args)
}

func Info(msg string, fields ...zap.Field) {
Expand All @@ -36,7 +51,7 @@ func Info(msg string, fields ...zap.Field) {
func Infof(template string, args ...interface{}) {
defer log.Sync()
sugar := log.Sugar()
sugar.Infof(template, args...)
sugar.Infof(template, args)
}

func Debug(msg string, fields ...zap.Field) {
Expand All @@ -48,5 +63,5 @@ func Debug(msg string, fields ...zap.Field) {
func Debugf(template string, args ...interface{}) {
defer log.Sync()
sugar := log.Sugar()
sugar.Debugf(template, args...)
sugar.Debugf(template, args)
}

0 comments on commit 07e5805

Please sign in to comment.