package detect

import "github.com/moby/buildkit/util/tracing/detect"

Index ¶

• Variables
• func IsNoneMetricExporter(exp sdkmetric.Exporter) bool
• func IsNoneSpanExporter(exp sdktrace.SpanExporter) bool
• func NewMetricExporter(_ context.Context) (sdkmetric.Exporter, error)
• func NewSpanExporter(_ context.Context) (sdktrace.SpanExporter, error)
• func OverrideResource(res *resource.Resource)
• func Register(name string, exp ExporterDetector, priority int)
• func Resource() *resource.Resource
• type ExporterDetector
• type TraceExporterDetector
• func (fn TraceExporterDetector) DetectMetricExporter() (sdkmetric.Exporter, error)
• func (fn TraceExporterDetector) DetectTraceExporter() (sdktrace.SpanExporter, error)
• type TraceRecorder
• func NewTraceRecorder() *TraceRecorder
• func (r *TraceRecorder) ExportSpans(ctx context.Context, spans []sdktrace.ReadOnlySpan) error
• func (r *TraceRecorder) Record(ctx context.Context) (func() []tracetest.SpanStub, error)
• func (r *TraceRecorder) Shutdown(ctx context.Context) error

Variables ¶

var (
	ServiceName string
)

Functions ¶

func IsNoneMetricExporter ¶

func IsNoneMetricExporter(exp sdkmetric.Exporter) bool

func IsNoneSpanExporter ¶

func IsNoneSpanExporter(exp sdktrace.SpanExporter) bool

func NewMetricExporter ¶

func NewMetricExporter(_ context.Context) (sdkmetric.Exporter, error)

func NewSpanExporter ¶

func NewSpanExporter(_ context.Context) (sdktrace.SpanExporter, error)

func OverrideResource ¶

func OverrideResource(res *resource.Resource)

OverrideResource overrides the resource returned from Resource.

This must be invoked before Resource is called otherwise it is a no-op.

func Register ¶

func Register(name string, exp ExporterDetector, priority int)

func Resource ¶

func Resource() *resource.Resource

Types ¶

type ExporterDetector ¶

type ExporterDetector interface {
	DetectTraceExporter() (sdktrace.SpanExporter, error)
	DetectMetricExporter() (sdkmetric.Exporter, error)
}

type TraceExporterDetector ¶

type TraceExporterDetector func() (sdktrace.SpanExporter, error)

func (TraceExporterDetector) DetectMetricExporter ¶

func (fn TraceExporterDetector) DetectMetricExporter() (sdkmetric.Exporter, error)

func (TraceExporterDetector) DetectTraceExporter ¶

func (fn TraceExporterDetector) DetectTraceExporter() (sdktrace.SpanExporter, error)

type TraceRecorder ¶

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

var Recorder *TraceRecorder

func NewTraceRecorder ¶

func NewTraceRecorder() *TraceRecorder

func (*TraceRecorder) ExportSpans ¶

func (r *TraceRecorder) ExportSpans(ctx context.Context, spans []sdktrace.ReadOnlySpan) error

func (*TraceRecorder) Record ¶

func (r *TraceRecorder) Record(ctx context.Context) (func() []tracetest.SpanStub, error)

Record signals to the TraceRecorder that it should track spans associated with the current trace and returns a function that will return these spans.

If the TraceRecorder is nil or there is no valid active span, the returned function will be nil to signal that the trace cannot be recorded.

func (*TraceRecorder) Shutdown ¶

func (r *TraceRecorder) Shutdown(ctx context.Context) error

Source Files ¶

detect.go otlp.go recorder.go resource.go

Directories ¶