Application Real-Time Monitoring Service:Go components and frameworks supported by ARMS Application Monitoring

Message

RPC frameworks

SQL/NoSQL

Logging

Job scheduling

Trace SDK

AI SDK

Alibaba Cloud SDK

Other SDKs

How do I maintain trace continuity for Asynq versions earlier than v0.26.0?

For more information, see How do I maintain trace continuity for Asynq versions earlier than v0.26.0?.

Why does trace discontinuity occur when using message frameworks?

Because of implementation details in certain message frameworks, the current Go agent has limitations when propagating trace context across them.

Why don't I see database or NoSQL calls in the console when using Redis clients?

Because of framework implementation details, the Go agent cannot instrument actions that run before the init function.

Make sure you initialize your Redis or database client inside the init function.

// Invalid approach
var rdb = redis.NewClient(&redis.Options{
	Addr:     "localhost:6379",
	Password: "", // no password set
	DB:       0,  // use default DB
})

// Valid approach
var rdb *redis.Client

func init() {
	rdb = redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "", // no password set
		DB:       0,  // use default DB
	})
}

Why don't I see my custom OpenTelemetry SDK instrumentation?

1. In the Custom Configuration page, select opentelemetry-plugin in the Agent Switch Settings section, then restart your application.

   

2. The default sample rate is 10%. You might not see traces if there are few requests. You can adjust the sample rate as needed.

How do I add custom spans for RabbitMQ?

Use the following example code to add custom spans:

import (
    "context"
    oTrace "go.opentelemetry.io/otel/trace"
    "go.opentelemetry.io/otel/propagation"
    "go.opentelemetry.io/otel"
    "go.opentelemetry.io/otel/trace"
  )
  
  // Create a span for each message in the handler
  func handle(deliveries <-chan amqp.Delivery, done chan error) {
      cleanup := func() {
          Log.Printf("handle: deliveries channel closed")
          done <- nil
      }
  
      defer cleanup()
      for d := range deliveries {
        var headerMap propagation.MapCarrier
        headerMap = make(map[string]string)
        headerMap["traceparent"] = delivery.Headers["traceparent"]
        ctx := otel.GetTextMapPropagator().Extract(context.Background(), headerMap)
        ctx = oTrace.ContextWithSpanContext(context.Background(), oTrace.SpanFromContext(ctx).SpanContext())
        tracer = otel.GetTracerProvider().Tracer("")
        opts := append([]oTrace.SpanStartOption{}, oTrace.WithSpanKind(oTrace.SpanKindConsumer))
        ctx, span := tracer.Start(context.Background(), "mq", opts...)
        defer span.End()
        //other process
      }
  }
  
  

How do I add custom spans for Kafka?

Use the following example code to add custom spans:

import (
    kafka "github.com/segmentio/kafka-go"
      "go.opentelemetry.io/otel"
      "go.opentelemetry.io/otel/propagation"
      "go.opentelemetry.io/otel/trace"
      oTrace "go.opentelemetry.io/otel/trace"
  )
  
  // Create a span for each message in the handler
  func handle(msg kafka.Message) {
      for _, attr := range msg.Headers {
          if attr.Key == "traceparent" {
              var headerMap propagation.MapCarrier
              headerMap = make(map[string]string)
              headerMap["traceparent"] = string(attr.Value)
              ctx := otel.GetTextMapPropagator().Extract(context.Background(), headerMap)
              tracer := otel.GetTracerProvider().Tracer("")
              opts := append([]oTrace.SpanStartOption{}, oTrace.WithSpanKind(oTrace.SpanKindConsumer))
              ctx, span := tracer.Start(ctx, "mq", opts...)
              defer span.End()
              //other process
          }
  
      }
  }