feat: add helper

This commit is contained in:
Kevin Franklin Kim 2022-06-02 14:09:28 +02:00
parent a63b858b67
commit 5659103f7b

View File

@ -1,6 +1,10 @@
package keeltemporal
import (
"context"
"go.temporal.io/sdk/activity"
tlog "go.temporal.io/sdk/log"
"go.temporal.io/sdk/workflow"
"go.uber.org/zap"
@ -31,3 +35,19 @@ func Debug(ctx workflow.Context, msg string, fields ...zap.Field) {
}
workflow.GetLogger(ctx).Debug(msg, keyvals...)
}
func GetWorkflowLogger(ctx workflow.Context) tlog.Logger {
return workflow.GetLogger(ctx)
}
func GetActivityLogger(ctx context.Context) tlog.Logger {
return activity.GetLogger(ctx)
}
func LoggerWith(logger tlog.Logger, fields ...zap.Field) tlog.Logger {
v := make([]interface{}, len(fields))
for i, field := range fields {
v[i] = field
}
return tlog.With(logger, v...)
}