mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
## What changed? Refactor code generators: 1. Extracted templates to separate files. 2. Extracted common helpers to `codegen` package. 3. Simplified code generators. All generated files are almost unchanged (removed leading empty line). ## Why? Better maintainability. ## How did you test it? - [ ] built - [x] run locally and tested manually - [ ] covered by existing tests - [ ] added new unit test(s) - [ ] added new functional test(s)
36 lines
850 B
Cheetah
36 lines
850 B
Cheetah
{{- /*gotype: go.temporal.io/server/cmd/tools/genrpcserverinterceptors.grpcServerData*/ -}}
|
|
// Code generated by cmd/tools/genrpcserverinterceptors. DO NOT EDIT.
|
|
|
|
package logtags
|
|
|
|
import (
|
|
{{- range .Imports}}
|
|
{{printf "%q" .}}
|
|
{{- end}}
|
|
"go.temporal.io/server/common/log/tag"
|
|
)
|
|
|
|
func (wt *WorkflowTags) extractFrom{{.Server}}Message(message any) []tag.Tag {
|
|
switch r := message.(type) {
|
|
{{- range .Messages}}
|
|
case {{.Type}}:
|
|
{{- if or .TaskTokenGetter .WorkflowIdGetter .RunIdGetter}}
|
|
{{- if .TaskTokenGetter}}
|
|
return wt.fromTaskToken(r.{{ .TaskTokenGetter}})
|
|
{{- else}}
|
|
return []tag.Tag{
|
|
{{if .WorkflowIdGetter}} tag.WorkflowID(r.{{.WorkflowIdGetter}}),
|
|
{{end -}}
|
|
{{if .RunIdGetter}} tag.WorkflowRunID(r.{{.RunIdGetter}}),
|
|
{{end -}}
|
|
}
|
|
{{- end}}
|
|
{{- else}}
|
|
return nil
|
|
{{- end -}}
|
|
{{- end}}
|
|
default:
|
|
return nil
|
|
}
|
|
}
|