instrument

Documentation

Index

• func AfterEndHook(tracer opentracing.Tracer) scope.ScopeOperationHook
• func BeforeStartHook(tracer opentracing.Tracer) scope.ScopeOperationHook
• func CliRunnerTracingProvider() fx.Annotated
• func GinTracing(tracer opentracing.Tracer, opName string, excludes web.RequestMatcher) gin.HandlerFunc
• func GormTracingProvider() fx.Annotated
• func HttpClientTracingProvider() fx.Annotated
• func KafkaTracingTracingProvider() fx.Annotated
• func MakeBootstrapTracingOption(tracer opentracing.Tracer, opName string) bootstrap.ContextOption
• func MakeStartTracingOption(tracer opentracing.Tracer, opName string) bootstrap.ContextOption
• func MakeStopTracingOption(tracer opentracing.Tracer, opName string) bootstrap.ContextOption
• func NewRedisTrackingHook(tracer opentracing.Tracer) *redisTracingHook
• func NewVaultTracingHook(tracer opentracing.Tracer) *vaultTracingHook
• func OpenSearchTracingProvider() fx.Annotated
• func SecurityScopeTracingProvider() fx.Annotated
• type OpenSearchTracer
  • func OpenSearchTracerHook(tracer opentracing.Tracer) *OpenSearchTracer
  • func (o *OpenSearchTracer) After(ctx context.Context, afterContext opensearch.AfterContext) context.Context
  • func (o *OpenSearchTracer) Before(ctx context.Context, before opensearch.BeforeContext) context.Context
• type TracingTaskHook
  • func NewTracingTaskHook(tracer opentracing.Tracer) *TracingTaskHook
  • func (h *TracingTaskHook) AfterTrigger(ctx context.Context, _ string, err error)
  • func (h *TracingTaskHook) BeforeTrigger(ctx context.Context, id string) context.Context
• type TracingWebCustomizer
  • func NewTracingWebCustomizer(tracer opentracing.Tracer) *TracingWebCustomizer
  • func (c *TracingWebCustomizer) Customize(_ context.Context, r *web.Registrar) error
  • func (c TracingWebCustomizer) Order() int

Functions

func AfterEndHook

func AfterEndHook(tracer opentracing.Tracer) scope.ScopeOperationHook

func BeforeStartHook

func BeforeStartHook(tracer opentracing.Tracer) scope.ScopeOperationHook

func CliRunnerTracingProvider

func CliRunnerTracingProvider() fx.Annotated

func GinTracing

func GinTracing(tracer opentracing.Tracer, opName string, excludes web.RequestMatcher) gin.HandlerFunc

func GormTracingProvider

func GormTracingProvider() fx.Annotated

func HttpClientTracingProvider

func HttpClientTracingProvider() fx.Annotated

func KafkaTracingTracingProvider

func KafkaTracingTracingProvider() fx.Annotated

func MakeBootstrapTracingOption

func MakeBootstrapTracingOption(tracer opentracing.Tracer, opName string) bootstrap.ContextOption

func MakeStartTracingOption

func MakeStartTracingOption(tracer opentracing.Tracer, opName string) bootstrap.ContextOption

func MakeStopTracingOption

func MakeStopTracingOption(tracer opentracing.Tracer, opName string) bootstrap.ContextOption

func NewRedisTrackingHook

func NewRedisTrackingHook(tracer opentracing.Tracer) *redisTracingHook

func NewVaultTracingHook

func NewVaultTracingHook(tracer opentracing.Tracer) *vaultTracingHook

func OpenSearchTracingProvider

func OpenSearchTracingProvider() fx.Annotated

func SecurityScopeTracingProvider

func SecurityScopeTracingProvider() fx.Annotated

Types

type OpenSearchTracer

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

OpensearchTracer will provide some opensearch.HookContainer to provide tracing

func OpenSearchTracerHook

func OpenSearchTracerHook(tracer opentracing.Tracer) *OpenSearchTracer

func (*OpenSearchTracer) After

func (o *OpenSearchTracer) After(ctx context.Context, afterContext opensearch.AfterContext) context.Context

func (*OpenSearchTracer) Before

func (o *OpenSearchTracer) Before(ctx context.Context, before opensearch.BeforeContext) context.Context

type TracingTaskHook

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

func NewTracingTaskHook

func NewTracingTaskHook(tracer opentracing.Tracer) *TracingTaskHook

func (*TracingTaskHook) AfterTrigger

func (h *TracingTaskHook) AfterTrigger(ctx context.Context, _ string, err error)

func (*TracingTaskHook) BeforeTrigger

func (h *TracingTaskHook) BeforeTrigger(ctx context.Context, id string) context.Context

type TracingWebCustomizer

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

func NewTracingWebCustomizer

func NewTracingWebCustomizer(tracer opentracing.Tracer) *TracingWebCustomizer

func (*TracingWebCustomizer) Customize

func (c *TracingWebCustomizer) Customize(_ context.Context, r *web.Registrar) error

func (TracingWebCustomizer) Order

func (c TracingWebCustomizer) Order() int

Order we want TracingWebCustomizer before anything else