kairos/luet
1
0
Fork 0
mirror of https://github.com/mudler/luet.git synced 2025-09-25 14:38:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make logging concurrent-aware

Browse Source
This commit is contained in:
Ettore Di Giacinto
2019-11-02 18:00:06 +01:00
parent 4fbe84b30b
commit b72a09ab1c
2 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/logger/logger.go
View File

@@ -2,6 +2,7 @@ package logger
import ( import (
"fmt" "fmt"
"sync"
"time" "time"
. "github.com/logrusorgru/aurora" . "github.com/logrusorgru/aurora"
@@ -10,6 +11,7 @@ import (
) )
var s *spinner.Spinner var s *spinner.Spinner
var m = &sync.Mutex{}
func Spinner(i int) { func Spinner(i int) {
if i > 43 { if i > 43 {
@@ -21,6 +23,8 @@ func Spinner(i int) {
} }
func SpinnerText(suffix, prefix string) { func SpinnerText(suffix, prefix string) {
m.Lock()
defer m.Unlock()
s.Suffix = Bold(Magenta(suffix)).BgBlack().String() s.Suffix = Bold(Magenta(suffix)).BgBlack().String()
s.Prefix = Bold(Cyan(prefix)).String() s.Prefix = Bold(Cyan(prefix)).String()
} }
@@ -33,7 +37,7 @@ func SpinnerStop() {
func Warning(msg ...interface{}) { func Warning(msg ...interface{}) {
if s != nil { if s != nil {
SpinnerText(Sprintf(msg), Bold(Yellow("Warn")).BgBlack().String()) SpinnerText(Sprintf(msg), Bold(Yellow("Warn")).BgBlack().String())
// return return
} }
cmd := []interface{}{Bold(Yellow("Warn")).BgBlack().String()} cmd := []interface{}{Bold(Yellow("Warn")).BgBlack().String()}
for _, f := range msg { for _, f := range msg {
@@ -44,7 +48,7 @@ func Warning(msg ...interface{}) {
func Debug(msg ...interface{}) { func Debug(msg ...interface{}) {
if s != nil { if s != nil {
SpinnerText(Sprintf(msg), Bold(White("Debug")).BgBlack().String()) SpinnerText(Sprintf(msg), Bold(White("Debug")).BgBlack().String())
// return return
} }
cmd := []interface{}{Bold(White("Debug")).String()} cmd := []interface{}{Bold(White("Debug")).String()}
for _, f := range msg { for _, f := range msg {
@@ -56,7 +60,7 @@ func Debug(msg ...interface{}) {
func Info(msg ...interface{}) { func Info(msg ...interface{}) {
if s != nil { if s != nil {
SpinnerText(Sprintf(msg), Bold(Blue("Info")).BgBlack().String()) SpinnerText(Sprintf(msg), Bold(Blue("Info")).BgBlack().String())
// return return
} }
cmd := []interface{}{Bold(Green("Info")).String()} cmd := []interface{}{Bold(Green("Info")).String()}
for _, f := range msg { for _, f := range msg {
@@ -68,7 +72,7 @@ func Info(msg ...interface{}) {
func Error(msg ...interface{}) { func Error(msg ...interface{}) {
if s != nil { if s != nil {
SpinnerText(Sprintf(msg), Bold(Red("Error")).BgBlack().String()) SpinnerText(Sprintf(msg), Bold(Red("Error")).BgBlack().String())
// return return
} }
cmd := []interface{}{Bold(Red("Error")).String()} cmd := []interface{}{Bold(Red("Error")).String()}
for _, f := range msg { for _, f := range msg {