/
log.go
44 lines (35 loc) · 1.02 KB
/
log.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
package keeltemporal
import (
"context"
"go.temporal.io/sdk/activity"
tlog "go.temporal.io/sdk/log"
"go.temporal.io/sdk/workflow"
"go.uber.org/zap"
)
func Error(l tlog.Logger, err error, msg string, fields ...zap.Field) {
LoggerWith(l, fields...).Error(msg)
}
func Info(l tlog.Logger, msg string, fields ...zap.Field) {
LoggerWith(l, fields...).Info(msg)
}
func Warn(l tlog.Logger, msg string, fields ...zap.Field) {
LoggerWith(l, fields...).Warn(msg)
}
func Debug(l tlog.Logger, msg string, fields ...zap.Field) {
LoggerWith(l, fields...).Debug(msg)
}
func GetWorkflowLogger(ctx workflow.Context, fields ...zap.Field) tlog.Logger {
l := workflow.GetLogger(ctx)
return LoggerWith(l, fields...)
}
func GetActivityLogger(ctx context.Context, fields ...zap.Field) tlog.Logger {
l := activity.GetLogger(ctx)
return LoggerWith(l, fields...)
}
func LoggerWith(l tlog.Logger, fields ...zap.Field) tlog.Logger {
v := make([]interface{}, len(fields))
for i, field := range fields {
v[i] = field
}
return tlog.With(l, v...)
}