foomo/gofuncy
1
0
Fork 0
mirror of https://github.com/foomo/gofuncy.git synced 2025-10-16 12:25:41 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: add log

Browse Source
This commit is contained in:
Kevin Franklin Kim 2025-05-12 22:25:28 +02:00
parent 6b0c554b2c
commit 2a1fb1d00c
No known key found for this signature in database
1 changed files with 25 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
go.go
View File

@ -19,9 +19,10 @@ import (
type (
Options struct {
l *slog.Logger
ctx context.Context //nolint:containedctx // required
name string
l *slog.Logger
ctx context.Context //nolint:containedctx // required
level slog.Level
name string
// telemetry
meter metric.Meter
tracer trace.Tracer
@ -47,6 +48,12 @@ func WithContext(ctx context.Context) Option {
}
}
func WithLogLevel(level slog.Level) Option {
return func(o *Options) {
o.level = level
}
}
func WithMeter(v metric.Meter) Option {
return func(o *Options) {
o.meter = v
@ -80,6 +87,7 @@ func WithHistogramName(name string) Option {
func Go(fn Func, opts ...Option) <-chan error {
o := &Options{
l: slog.Default(),
level: slog.LevelDebug,
counterName: "gofuncy.routine.count",
histogramName: "gofuncy.routine.duration",
telemetryEnabled: os.Getenv("OTEL_ENABLED") == "true",
@ -133,14 +141,27 @@ func Go(fn Func, opts ...Option) <-chan error {
err := make(chan error)
go func(o *Options, errChan chan<- error) {
var err error
defer close(errChan)
ctx := o.ctx
var err error
start := time.Now()
l := o.l.With("name", o.name)
if value := RoutineFromContext(ctx); value != "" {
l = l.With("parent", value)
}
var span trace.Span
if o.tracer != nil {
ctx, span = o.tracer.Start(o.ctx, o.name)
l = l.With("trace_id", span.SpanContext().TraceID().String())
defer span.End()
}
l.Log(ctx, o.level, "starting gofuncy routine")
defer func() {
if err != nil {
l = l.With("error", err.Error())
}
l.Log(ctx, o.level, "exiting gofuncy routine", "duration", time.Since(start).Round(time.Millisecond).String())
}()
// create telemetry if enabled
if o.counter != nil {
attrs := metric.WithAttributes(semconv.ProcessRuntimeName(o.name))