opentelemetry

Documentation

Index

• type OpenTelemetry
  • func GetOpenTelemetrySingleton() (*OpenTelemetry, error)
  • func (o *OpenTelemetry) Extract(ctx context.Context, headers http.Header) context.Context
  • func (o *OpenTelemetry) ExtractByGrpcCtx(ctx context.Context) context.Context
  • func (o *OpenTelemetry) GetCtx(ctx context.Context, traceID, spanID string) context.Context
  • func (o *OpenTelemetry) InitProvider() error
  • func (o *OpenTelemetry) Inject(ctx context.Context, headers http.Header)
  • func (o *OpenTelemetry) InvokeFunc(ctx context.Context, spanName string, ...) (any, error)
  • func (o *OpenTelemetry) Shutdown()
  • func (o *OpenTelemetry) Start(ctx context.Context, spanName string) (context.Context, trace.Span)
• type OpenTelemetryIOCInterface
  • func GetOpenTelemetryIOCInterfaceSingleton() (OpenTelemetryIOCInterface, error)
• type ThisOpenTelemetry
  • func (t *ThisOpenTelemetry) This() OpenTelemetryIOCInterface

Types

type OpenTelemetry

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

func GetOpenTelemetrySingleton

func GetOpenTelemetrySingleton() (*OpenTelemetry, error)

func (*OpenTelemetry) Extract

func (o *OpenTelemetry) Extract(ctx context.Context, headers http.Header) context.Context

func (*OpenTelemetry) ExtractByGrpcCtx

func (o *OpenTelemetry) ExtractByGrpcCtx(ctx context.Context) context.Context

func (*OpenTelemetry) GetCtx

func (o *OpenTelemetry) GetCtx(ctx context.Context, traceID, spanID string) context.Context

func (*OpenTelemetry) InitProvider

func (o *OpenTelemetry) InitProvider() error

func (*OpenTelemetry) Inject

func (o *OpenTelemetry) Inject(ctx context.Context, headers http.Header)

func (*OpenTelemetry) InvokeFunc

func (o *OpenTelemetry) InvokeFunc(ctx context.Context, spanName string, fn func(context.Context, any) (any, error), args any) (any, error)

func (*OpenTelemetry) Shutdown

func (o *OpenTelemetry) Shutdown()

func (*OpenTelemetry) Start

func (o *OpenTelemetry) Start(ctx context.Context, spanName string) (context.Context, trace.Span)

type OpenTelemetryIOCInterface

type OpenTelemetryIOCInterface interface {
	Shutdown()
	InitProvider() error
	Start(ctx contextx.Context, spanName string) (contextx.Context, trace.Span)
	InvokeFunc(ctx contextx.Context, spanName string, fn func(contextx.Context, any) (any, error), args any) (any, error)
	Inject(ctx contextx.Context, headers http.Header)
	Extract(ctx contextx.Context, headers http.Header) contextx.Context
	ExtractByGrpcCtx(ctx contextx.Context) contextx.Context
	GetCtx(ctx contextx.Context, traceID, spanID string) contextx.Context
}

func GetOpenTelemetryIOCInterfaceSingleton

func GetOpenTelemetryIOCInterfaceSingleton() (OpenTelemetryIOCInterface, error)

type ThisOpenTelemetry

type ThisOpenTelemetry struct {
}

func (*ThisOpenTelemetry) This

func (t *ThisOpenTelemetry) This() OpenTelemetryIOCInterface