working example of tail_sampling

collector-config.yaml

@@ -36,6 +36,23 @@ processors:
     - action: insert
       key: loki.resource.labels
       value: service_name, deployment_environment
+  tail_sampling:
+    decision_wait: 10s
+    num_traces: 100
+    expected_new_traces_per_sec: 10
+    policies:
+      [
+        {
+          name: errors-policy,
+          type: status_code,
+          status_code: { status_codes: [ERROR] }
+        },
+        {
+          name: randomized-policy,
+          type: probabilistic,
+          probabilistic: { sampling_percentage: 25 },
+        },
+      ]
 
 service:
   pipelines:
@@ -49,5 +66,5 @@ service:
       exporters: [loki]
     traces:
       receivers: [otlp/traces]
-      processors: [resource]
+      processors: [resource,tail_sampling]
       exporters: [otlp/traces]

emissor-de-metricas-simples/main.go

@@ -31,15 +31,14 @@ var meuContador otel_metric.Int64Counter
 
 var tracer trace.Tracer
 
-type IgnoreCaminhoSampler struct {
-	sampler sdktrace.Sampler
-}
+type IgnoreCaminhoSampler struct{}
 
 func (ics *IgnoreCaminhoSampler) ShouldSample(p sdktrace.SamplingParameters) sdktrace.SamplingResult {
 	result := sdktrace.SamplingResult{
 		Tracestate: trace.SpanContextFromContext(p.ParentContext).TraceState(),
 	}
 	shouldSample := true
+	fmt.Println("### SHOULD SAMPLE EXECUTANDO!!!")
 	for _, att := range p.Attributes {
 		if att.Key == "http.target" && att.Value.AsString() == "/meh" {
 			shouldSample = false
@@ -120,8 +119,7 @@ func main() {
 	//}
 	//bsp := sdktrace.NewBatchSpanProcessor(exp)
 	bsp := sdktrace.NewBatchSpanProcessor(t)
-	s := sdktrace.ParentBased(sdktrace.TraceIDRatioBased(0.1))
-	ignoreCaminhoSampler := &IgnoreCaminhoSampler{sampler: s}
+	ignoreCaminhoSampler := new(IgnoreCaminhoSampler)
 	tp := sdktrace.NewTracerProvider(
 		sdktrace.WithSampler(ignoreCaminhoSampler),
 		sdktrace.WithResource(res),