Skip to content

Commit 6b1137a

Browse files
committed
test changes
1 parent 171b2dc commit 6b1137a

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

internal/trace/listener.go

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,12 +85,25 @@ func (l *Listener) HandlerStarted(ctx context.Context, msg json.RawMessage) cont
8585
serviceName = "aws.lambda"
8686
}
8787
extensionNotRunning := !l.extensionManager.IsExtensionRunning()
88+
89+
// Parse sampling rules from environment
8890
opts := append([]tracer.StartOption{
8991
tracer.WithService(serviceName),
9092
tracer.WithLambdaMode(extensionNotRunning),
9193
tracer.WithGlobalTag("_dd.origin", "lambda"),
9294
tracer.WithSendRetries(2),
9395
}, l.tracerOptions...)
96+
97+
// Add sampling rules if configured
98+
if rulesStr := os.Getenv("DD_TRACE_SAMPLING_RULES"); rulesStr != "" {
99+
var rules []tracer.SamplingRule
100+
if err := json.Unmarshal([]byte(rulesStr), &rules); err == nil {
101+
opts = append(opts, tracer.WithSamplingRules(rules))
102+
}
103+
}
104+
105+
opts = append(opts, l.tracerOptions...)
106+
94107
if l.otelTracerEnabled {
95108
provider := ddotel.NewTracerProvider(
96109
opts...,

0 commit comments

Comments
 (0)