tracer

Jun 5, 2025

Changes in this version

+ const Customer

+ const DefaultBaggageHeader

+ const DefaultBaggageHeaderPrefix

+ const DefaultParentIDHeader

+ const DefaultPriorityHeader

+ const DefaultTraceIDHeader

+ const Dynamic

+ const EvpProxyPath

+ const Local

+ const SamplingRuleSpan

+ const SamplingRuleTrace

+ const SamplingRuleUndefined

+ const TestCyclePath

+ const TestCycleSubdomain

+ const TraceIDZero

+ var ErrInvalidCarrier = errors.New("invalid carrier")

+ var ErrInvalidSpanContext = errors.New("invalid span context")

+ var ErrSpanContextCorrupted = errors.New("span context corrupted")

+ var ErrSpanContextNotFound = errors.New("span context not found")

+ func ContextWithSpan(ctx context.Context, s *Span) context.Context

+ func EqualsFalseNegative(a, b []SamplingRule) bool

+ func Flush()

+ func Inject(ctx *SpanContext, carrier interface{}) error

+ func MarkIntegrationImported(integration string) bool

+ func SetDataStreamsCheckpoint(ctx context.Context, edgeTags ...string) (outCtx context.Context, ok bool)

+ func SetDataStreamsCheckpointWithParams(ctx context.Context, params options.CheckpointParams, edgeTags ...string) (outCtx context.Context, ok bool)

+ func SetUser(s *Span, id string, opts ...UserMonitoringOption)

+ func Start(opts ...StartOption) error

+ func Stop()

+ func TrackKafkaCommitOffset(group, topic string, partition int32, offset int64)

+ func TrackKafkaHighWatermarkOffset(cluster string, topic string, partition int32, offset int64)

+ func TrackKafkaProduceOffset(topic string, partition int32, offset int64)

+ func UseLogger(l Logger)

+ type Chunk struct

+ type DBMPropagationMode string

+ const DBMPropagationModeDisabled

+ const DBMPropagationModeFull

+ const DBMPropagationModeService

+ const DBMPropagationModeUndefined

+ type FinishConfig struct

+ Error error

+ FinishTime time.Time

+ NoDebugStack bool

+ SkipStackFrames uint

+ StackFrames uint

+ func NewFinishConfig(opts ...FinishOption) *FinishConfig

+ type FinishOption func(cfg *FinishConfig)

+ func FinishTime(t time.Time) FinishOption

+ func NoDebugStack() FinishOption

+ func StackFrames(n, skip uint) FinishOption

+ func WithError(err error) FinishOption

+ func WithFinishConfig(cfg *FinishConfig) FinishOption

+ type HTTPHeadersCarrier http.Header

+ func (c HTTPHeadersCarrier) ForeachKey(handler func(key, val string) error) error

+ func (c HTTPHeadersCarrier) Set(key, val string)

+ type LogLevel = log.Level

+ type Logger interface

+ Log func(msg string)

+ func AdaptLogger(fn func(lvl LogLevel, msg string, a ...any)) Logger

+ type Metadata struct

+ Hostname string

+ Language string

+ RuntimeID string

+ SchemaVersion uint8

+ ServiceEnvironment string

+ ServiceName string

+ ServiceVersion string

+ Version string

+ func (z *Metadata) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Metadata) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Metadata) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Metadata) Msgsize() (s int)

+ func (z *Metadata) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type NoopTracer struct

+ func (NoopTracer) Extract(_ interface{}) (*SpanContext, error)

+ func (NoopTracer) Flush()

+ func (NoopTracer) Inject(_ *SpanContext, _ interface{}) error

+ func (NoopTracer) SetServiceInfo(_, _, _ string)

+ func (NoopTracer) StartSpan(_ string, _ ...StartSpanOption) *Span

+ func (NoopTracer) Stop()

+ func (NoopTracer) Submit(*Span)

+ func (NoopTracer) SubmitChunk(*Chunk)

+ func (NoopTracer) TracerConf() TracerConf

+ type Propagator interface

+ Extract func(carrier interface{}) (*SpanContext, error)

+ Inject func(context *SpanContext, carrier interface{}) error

+ func NewPropagator(cfg *PropagatorConfig, propagators ...Propagator) Propagator

+ type PropagatorConfig struct

+ B3 bool

+ BaggageHeader string

+ BaggagePrefix string

+ MaxTagsHeaderLen int

+ ParentHeader string

+ PriorityHeader string

+ TraceHeader string

+ type RateSampler interface

+ Rate func() float64

+ SetRate func(rate float64)

+ func NewAllSampler() RateSampler

+ func NewRateSampler(rate float64) RateSampler

+ type Rule struct

+ MaxPerSecond float64

+ NameGlob string

+ Rate float64

+ ResourceGlob string

+ ServiceGlob string

+ Tags map[string]string

+ type SQLCommentCarrier struct

+ DBServiceName string

+ Mode DBMPropagationMode

+ PeerDBHostname string

+ PeerDBName string

+ PeerService string

+ Query string

+ SpanID uint64

+ func (c *SQLCommentCarrier) Extract() (*SpanContext, error)

+ func (c *SQLCommentCarrier) Inject(ctx *SpanContext) error

+ type Sampler interface

+ Sample func(span *Span) bool

+ type SamplingRule struct

+ MaxPerSecond float64

+ Name *regexp.Regexp

+ Provenance provenance

+ Rate float64

+ Resource *regexp.Regexp

+ Service *regexp.Regexp

+ Tags map[string]*regexp.Regexp

+ func SpanSamplingRules(rules ...Rule) []SamplingRule

+ func TraceSamplingRules(rules ...Rule) []SamplingRule

+ func (sr *SamplingRule) EqualsFalseNegative(other *SamplingRule) bool

+ func (sr *SamplingRule) UnmarshalJSON(b []byte) error

+ func (sr SamplingRule) MarshalJSON() ([]byte, error)

+ func (sr SamplingRule) String() string

+ type SamplingRuleType int

+ func (sr SamplingRuleType) String() string

+ type Span struct

+ func SpanFromContext(ctx context.Context) (*Span, bool)

+ func StartSpan(operationName string, opts ...StartSpanOption) *Span

+ func StartSpanFromContext(ctx context.Context, operationName string, opts ...StartSpanOption) (*Span, context.Context)

+ func (s *Span) AddEvent(name string, opts ...SpanEventOption)

+ func (s *Span) AddLink(link SpanLink)

+ func (s *Span) AsMap() map[string]interface{}

+ func (s *Span) BaggageItem(key string) string

+ func (s *Span) Context() *SpanContext

+ func (s *Span) Finish(opts ...FinishOption)

+ func (s *Span) Format(f fmt.State, c rune)

+ func (s *Span) Root() *Span

+ func (s *Span) SetBaggageItem(key, val string)

+ func (s *Span) SetOperationName(operationName string)

+ func (s *Span) SetTag(key string, value interface{})

+ func (s *Span) SetUser(id string, opts ...UserMonitoringOption)

+ func (s *Span) StartChild(operationName string, opts ...StartSpanOption) *Span

+ func (s *Span) String() string

+ func (z *Span) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Span) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Span) Msgsize() (s int)

+ type SpanContext struct

+ func Extract(carrier interface{}) (*SpanContext, error)

+ func FromGenericCtx(c ddtrace.SpanContext) *SpanContext

+ func (c *SpanContext) ForeachBaggageItem(handler func(k, v string) bool)

+ func (c *SpanContext) SamplingPriority() (p int, ok bool)

+ func (c *SpanContext) SpanID() uint64

+ func (c *SpanContext) SpanLinks() []SpanLink

+ func (c *SpanContext) TraceID() string

+ func (c *SpanContext) TraceIDBytes() [16]byte

+ func (c *SpanContext) TraceIDLower() uint64

+ func (c *SpanContext) TraceIDUpper() uint64

+ type SpanEventConfig struct

+ Attributes map[string]any

+ Time time.Time

+ type SpanEventOption func(cfg *SpanEventConfig)

+ func WithSpanEventAttributes(attributes map[string]any) SpanEventOption

+ func WithSpanEventTimestamp(tStamp time.Time) SpanEventOption

+ type SpanLink struct

+ Attributes map[string]string

+ Flags uint32

+ SpanID uint64

+ TraceID uint64

+ TraceIDHigh uint64

+ Tracestate string

+ func (z *SpanLink) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SpanLink) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *SpanLink) Msgsize() (s int)

+ type StartOption func(*config)

+ func WithAgentAddr(addr string) StartOption

+ func WithAgentTimeout(timeout int) StartOption

+ func WithAgentURL(agentURL string) StartOption

+ func WithAnalytics(on bool) StartOption

+ func WithAnalyticsRate(rate float64) StartOption

+ func WithAppSecEnabled(enabled bool) StartOption

+ func WithDebugMode(enabled bool) StartOption

+ func WithDebugSpansMode(timeout time.Duration) StartOption

+ func WithDebugStack(enabled bool) StartOption

+ func WithDogstatsdAddr(addr string) StartOption

+ func WithEnv(env string) StartOption

+ func WithFeatureFlags(feats ...string) StartOption

+ func WithGlobalServiceName(enabled bool) StartOption

+ func WithGlobalTag(k string, v interface{}) StartOption

+ func WithHTTPClient(client *http.Client) StartOption

+ func WithHeaderTags(headerAsTags []string) StartOption

+ func WithHostname(name string) StartOption

+ func WithLambdaMode(enabled bool) StartOption

+ func WithLogStartup(enabled bool) StartOption

+ func WithLogger(logger Logger) StartOption

+ func WithPartialFlushing(numSpans int) StartOption

+ func WithPeerServiceDefaults(enabled bool) StartOption

+ func WithPeerServiceMapping(from, to string) StartOption

+ func WithProfilerCodeHotspots(enabled bool) StartOption

+ func WithProfilerEndpoints(enabled bool) StartOption

+ func WithPropagator(p Propagator) StartOption

+ func WithRetryInterval(interval int) StartOption

+ func WithRuntimeMetrics() StartOption

+ func WithSampler(s Sampler) StartOption

+ func WithSamplerRate(rate float64) StartOption

+ func WithSamplingRules(rules []SamplingRule) StartOption

+ func WithSendRetries(retries int) StartOption

+ func WithService(name string) StartOption

+ func WithServiceMapping(from, to string) StartOption

+ func WithServiceVersion(version string) StartOption

+ func WithStatsComputation(enabled bool) StartOption

+ func WithTestDefaults(statsdClient any) StartOption

+ func WithTraceEnabled(enabled bool) StartOption

+ func WithUDS(socketPath string) StartOption

+ func WithUniversalVersion(version string) StartOption

+ type StartSpanConfig struct

+ Context context.Context

+ Parent *SpanContext

+ SpanID uint64

+ SpanLinks []SpanLink

+ StartTime time.Time

+ Tags map[string]interface{}

+ func NewStartSpanConfig(opts ...StartSpanOption) *StartSpanConfig

+ type StartSpanOption func(cfg *StartSpanConfig)

+ func AnalyticsRate(rate float64) StartSpanOption

+ func ChildOf(ctx *SpanContext) StartSpanOption

+ func Measured() StartSpanOption

+ func ResourceName(name string) StartSpanOption

+ func ServiceName(name string) StartSpanOption

+ func SpanType(name string) StartSpanOption

+ func StartTime(t time.Time) StartSpanOption

+ func Tag(k string, v interface{}) StartSpanOption

+ func WithSpanID(id uint64) StartSpanOption

+ func WithSpanLinks(links []SpanLink) StartSpanOption

+ func WithStartSpanConfig(cfg *StartSpanConfig) StartSpanOption

+ type TextMapCarrier map[string]string

+ func (c TextMapCarrier) ForeachKey(handler func(key, val string) error) error

+ func (c TextMapCarrier) Set(key, val string)

+ type TextMapReader interface

+ ForeachKey func(handler func(key, val string) error) error

+ type TextMapWriter interface

+ Set func(key, val string)

+ type Tracer interface

+ Extract func(carrier interface{}) (*SpanContext, error)

+ Flush func()

+ Inject func(context *SpanContext, carrier interface{}) error

+ StartSpan func(operationName string, opts ...StartSpanOption) *Span

+ Stop func()

+ TracerConf func() TracerConf

+ type TracerConf struct

+ CanComputeStats bool

+ CanDropP0s bool

+ DebugAbandonedSpans bool

+ Disabled bool

+ EnvTag string

+ PartialFlush bool

+ PartialFlushMinSpans int

+ PeerServiceDefaults bool

+ PeerServiceMappings map[string]string

+ ServiceTag string

+ TracingAsTransport bool

+ VersionTag string

+ type UserMonitoringConfig struct

+ Email string

+ Login string

+ Metadata map[string]string

+ Name string

+ Org string

+ PropagateID bool

+ Role string

+ Scope string

+ SessionID string

+ type UserMonitoringOption func(*UserMonitoringConfig)

+ func WithPropagation() UserMonitoringOption

+ func WithUserEmail(email string) UserMonitoringOption

+ func WithUserLogin(login string) UserMonitoringOption

+ func WithUserMetadata(key, value string) UserMonitoringOption

+ func WithUserName(name string) UserMonitoringOption

+ func WithUserOrg(org string) UserMonitoringOption

+ func WithUserRole(role string) UserMonitoringOption

+ func WithUserScope(scope string) UserMonitoringOption

+ func WithUserSessionID(sessionID string) UserMonitoringOption