mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
zeekay
5a601d081b
Full module path rebrand from Temporal to Hanzo Tasks: - go.mod module: github.com/hanzoai/tasks - All internal Go imports updated (1906 files) - cmd/server renamed to cmd/tasksd - Binary name: tasksd (was temporal-server) - Docker images: hanzoai/tasks (was temporalio/server) - README rewritten with Hanzo Tasks branding - LLM.md created with integration notes - Makefile, goreleaser, CI workflows updated - go.temporal.io/sdk and go.temporal.io/api imports preserved (separate repos) Fork of Temporal.io (MIT license).
88 lines
2.0 KiB
Go
88 lines
2.0 KiB
Go
package log
|
|
|
|
import (
|
|
"go.temporal.io/sdk/workflow"
|
|
"github.com/hanzoai/tasks/common/log/tag"
|
|
)
|
|
|
|
const extraSkipForReplayLogger = 1
|
|
|
|
type (
|
|
replayLogger struct {
|
|
logger Logger
|
|
ctx workflow.Context
|
|
enableLogInReplay bool
|
|
}
|
|
)
|
|
|
|
var _ Logger = (*replayLogger)(nil)
|
|
|
|
// NewReplayLogger creates a logger which is aware of Temporal replay mode
|
|
func NewReplayLogger(logger Logger, ctx workflow.Context, enableLogInReplay bool) *replayLogger {
|
|
if sl, ok := logger.(SkipLogger); ok {
|
|
logger = sl.Skip(extraSkipForReplayLogger)
|
|
}
|
|
return &replayLogger{
|
|
logger: logger,
|
|
ctx: ctx,
|
|
enableLogInReplay: enableLogInReplay,
|
|
}
|
|
}
|
|
|
|
func (r *replayLogger) Debug(msg string, tags ...tag.Tag) {
|
|
if workflow.IsReplaying(r.ctx) && !r.enableLogInReplay {
|
|
return
|
|
}
|
|
r.logger.Debug(msg, tags...)
|
|
}
|
|
|
|
func (r *replayLogger) Info(msg string, tags ...tag.Tag) {
|
|
if workflow.IsReplaying(r.ctx) && !r.enableLogInReplay {
|
|
return
|
|
}
|
|
r.logger.Info(msg, tags...)
|
|
}
|
|
|
|
func (r *replayLogger) Warn(msg string, tags ...tag.Tag) {
|
|
if workflow.IsReplaying(r.ctx) && !r.enableLogInReplay {
|
|
return
|
|
}
|
|
r.logger.Warn(msg, tags...)
|
|
}
|
|
|
|
func (r *replayLogger) Error(msg string, tags ...tag.Tag) {
|
|
if workflow.IsReplaying(r.ctx) && !r.enableLogInReplay {
|
|
return
|
|
}
|
|
r.logger.Error(msg, tags...)
|
|
}
|
|
|
|
func (r *replayLogger) DPanic(msg string, tags ...tag.Tag) {
|
|
if workflow.IsReplaying(r.ctx) && !r.enableLogInReplay {
|
|
return
|
|
}
|
|
r.logger.DPanic(msg, tags...)
|
|
}
|
|
|
|
func (r *replayLogger) Panic(msg string, tags ...tag.Tag) {
|
|
if workflow.IsReplaying(r.ctx) && !r.enableLogInReplay {
|
|
return
|
|
}
|
|
r.logger.Panic(msg, tags...)
|
|
}
|
|
|
|
func (r *replayLogger) Fatal(msg string, tags ...tag.Tag) {
|
|
if workflow.IsReplaying(r.ctx) && !r.enableLogInReplay {
|
|
return
|
|
}
|
|
r.logger.Fatal(msg, tags...)
|
|
}
|
|
|
|
func (r *replayLogger) With(tags ...tag.Tag) Logger {
|
|
return &replayLogger{
|
|
logger: newWithLogger(r.logger, tags...),
|
|
ctx: r.ctx,
|
|
enableLogInReplay: r.enableLogInReplay,
|
|
}
|
|
}
|