internal

Documentation

Index

• Constants
• Variables
• func AgentURLFromEnv() *url.URL
• func BoolEnv(key string, def bool) bool
• func CleanGitMetadataTags(tags map[string]string)
• func ContainerID() string
• func DurationEnv(key string, def time.Duration) time.Duration
• func EntityID() string
• func FloatEnv(key string, def float64) float64
• func ForEachStringTag(str string, fn func(key string, val string))
• func GetGitMetadataTags() map[string]string
• func GetTracerGitMetadataTags() map[string]string
• func IntEnv(key string, def int) int
• func IsExecutionTraced(ctx context.Context) bool
• func ParseTagString(str string) map[string]string
• func ResetGitMetadataTags()
• func WithExecutionNotTraced(ctx context.Context) context.Context
• func WithExecutionTraced(ctx context.Context) context.Context
• type Count
  • func NewCount(name string, value int64, tags []string, rate float64) Count
  • func (c Count) Name() string
  • func (c Count) Rate() float64
  • func (c Count) Tags() []string
  • func (c Count) Value() interface{}
• type Gauge
  • func NewGauge(name string, value float64, tags []string, rate float64) Gauge
  • func (g Gauge) Name() string
  • func (g Gauge) Rate() float64
  • func (g Gauge) Tags() []string
  • func (g Gauge) Value() interface{}
• type LockMap
  • func NewLockMap(m map[string]string) *LockMap
  • func (l *LockMap) Clear()
  • func (l *LockMap) Get(k string) string
  • func (l *LockMap) Iter(f func(key string, val string))
  • func (l *LockMap) Len() int
  • func (l *LockMap) Set(k, v string)
• type Stat
• type StatsCarrier
  • func NewStatsCarrier(statsd StatsdClient) *StatsCarrier
  • func (sc *StatsCarrier) Add(s Stat)
  • func (sc *StatsCarrier) Start()
  • func (sc *StatsCarrier) Stop()
• type StatsdClient
• type Timing
  • func NewTiming(name string, value time.Duration, tags []string, rate float64) Timing
  • func (t Timing) Name() string
  • func (t Timing) Rate() float64
  • func (t Timing) Tags() []string
  • func (t Timing) Value() interface{}

Constants

const (
	// EnvGitMetadataEnabledFlag specifies the environment variable name for enable/disable
	EnvGitMetadataEnabledFlag = "DD_TRACE_GIT_METADATA_ENABLED"
	// EnvGitRepositoryURL specifies the environment variable name for git repository URL
	EnvGitRepositoryURL = "DD_GIT_REPOSITORY_URL"
	// EnvGitCommitSha specifies the environment variable name git commit sha
	EnvGitCommitSha = "DD_GIT_COMMIT_SHA"
	// EnvDDTags specifies the environment variable name global tags
	EnvDDTags = "DD_TAGS"

	// TagRepositoryURL specifies the tag name for git repository URL
	TagRepositoryURL = "git.repository_url"
	// TagCommitSha specifies the tag name for git commit sha
	TagCommitSha = "git.commit.sha"
	// TagGoPath specifies the tag name for go module path
	TagGoPath = "go_path"

	// TraceTagRepositoryURL specifies the trace tag name for git repository URL
	TraceTagRepositoryURL = "_dd.git.repository_url"
	// TraceTagCommitSha specifies the trace tag name for git commit sha
	TraceTagCommitSha = "_dd.git.commit.sha"
	// TraceTagGoPath specifies the trace tag name for go module path
	TraceTagGoPath = "_dd.go_path"
)

Variables

var ActiveSpanKey = contextKey{}

ActiveSpanKey is used to set tracer context on a context.Context objects with a unique key

Functions

func AgentURLFromEnv

func AgentURLFromEnv() *url.URL

AgentURLFromEnv determines the trace agent URL from environment variable DD_TRACE_AGENT_URL. If the determined value is valid and the scheme is supported (unix, http or https), it will return an *url.URL. Otherwise, it returns nil.

func BoolEnv

func BoolEnv(key string, def bool) bool

BoolEnv returns the parsed boolean value of an environment variable, or def otherwise.

func CleanGitMetadataTags

func CleanGitMetadataTags(tags map[string]string)

CleanGitMetadataTags cleans up tags from git metadata

func ContainerID

func ContainerID() string

ContainerID attempts to return the container ID from /proc/self/cgroup or empty on failure.

func DurationEnv

func DurationEnv(key string, def time.Duration) time.Duration

DurationEnv returns the parsed duration value of an environment variable, or def otherwise.

func EntityID

func EntityID() string

EntityID attempts to return the container ID or the cgroup node controller's inode if the container ID is not available. The cid is prefixed with `cid-` and the inode with `in-`.

func FloatEnv

func FloatEnv(key string, def float64) float64

FloatEnv returns the parsed float64 value of an environment variable, or def otherwise.

func ForEachStringTag

func ForEachStringTag(str string, fn func(key string, val string))

ForEachStringTag runs fn on every key:val pair encountered in str. str may contain multiple key:val pairs separated by either space or comma (but not a mixture of both).

func GetGitMetadataTags

func GetGitMetadataTags() map[string]string

GetGitMetadataTags returns git metadata tags

func GetTracerGitMetadataTags

func GetTracerGitMetadataTags() map[string]string

GetTracerGitMetadataTags returns git metadata tags for tracer NB: Currently tracer inject tags with some workaround (only with _dd prefix and only for the first span in payload) So we provide different tag names

func IntEnv

func IntEnv(key string, def int) int

IntEnv returns the parsed int value of an environment variable, or def otherwise.

func IsExecutionTraced

func IsExecutionTraced(ctx context.Context) bool

IsExecutionTraced returns whether ctx is associated with an execution trace task, as indicated via WithExecutionTraced

func ParseTagString

func ParseTagString(str string) map[string]string

ParseTagString returns tags parsed from string as map

func ResetGitMetadataTags

func ResetGitMetadataTags()

ResetGitMetadataTags reset cashed metadata tags

func WithExecutionNotTraced

func WithExecutionNotTraced(ctx context.Context) context.Context

WithExecutionNotTraced marks that the context is *not* covered by an execution trace task. This is intended to prevent child spans (which inherit information from ctx) from being considered covered by a task, when an integration may create its own child span with its own execution trace task.

func WithExecutionTraced

func WithExecutionTraced(ctx context.Context) context.Context

WithExecutionTraced marks ctx as being associated with an execution trace task. It is assumed that ctx already contains a trace task. The caller is responsible for ending the task.

This is intended for a specific case where the database/sql contrib package only creates spans *after* an operation, in case the operation was unavailable, and thus execution trace tasks tied to the span only capture the very end. This function enables creating a task *before* creating a span, and communicating to the APM tracer that it does not need to create a task. In general, APM instrumentation should prefer creating tasks around the operation rather than after the fact, if possible.

Types

type Count

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

Count implements the Stat interface and contains a int64 value

func NewCount

func NewCount(name string, value int64, tags []string, rate float64) Count

func (Count) Name

func (c Count) Name() string

func (Count) Rate

func (c Count) Rate() float64

func (Count) Tags

func (c Count) Tags() []string

func (Count) Value

func (c Count) Value() interface{}

type Gauge

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

Gauge implements the Stat interface and contains a float64 value

func NewGauge

func NewGauge(name string, value float64, tags []string, rate float64) Gauge

func (Gauge) Name

func (g Gauge) Name() string

func (Gauge) Rate

func (g Gauge) Rate() float64

func (Gauge) Tags

func (g Gauge) Tags() []string

func (Gauge) Value

func (g Gauge) Value() interface{}

type LockMap

type LockMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

LockMap uses an RWMutex to synchronize map access to allow for concurrent access. This should not be used for cases with heavy write load and performance concerns.

func NewLockMap

func NewLockMap(m map[string]string) *LockMap

func (*LockMap) Clear

func (l *LockMap) Clear()

func (*LockMap) Get

func (l *LockMap) Get(k string) string

func (*LockMap) Iter

func (l *LockMap) Iter(f func(key string, val string))

Iter iterates over all the map entries passing in keys and values to provided func f. Note this is READ ONLY.

func (*LockMap) Len

func (l *LockMap) Len() int

func (*LockMap) Set

func (l *LockMap) Set(k, v string)

type Stat

type Stat interface {
	Name() string
	Value() interface{}
	Tags() []string
	Rate() float64
}

type StatsCarrier

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

StatsCarrier collects stats on its contribStats channel and submits them through a statsd client

func NewStatsCarrier

func NewStatsCarrier(statsd StatsdClient) *StatsCarrier

func (*StatsCarrier) Add

func (sc *StatsCarrier) Add(s Stat)

Add pushes the Stat, s, onto the StatsCarrier's contribStats channel

func (*StatsCarrier) Start

func (sc *StatsCarrier) Start()

Start runs the StatsCarrier in a goroutine The caller of sc.Start() is resopnsible for calling sc.Stop()

func (*StatsCarrier) Stop

func (sc *StatsCarrier) Stop()

Stop closes the StatsCarrier's stop channel

type StatsdClient

type StatsdClient interface {
	Incr(name string, tags []string, rate float64) error
	Count(name string, value int64, tags []string, rate float64) error
	Gauge(name string, value float64, tags []string, rate float64) error
	Timing(name string, value time.Duration, tags []string, rate float64) error
	Flush() error
	Close() error
}

type Timing

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

Timing implements the Stat interface and contains a time.Duration value

func NewTiming

func NewTiming(name string, value time.Duration, tags []string, rate float64) Timing

func (Timing) Name

func (t Timing) Name() string

func (Timing) Rate

func (t Timing) Rate() float64

func (Timing) Tags

func (t Timing) Tags() []string

func (Timing) Value

func (t Timing) Value() interface{}