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

Messages

RPC frameworks

SQL/NoSQL

Logs

Task scheduling

Trace SDK

AI SDK

Alibaba Cloud SDKs

Other SDKs

Why do broken traces occur when I use a message framework?

Because of the specific implementations of certain message frameworks, the current version of the Go agent has limitations in propagating trace contexts. The limitations are as follows:

Why can't I see database/NoSQL calls in the console when I use a Redis client?

Because of the framework's implementation, the Go agent cannot effectively instrument actions that are executed before the init function.

Ensure that you initialize the Redis client or database client within the init function.

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

// Valid method
var rdb *redis.Client

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

Why can't I see my custom OTel SDK instrumentation?

1. On the Custom Configuration page, select opentelemetry-plugin in the Probe Settings section, and then restart the application.

   

2. The default sample rate is 10%. If the number of requests is low, traces might not be captured. You can adjust the sample rate.

How do I add a custom span for RabbitMQ?

The following sample code shows how to add a custom span:

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 message 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 a custom span for Kafka?

The following sample code shows how to add a custom span:

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 message 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
          }
  
      }
  }