-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathtee_handler_test.go
89 lines (71 loc) · 2.3 KB
/
tee_handler_test.go
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
package clog
import (
"testing"
"github.com/stretchr/testify/assert"
)
func TestTeeHandler(t *testing.T) {
a := NewMemoryHandler()
b := NewMemoryHandler()
logger := NewLogger(NewTeeHandler(a, b))
logger.Info("test")
assert.Equal(t, 1, len(a.log))
assert.Equal(t, 1, len(b.log))
assert.Equal(t, "test", a.log[0])
assert.Equal(t, "test", b.log[0])
}
func TestTeeHandlerSetPrefix(t *testing.T) {
a := NewMemoryHandler()
b := NewMemoryHandler()
logger := NewLogger(NewTeeHandler(a, b))
logger.SetPrefix("prefix ")
logger.Info("test")
assert.Equal(t, 1, len(a.log))
assert.Equal(t, 1, len(b.log))
assert.Equal(t, "prefix test", a.log[0])
assert.Equal(t, "prefix test", b.log[0])
}
func TestTeeHandlerReturnsError1(t *testing.T) {
next := NewMemoryHandler()
handler := NewTeeHandler(NewDiscardHandler(), next)
err := handler.LogEntry(LogEntry{Values: []interface{}{"test"}})
assert.ErrorIs(t, err, ErrMessageDiscarded)
assert.Equal(t, 1, len(next.log))
assert.Equal(t, "test", next.log[0])
}
func TestTeeHandlerReturnsError2(t *testing.T) {
next := NewMemoryHandler()
handler := NewTeeHandler(next, NewDiscardHandler())
err := handler.LogEntry(LogEntry{Values: []interface{}{"test"}})
assert.ErrorIs(t, err, ErrMessageDiscarded)
assert.Equal(t, 1, len(next.log))
assert.Equal(t, "test", next.log[0])
}
func TestTeeHandlerNil1(t *testing.T) {
next := NewMemoryHandler()
handler := NewTeeHandler(nil, next)
err := handler.LogEntry(LogEntry{Values: []interface{}{"test"}})
assert.ErrorIs(t, err, ErrNoRegisteredHandler)
assert.Equal(t, 1, len(next.log))
assert.Equal(t, "test", next.log[0])
}
func TestTeeHandlerNil2(t *testing.T) {
next := NewMemoryHandler()
handler := NewTeeHandler(next, nil)
err := handler.LogEntry(LogEntry{Values: []interface{}{"test"}})
assert.ErrorIs(t, err, ErrNoRegisteredHandler)
assert.Equal(t, 1, len(next.log))
assert.Equal(t, "test", next.log[0])
}
func ExampleTeeHandler() {
// a tee handler is a middleware with two targets (Handler) which
// will send all messages to both handlers as targets
// let's create a tee handler with two TextHandler targets
logger := NewLogger(NewTeeHandler(
NewTextHandler("logger 1 - ", 0),
NewTextHandler("logger 2 - ", 0),
))
logger.Infof("hello %s", "world")
// Output:
// logger 1 - hello world
// logger 2 - hello world
}