telemetry

Documentation

Index

• type Provider
  • func Initialize(ctx context.Context, serviceName, serviceVersion string) (*Provider, error)
  • func (p *Provider) RecordConversionDuration(ctx context.Context, duration time.Duration, inputFormat, outputFormat string)
  • func (p *Provider) RecordFileFailed(ctx context.Context, fileType string, errorType string)
  • func (p *Provider) RecordFileProcessed(ctx context.Context, fileType, format string, fileSize int64)
  • func (p *Provider) RecordProcessingDuration(ctx context.Context, duration time.Duration, fileType string, success bool)
  • func (p *Provider) Shutdown(ctx context.Context) error
  • func (p *Provider) StartSpan(ctx context.Context, name string, attrs ...attribute.KeyValue) (context.Context, trace.Span)

Types

type Provider

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

Provider manages OpenTelemetry tracing and metrics

func Initialize

func Initialize(ctx context.Context, serviceName, serviceVersion string) (*Provider, error)

Initialize sets up OpenTelemetry with OTLP exporters

func (*Provider) RecordConversionDuration

func (p *Provider) RecordConversionDuration(ctx context.Context, duration time.Duration, inputFormat, outputFormat string)

RecordConversionDuration records the duration of a conversion operation

func (*Provider) RecordFileFailed

func (p *Provider) RecordFileFailed(ctx context.Context, fileType string, errorType string)

RecordFileFailed records a failed file processing

func (*Provider) RecordFileProcessed

func (p *Provider) RecordFileProcessed(ctx context.Context, fileType, format string, fileSize int64)

RecordFileProcessed records a successfully processed file

func (*Provider) RecordProcessingDuration

func (p *Provider) RecordProcessingDuration(ctx context.Context, duration time.Duration, fileType string, success bool)

RecordProcessingDuration records the duration of a processing operation

func (*Provider) Shutdown

func (p *Provider) Shutdown(ctx context.Context) error

Shutdown cleanly shuts down the telemetry providers

func (*Provider) StartSpan

func (p *Provider) StartSpan(ctx context.Context, name string, attrs ...attribute.KeyValue) (context.Context, trace.Span)

StartSpan creates a new span with the given name