ddtrace

Documentation

Overview

Package ddtrace is the implementation of instrumentation.Tracer for Datadog.

Index

• func Init() (instrumentation.Tracer, error)
• func ShutDown()
• type MessageCarrier
  • func NewKafkaCarrier(msg *kafka.Message) MessageCarrier
  • func (c MessageCarrier) ForeachKey(handler func(key, val string) error) error
  • func (c MessageCarrier) Set(key, val string)

Functions

func Init

func Init() (instrumentation.Tracer, error)

Init initializes the Datadog tracer and returns an instance of instrumentation.Tracer. This function starts the Datadog tracer.

func ShutDown

func ShutDown()

ShutDown stops the Datadog tracer. This function should be called to properly shut down the tracer and flush any remaining traces.

Types

type MessageCarrier

type MessageCarrier struct {
	// contains filtered or unexported fields
}

MessageCarrier implements the Datadog carrier interface for kafka.Message (github.com/segmentio/kafka-go). It allows injecting and extracting trace context into/from Kafka messages.

func NewKafkaCarrier

func NewKafkaCarrier(msg *kafka.Message) MessageCarrier

NewKafkaCarrier creates a new MessageCarrier for the given kafka.Message.

func (MessageCarrier) ForeachKey

func (c MessageCarrier) ForeachKey(handler func(key, val string) error) error

ForeachKey iterates over every header in the carrier and invokes the given handler function for each key-value pair.

func (MessageCarrier) Set

func (c MessageCarrier) Set(key, val string)

Set sets a header in the carrier.