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

Message

RPC frameworks

SQL/NOSQL

Logs

Trace SDK

AI SDK

Other SDKs

Why are there broken chains when using message frameworks?

Due to limitations in the specific implementations of message frameworks, the current version of the Go agent has certain limitations in Trace context propagation for some message frameworks, as detailed below:

Why can't I see database/NoSQL related calls in the console when using Redis database clients?

Due to limitations in the framework implementation, the Go Agent cannot effectively instrument actions performed before the init function is executed.

Please ensure that you initialize the Redis client or database client in the init function.

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

// Effective 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 can't I see custom OTel SDK instrumentation?

1. Please select opentelemetry-plugin in the Agent switch settings section on the Custom configuration page, and then restart your application.

   

2. The default sample rate is 10%. If you have a small number of requests, you might not see any data. We recommend adjusting the sample rate.

How do I add custom Spans for RabbitMQ?

The following is an example of adding custom Spans:

import (
  "context"
  oTrace "go.opentelemetry.io/otel/trace"
  "go.opentelemetry.io/otel"
  "go.opentelemetry.io/otel/trace"
)

//Create a span for each message when handling messages
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{}, trace.WithSpanKind(oTrace.SpanKindConsumer))
      ctx, span := tracer.Start(context.Background(), "mq", opts...)
      span.End
      DeliveryCount++
      if *Verbose == true {
          Log.Printf(
              "got %dB delivery: [%v] %q",
              len(d.Body),
              d.DeliveryTag,
              d.Body
          )
          for k, v := range d.Headers {
              if strV, ok := v.(string); ok {
                  Log.Printf("[Headers] delivery has header < %s - %s >", k, strV)
              }
          }
      } else {
          if DeliveryCount%65536 == 0 {
              Log.Printf("delivery count %d", DeliveryCount)
          }
      }
      if *AutoAck == false {
          d.Ack(false)
      }
    }
}