1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
package global
import (
"bytes"
"errors"
"io"
"log"
"sync"
"testing"
"github.com/go-logr/logr"
"github.com/stretchr/testify/assert"
"github.com/go-logr/logr/funcr"
"github.com/go-logr/stdr"
)
func TestLoggerConcurrentSafe(t *testing.T) {
var wg sync.WaitGroup
wg.Add(1)
go func() {
defer wg.Done()
SetLogger(stdr.New(log.New(io.Discard, "", 0)))
}()
wg.Add(1)
go func() {
defer wg.Done()
Info("")
}()
wg.Wait()
ResetForTest(t)
}
func TestLogLevel(t *testing.T) {
tests := []struct {
name string
verbosity int
logF func()
want string
}{
{
name: "Verbosity 0 should log errors.",
verbosity: 0,
want: `"msg"="foobar" "error"="foobar"`,
logF: func() {
Error(errors.New("foobar"), "foobar")
},
},
{
name: "Verbosity 1 should log warnings",
verbosity: 1,
want: `"level"=1 "msg"="foo"`,
logF: func() {
Warn("foo")
},
},
{
name: "Verbosity 4 should log info",
verbosity: 4,
want: `"level"=4 "msg"="bar"`,
logF: func() {
Info("bar")
},
},
{
name: "Verbosity 8 should log debug",
verbosity: 8,
want: `"level"=8 "msg"="baz"`,
logF: func() {
Debug("baz")
},
},
}
for _, test := range tests {
t.Run(test.name, func(t *testing.T) {
var buf bytes.Buffer
SetLogger(newBuffLogger(&buf, test.verbosity))
test.logF()
assert.Equal(t, test.want, buf.String())
})
}
}
func newBuffLogger(buf *bytes.Buffer, verbosity int) logr.Logger {
return funcr.New(func(prefix, args string) {
_, _ = buf.Write([]byte(args))
}, funcr.Options{
Verbosity: verbosity,
})
}
|
