multilog/log.go at main · mateothegreat/multilog · GitHub

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
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
package multilog

import (
	"os"
	"sync"
)

// Trace logs a trace message to all registered loggers at the TRACE level.
//
// This function is concurrently called for each logger, so it is safe to call
// from multiple goroutines without blocking.
//
// Arguments:
//
//   - group: The group name
//   - message: The message to log
//   - v: The data to log
func Trace(group string, message string, v map[string]interface{}) {
	wg := sync.WaitGroup{}
	for _, logger := range Loggers {
		wg.Add(1)
		go func(logger *CustomLogger) {
			defer wg.Done()
			logger.Log(TRACE, group, message, v)
		}(logger)
	}
	wg.Wait()
}

// Debug logs a debug message to all registered loggers at the DEBUG level.
//
// This function is concurrently called for each logger, so it is safe to call
// from multiple goroutines without blocking.
//
// Arguments:
//
//   - group: The group name
//   - message: The message to log
//   - v: The data to log
func Debug(group string, message string, v map[string]interface{}) {
	wg := sync.WaitGroup{}
	for _, logger := range Loggers {
		wg.Add(1)
		go func(logger *CustomLogger) {
			defer wg.Done()
			logger.Log(DEBUG, group, message, v)
		}(logger)
	}
	wg.Wait()
}

// Info logs an info message to all registered loggers at the INFO level.
//
// This function is concurrently called for each logger, so it is safe to call
// from multiple goroutines without blocking.
//
// Arguments:
//
//   - group: The group name
//   - message: The message to log
//   - v: The data to log
func Info(group string, message string, v map[string]interface{}) {
	wg := sync.WaitGroup{}
	for _, logger := range Loggers {
		wg.Add(1)
		go func(logger *CustomLogger) {
			defer wg.Done()
			logger.Log(INFO, group, message, v)
		}(logger)
	}
	wg.Wait()
}

// Warn logs a warn message to all registered loggers at the WARN level.
//
// This function is concurrently called for each logger, so it is safe to call
// from multiple goroutines without blocking.
//
// Arguments:
//
//   - group: The group name
//   - message: The message to log
//   - v: The data to log
func Warn(group string, message string, v map[string]interface{}) {
	wg := sync.WaitGroup{}
	for _, logger := range Loggers {
		wg.Add(1)
		go func(logger *CustomLogger) {
			defer wg.Done()
			logger.Log(WARN, group, message, v)
		}(logger)
	}
	wg.Wait()
}

// Error logs an error message to all registered loggers at the ERROR level.
//
// This function is concurrently called for each logger, so it is safe to call
// from multiple goroutines without blocking.
//
// Arguments:
//
//   - group: The group name
//   - message: The message to log
//   - v: The data to log
func Error(group string, message string, v map[string]interface{}) {
	wg := sync.WaitGroup{}
	for _, logger := range Loggers {
		wg.Add(1)
		go func(logger *CustomLogger) {
			defer wg.Done()
			logger.Log(ERROR, group, message, v)
		}(logger)
	}
	wg.Wait()
}

// Fatal logs a fatal message to all registered loggers at the FATAL level.
//
// This function is concurrently called for each logger, so it is safe to call
// from multiple goroutines without blocking.
//
// Arguments:
//
//   - group: The group name
//   - message: The message to log
//   - v: The data to log
func Fatal(group string, message string, v map[string]interface{}) {
	wg := sync.WaitGroup{}
	for _, logger := range Loggers {
		wg.Add(1)
		go func(logger *CustomLogger) {
			defer wg.Done()
			logger.Log(FATAL, group, message, v)
		}(logger)
	}
	wg.Wait()
	os.Exit(1)
}