Documentation ¶
Index ¶
- func Version() string
- type AlwaysOffSampler
- type AlwaysOnSampler
- type ConfigProvider
- type Instrumentation
- type InstrumentationConfig
- type InstrumentationLibrary
- type InstrumentationLibraryID
- type InstrumentationOption
- func WithConfigProvider(cp ConfigProvider) InstrumentationOption
- func WithEnv() InstrumentationOption
- func WithGlobal() InstrumentationOption
- func WithLoadedIndicator(indicator chan struct{}) InstrumentationOption
- func WithLogger(logger *slog.Logger) InstrumentationOption
- func WithPID(pid int) InstrumentationOption
- func WithResourceAttributes(attrs ...attribute.KeyValue) InstrumentationOption
- func WithSampler(sampler Sampler) InstrumentationOption
- func WithServiceName(serviceName string) InstrumentationOption
- func WithTarget(path string) InstrumentationOption
- func WithTraceExporter(exp trace.SpanExporter) InstrumentationOption
- type ParentBasedSampler
- type Sampler
- type TraceIDRatioSampler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AlwaysOffSampler ¶
type AlwaysOffSampler struct{}
AlwaysOffSampler returns a Sampler that samples no traces.
type AlwaysOnSampler ¶
type AlwaysOnSampler struct{}
AlwaysOnSampler is a Sampler that samples every trace. Be careful about using this sampler in a production application with significant traffic: a new trace will be started and exported for every request.
type ConfigProvider ¶
type ConfigProvider interface { // InitialConfig returns the initial instrumentation configuration. InitialConfig(ctx context.Context) InstrumentationConfig // Watch returns a channel that receives updates to the instrumentation configuration. Watch() <-chan InstrumentationConfig // Shutdown releases any resources held by the provider. // It is an error to send updates after Shutdown is called. Shutdown(ctx context.Context) error }
ConfigProvider provides the initial configuration and updates to the instrumentation configuration.
type Instrumentation ¶
type Instrumentation struct {
// contains filtered or unexported fields
}
Instrumentation manages and controls all OpenTelemetry Go auto-instrumentation.
func NewInstrumentation ¶
func NewInstrumentation(ctx context.Context, opts ...InstrumentationOption) (*Instrumentation, error)
NewInstrumentation returns a new Instrumentation configured with the provided opts.
If conflicting or duplicate options are provided, the last one will have precedence and be used.
func (*Instrumentation) Close ¶
func (i *Instrumentation) Close() error
Close closes the Instrumentation, cleaning up all used resources.
type InstrumentationConfig ¶
type InstrumentationConfig struct { // InstrumentationLibraryConfigs defines library-specific configuration. // If a package is referenced by more than one key, the most specific key is used. // For example, if ("net/http", unspecified) and ("net/http", client) are both present, // the configuration for ("net/http", client) is used for client spans and the configuration for ("net/http", unspecified) is used for server spans. InstrumentationLibraryConfigs map[InstrumentationLibraryID]InstrumentationLibrary // DefaultTracesDisabled determines whether traces are disabled by default. // If set to true, traces are disabled by default for all libraries, unless the library is explicitly enabled. // If set to false, traces are enabled by default for all libraries, unless the library is explicitly disabled. // default is false - traces are enabled by default. DefaultTracesDisabled bool // Sampler is used to determine whether a trace should be sampled and exported. Sampler Sampler }
InstrumentationConfig is used to configure instrumentation.
type InstrumentationLibrary ¶
type InstrumentationLibrary struct { // TracesEnabled determines whether traces are enabled for the instrumentation library. // if nil - take DefaultTracesDisabled value. TracesEnabled *bool }
InstrumentationLibrary is used to configure instrumentation for a specific library.
type InstrumentationLibraryID ¶
type InstrumentationLibraryID struct { // Name of the instrumentation pkg (e.g. "net/http"). InstrumentedPkg string // SpanKind is the relevant span kind for the instrumentation. // This can be used to configure server-only, client-only spans. // If not set, the identifier is assumed to be applicable to all span kinds relevant to the instrumented package. SpanKind trace.SpanKind }
InstrumentationLibraryID is used to identify an instrumentation library.
type InstrumentationOption ¶
type InstrumentationOption interface {
// contains filtered or unexported methods
}
InstrumentationOption applies a configuration option to Instrumentation.
func WithConfigProvider ¶
func WithConfigProvider(cp ConfigProvider) InstrumentationOption
WithConfigProvider returns an InstrumentationOption that will configure an Instrumentation to use the provided ConfigProvider. The ConfigProvider is used to provide the initial configuration and update the configuration of the instrumentation in runtime.
func WithEnv ¶
func WithEnv() InstrumentationOption
WithEnv returns an InstrumentationOption that will configure Instrumentation using the values defined by the following environment variables:
- OTEL_GO_AUTO_TARGET_EXE: sets the target binary
- OTEL_SERVICE_NAME (or OTEL_RESOURCE_ATTRIBUTES): sets the service name
- OTEL_TRACES_EXPORTER: sets the trace exporter
- OTEL_GO_AUTO_GLOBAL: enables the OpenTelemetry global implementation
- OTEL_LOG_LEVEL: sets the default logger's minimum logging level
- OTEL_TRACES_SAMPLER: sets the trace sampler
- OTEL_TRACES_SAMPLER_ARG: optionally sets the trace sampler argument
This option may conflict with WithTarget, WithPID, WithTraceExporter, WithServiceName, WithGlobal, and WithSampler if their respective environment variable is defined. If more than one of these options are used, the last one provided to an Instrumentation will be used.
If WithLogger is used, OTEL_LOG_LEVEL will not be used for the Instrumentation logger. Instead, the slog.Logger passed to that option will be used as-is.
If WithLogger is not used, OTEL_LOG_LEVEL will be parsed and the default logger used by the configured Instrumentation will use that level as its minimum logging level.
The OTEL_TRACES_EXPORTER environment variable value is resolved using the autoexport package. See that package's documentation for information on supported values and registration of custom exporters.
func WithGlobal ¶
func WithGlobal() InstrumentationOption
WithGlobal returns an InstrumentationOption that will configure an Instrumentation to record telemetry from the OpenTelemetry default global implementation. By default, the OpenTelemetry global implementation is a no-op implementation of the OpenTelemetry API. However, by using this option, all telemetry that would have been dropped by the global implementation will be recorded using telemetry pipelines from the configured Instrumentation.
If the target process overrides the default global implementation (e.g. [otel.SetTracerProvider]), the telemetry from that process will go to the set implementation. It will not be recorded using the telemetry pipelines from the configured Instrumentation even if this option is used.
The OpenTelemetry default global implementation is left unchanged (i.e. it remains a no-op implementation) if this options is not used.
If OTEL_GO_AUTO_GLOBAL is defined, this option will conflict with WithEnv. If both are used, the last one provided to an Instrumentation will be used.
func WithLoadedIndicator ¶
func WithLoadedIndicator(indicator chan struct{}) InstrumentationOption
WithLoadedIndicator returns an InstrumentationOption that will configure an Instrumentation to close the provided indicator channel when the target process has been instrumented (i.e. all probes have been loaded). The provided indicator channel needs to be initialized by the caller.
func WithLogger ¶
func WithLogger(logger *slog.Logger) InstrumentationOption
WithLogger returns an InstrumentationOption that will configure an Instrumentation to use the provided logger.
If this option is used and WithEnv is also used, OTEL_LOG_LEVEL is ignored by the configured Instrumentation. This passed logger takes precedence and is used as-is.
If this option is not used, the Instrumentation will use an slog.Loogger backed by an slog.JSONHandler outputting to STDERR as a default.
func WithPID ¶
func WithPID(pid int) InstrumentationOption
WithPID returns an InstrumentationOption defining the target binary for Instrumentation that is being run with the provided PID.
This option conflicts with WithTarget. If both are used, the last one provided to an Instrumentation will be used.
If multiple of these options are provided to an Instrumentation, the last one will be used.
If OTEL_GO_AUTO_TARGET_EXE is defined, this option will conflict with WithEnv. If both are used, the last one provided to an Instrumentation will be used.
func WithResourceAttributes ¶
func WithResourceAttributes(attrs ...attribute.KeyValue) InstrumentationOption
WithResourceAttributes returns an InstrumentationOption that will configure an Instrumentation to add the provided attributes to the OpenTelemetry resource.
func WithSampler ¶
func WithSampler(sampler Sampler) InstrumentationOption
WithSampler returns an InstrumentationOption that will configure an Instrumentation to use the provided sampler to sample OpenTelemetry traces.
This currently is a no-op. It is expected to take effect in the next release.
func WithServiceName ¶
func WithServiceName(serviceName string) InstrumentationOption
WithServiceName returns an InstrumentationOption defining the name of the service running.
If multiple of these options are provided to an Instrumentation, the last one will be used.
If OTEL_SERVICE_NAME is defined or the service name is defined in OTEL_RESOURCE_ATTRIBUTES, this option will conflict with WithEnv. If both are used, the last one provided to an Instrumentation will be used.
func WithTarget ¶
func WithTarget(path string) InstrumentationOption
WithTarget returns an InstrumentationOption defining the target binary for Instrumentation that is being executed at the provided path.
This option conflicts with WithPID. If both are used, the last one provided to an Instrumentation will be used.
If multiple of these options are provided to an Instrumentation, the last one will be used.
If OTEL_GO_AUTO_TARGET_EXE is defined, this option will conflict with WithEnv. If both are used, the last one provided to an Instrumentation will be used.
func WithTraceExporter ¶
func WithTraceExporter(exp trace.SpanExporter) InstrumentationOption
WithTraceExporter returns an InstrumentationOption that will configure an Instrumentation to use the provided exp to export OpenTelemetry tracing telemetry.
If OTEL_TRACES_EXPORTER is defined, this option will conflict with WithEnv. If both are used, the last one provided to an Instrumentation will be used.
type ParentBasedSampler ¶
type ParentBasedSampler struct { // Root is the Sampler used when a span is created without a parent. Root Sampler // RemoteSampled is the Sampler used when the span parent is remote and sampled. RemoteSampled Sampler // RemoteNotSampled is the Sampler used when the span parent is remote and not sampled. RemoteNotSampled Sampler // LocalSampled is the Sampler used when the span parent is local and sampled. LocalSampled Sampler // LocalNotSampled is the Sampler used when the span parent is local and not sampled. LocalNotSampled Sampler }
ParentBasedSampler is a Sampler which behaves differently, based on the parent of the span. If the span has no parent, the Root sampler is used to make sampling decision. If the span has a parent, depending on whether the parent is remote and whether it is sampled, one of the following samplers will apply:
- RemoteSampled (default: [AlwaysOn])
- RemoteNotSampled (default: [AlwaysOff])
- LocalSampled (default: [AlwaysOn])
- LocalNotSampled (default: [AlwaysOff])
type Sampler ¶
type Sampler interface {
// contains filtered or unexported methods
}
Sampler decides whether a trace should be sampled and exported.
func DefaultSampler ¶
func DefaultSampler() Sampler
DefaultSampler returns a ParentBased sampler with the following defaults:
- Root: AlwaysOn
- RemoteSampled: AlwaysOn
- RemoteNotSampled: AlwaysOff
- LocalSampled: AlwaysOn
- LocalNotSampled: AlwaysOff
type TraceIDRatioSampler ¶
type TraceIDRatioSampler struct { // Fraction is the fraction of traces to sample. This value needs to be in the interval [0, 1]. Fraction float64 }
TraceIDRatioSampler samples a given fraction of traces. Fraction should be in the closed interval [0, 1]. To respect the parent trace's SampledFlag, the TraceIDRatioSampler sampler should be used as a delegate of a [ParentBased] sampler.
Directories ¶
Path | Synopsis |
---|---|
examples
module
|
|
httpPlusdb
Module
|
|
kafka-go
Module
|
|
kafka-go/consumer
Module
|
|
kafka-go/producer
Module
|
|
rolldice
Module
|
|
rolldice/user
Module
|
|
internal
|
|
pkg/instrumentation/probe
Package probe provides instrumentation probe types and definitions.
|
Package probe provides instrumentation probe types and definitions. |
pkg/structfield
Package structfield provides types to track struct field offsets.
|
Package structfield provides types to track struct field offsets. |
test/e2e/autosdk
Module
|
|
test/e2e/databasesql
Module
|
|
test/e2e/gin
Module
|
|
test/e2e/gorillamux
Module
|
|
test/e2e/grpc
Module
|
|
test/e2e/kafka-go
Module
|
|
test/e2e/nethttp
Module
|
|
test/e2e/otelglobal
Module
|
|
tools
Module
|
|
offsets-tracker
module
|
|
sdk
module
|
|
internal/telemetry/test
Module
|
|
telemetry/test
Module
|
|
test
|
|
e2e/gin
Module
|
|
e2e/gorillamux
Module
|
|
e2e/nethttp
Module
|