tracing

Documentation

Index

• Constants
• func NewJaegerTracer(jaegerConfig *Config, log logger.Logger) (opentracing.Tracer, io.Closer, error)
• func SetDefaultNeo4jRepositorySpanTags(ctx context.Context, span opentracing.Span)
• func SetDefaultPostgresRepositorySpanTags(ctx context.Context, span opentracing.Span)
• func SetDefaultSyncServiceSpanTags(ctx context.Context, span opentracing.Span)
• func StartTracerSpan(ctx context.Context, operationName string) (opentracing.Span, context.Context)
• func TraceErr(span opentracing.Span, err error)
• type Config

Constants

const (
	SpanTagTenant    = "tenant"
	SpanTagComponent = "component"
	SpanTagSource    = "source"
)

const ComponentNeo4jRepository = "neo4jRepository"

const ComponentPostgresRepository = "postgresRepository"

const ComponentSyncService = "syncService"

Functions

func NewJaegerTracer

func NewJaegerTracer(jaegerConfig *Config, log logger.Logger) (opentracing.Tracer, io.Closer, error)

func SetDefaultNeo4jRepositorySpanTags

func SetDefaultNeo4jRepositorySpanTags(ctx context.Context, span opentracing.Span)

func SetDefaultPostgresRepositorySpanTags

func SetDefaultPostgresRepositorySpanTags(ctx context.Context, span opentracing.Span)

func SetDefaultSyncServiceSpanTags

func SetDefaultSyncServiceSpanTags(ctx context.Context, span opentracing.Span)

func StartTracerSpan

func StartTracerSpan(ctx context.Context, operationName string) (opentracing.Span, context.Context)

func TraceErr

func TraceErr(span opentracing.Span, err error)

Types

type Config

type Config struct {
	ServiceName  string  `env:"JAEGER_SERVICE_NAME" envDefault:"sync-customer-os-data" validate:"required"`
	AgentHost    string  `env:"JAEGER_AGENT_HOST" envDefault:"localhost" validate:"required"`
	AgentPort    string  `env:"JAEGER_AGENT_PORT" envDefault:"6831" validate:"required"`
	Enabled      bool    `env:"JAEGER_ENABLED" envDefault:"true"`
	LogSpans     bool    `env:"JAEGER_REPORTER_LOG_SPANS" envDefault:"true" `
	SamplerType  string  `env:"JAEGER_SAMPLER_TYPE" envDefault:"probabilistic" validate:"required"`
	SamplerParam float64 `env:"JAEGER_SAMPLER_PARAM" envDefault:"0.01" validate:"required"`
}